Java-Codebeispiele für die WeChat-Klassifizierung zum Empfangen von Nachrichten und zum Erstellen von Entitäten

Dieser Artikel stellt hauptsächlich den dritten Schritt der Entwicklung der öffentlichen Java-WeChat-Plattform im Detail vor, die Klassifizierung empfangener Nachrichten und die Erstellung von Entitäten. Interessierte Freunde können sich darauf beziehen

Das vorherige Der Artikel erwähnte, dass der Anwendungsserver und der Tencent-Server über Nachrichten kommunizieren, und stellte kurz die Nachrichtentypen von WeChat-Beiträgen vor. Hier werden wir eine Nachrichtenentität einrichten, um unsere spätere Verwendung zu erleichtern!

(1) Basisklasse für Nachrichtenentitäten

package com.cuiyongzhi.wechat.message.req;
/**
 * ClassName: BaseMessage
 * @Description: 微信请求消息基本类
 * @author dapengniao
 * @date 2016年3月7日 下午3:03:59
 */
public class BaseMessage {
 // 开发者微信号
 private String ToUserName;
 // 发送方帐号（一个OpenID）
 private String FromUserName;
 // 消息创建时间 （整型）
 private long CreateTime;
 // 消息类型（text/image/location/link/video/shortvideo）
 private String MsgType;
 // 消息id，64位整型
 private long MsgId;
 
 public String getToUserName() {
  return ToUserName;
 }
 
 public void setToUserName(String toUserName) {
  ToUserName = toUserName;
 }
 
 public String getFromUserName() {
  return FromUserName;
 }
 
 public void setFromUserName(String fromUserName) {
  FromUserName = fromUserName;
 }
 
 public long getCreateTime() {
  return CreateTime;
 }
 
 public void setCreateTime(long createTime) {
  CreateTime = createTime;
 }
 
 public String getMsgType() {
  return MsgType;
 }
 
 public void setMsgType(String msgType) {
  MsgType = msgType;
 }
 
 public long getMsgId() {
  return MsgId;
 }
 
 public void setMsgId(long msgId) {
  MsgId = msgId;
 }
}

(2) Gewöhnliche Nachrichten-Pojo-Entität

①Bildnachricht

package com.cuiyongzhi.wechat.message.req;
 
/**
 * ClassName: ImageMessage
 * @Description: 图片消息
 * @author dapengniao
 * @date 2016年3月7日 下午3:04:52
 */
public class ImageMessage extends BaseMessage {
 // 图片链接
 private String PicUrl;
 
 public String getPicUrl() {
  return PicUrl;
 }
 
 public void setPicUrl(String picUrl) {
  PicUrl = picUrl;
 }
}

②Verbindungsnachricht

package com.cuiyongzhi.wechat.message.req;
 
/**
 * ClassName: LinkMessage
 * @Description: 连接消息
 * @author dapengniao
 * @date 2016年3月7日 下午3:05:48
 */
public class LinkMessage extends BaseMessage {
 // 消息标题
 private String Title;
 // 消息描述
 private String Description;
 // 消息链接
 private String Url;
 
 public String getTitle() {
  return Title;
 }
 
 public void setTitle(String title) {
  Title = title;
 }
 
 public String getDescription() {
  return Description;
 }
 
 public void setDescription(String description) {
  Description = description;
 }
 
 public String getUrl() {
  return Url;
 }
 
 public void setUrl(String url) {
  Url = url;
 }
}

③Geolocation-Nachricht

package com.cuiyongzhi.wechat.message.req;
 
/**
 * ClassName: LocationMessage
 * @Description: 地理位置消息
 * @author dapengniao
 * @date 2016年3月7日 下午3:06:10
 */
public class LocationMessage extends BaseMessage { 
 // 地理位置维度 
 private String Location_X; 
 // 地理位置经度 
 private String Location_Y; 
 // 地图缩放大小 
 private String Scale; 
 // 地理位置信息 
 private String Label; 
 public String getLocation_X() { 
  return Location_X; 
 } 
 public void setLocation_X(String location_X) { 
  Location_X = location_X; 
 } 
 public String getLocation_Y() { 
  return Location_Y; 
 } 
 public void setLocation_Y(String location_Y) { 
  Location_Y = location_Y; 
 } 
 public String getScale() { 
  return Scale; 
 } 
 public void setScale(String scale) { 
  Scale = scale; 
 } 
 public String getLabel() { 
  return Label; 
 } 
 public void setLabel(String label) { 
  Label = label; 
 } 
}

④Textnachricht

package com.cuiyongzhi.wechat.message.req;
 
/**
 * ClassName: TextMessage
 * @Description: 文本消息
 * @author dapengniao
 * @date 2016年3月7日 下午3:06:40
 */
public class TextMessage extends BaseMessage { 
 // 消息内容 
 private String Content; 
 public String getContent() { 
  return Content; 
 } 
 public void setContent(String content) { 
  Content = content; 
 } 
}

⑤ Video-/Kleinbildnachricht

package com.cuiyongzhi.wechat.message.req;
 
/**
 * ClassName: VideoMessage
 * @Description: 视频/小视屏消息
 * @author dapengniao
 * @date 2016年3月7日 下午3:12:51
 */
public class VideoMessage extends BaseMessage {
 private String MediaId; // 视频消息媒体id，可以调用多媒体文件下载接口拉取数据
 private String ThumbMediaId; // 视频消息缩略图的媒体id，可以调用多媒体文件下载接口拉取数据
 public String getMediaId() {
  return MediaId;
 }
 public void setMediaId(String mediaId) {
  MediaId = mediaId;
 }
 public String getThumbMediaId() {
  return ThumbMediaId;
 }
 public void setThumbMediaId(String thumbMediaId) {
  ThumbMediaId = thumbMediaId;
 }
}

⑥Sprachnachricht

package com.cuiyongzhi.wechat.message.req;
/**
 * ClassName: VoiceMessage
 * @Description: 语音消息
 * @author dapengniao
 * @date 2016年3月7日 下午3:07:10
 */
public class VoiceMessage extends BaseMessage { 
 // 媒体ID 
 private String MediaId; 
 // 语音格式 
 private String Format; 
 
 public String getMediaId() { 
  return MediaId; 
 } 
 public void setMediaId(String mediaId) { 
  MediaId = mediaId; 
 } 
 public String getFormat() { 
  return Format; 
 } 
 public void setFormat(String format) { 
  Format = format; 
 } 
}

(3) Nachrichtenklassifizierungsverarbeitung

Befolgen Sie die oben genannten Schritte, um die gewünschte Nachricht zu erhalten. Kategorien führen eine unterschiedliche Verteilung durch Hier haben wir unsere eigenen Geschäftsverteiler (EventDispatcher, MsgDispatcher) eingerichtet, um die normale Nachrichtenverarbeitung bzw. die Ereignisnachrichtenverarbeitung durchzuführen!

①MsgDispatcher.java – wird für die Geschäftsverteilungsverarbeitung gewöhnlicher Nachrichten verwendet

package com.cuiyongzhi.wechat.dispatcher;
import java.util.Map;
import com.cuiyongzhi.wechat.util.MessageUtil;
/**
 * ClassName: MsgDispatcher
 * @Description: 消息业务处理分发器
 * @author dapengniao
 * @date 2016年3月7日 下午4:04:21
 */
public class MsgDispatcher {
 public static String processMessage(Map<String, String> map) {
  if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) { // 文本消息
   System.out.println("==============这是文本消息！");
  }
   
  if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) { // 图片消息
   System.out.println("==============这是图片消息！");
  }
   
  if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) { // 链接消息
   System.out.println("==============这是链接消息！");
  }
   
  if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) { // 位置消息
   System.out.println("==============这是位置消息！");
  }
   
  if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_VIDEO)) { // 视频消息
   System.out.println("==============这是视频消息！");
  }  
   
  if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) { // 语音消息
   System.out.println("==============这是语音消息！");
  }
 
  return null;
 }
}

②EventDispatcher.java – Geschäftsverteilungsverarbeitung von Ereignisnachrichten

package com.cuiyongzhi.wechat.dispatcher;
 
import java.util.Map;
 
import com.cuiyongzhi.wechat.util.MessageUtil;
 
/**
 * ClassName: EventDispatcher
 * @Description: 事件消息业务分发器
 * @author dapengniao
 * @date 2016年3月7日 下午4:04:41
 */
public class EventDispatcher {
 public static String processEvent(Map<String, String> map) {
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) { //关注事件
   System.out.println("==============这是关注事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) { //取消关注事件
   System.out.println("==============这是取消关注事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_SCAN)) { //扫描二维码事件
   System.out.println("==============这是扫描二维码事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_LOCATION)) { //位置上报事件
   System.out.println("==============这是位置上报事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_CLICK)) { //自定义菜单点击事件
   System.out.println("==============这是自定义菜单点击事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_VIEW)) { //自定义菜单View事件
   System.out.println("==============这是自定义菜单View事件！");
  }
   
   
  return null;
 }
}

Zu diesem Zeitpunkt Wir Wir müssen einige Änderungen an der Post-Methode in unserem Nachrichtenportal [WechatSecurity.java] vornehmen. Das Endergebnis ist wie folgt:

package com.cuiyongzhi.wechat.controller;
 
import java.io.PrintWriter;
import java.util.Map;
 
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import org.apache.log4j.Logger;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
 
import com.cuiyongzhi.wechat.dispatcher.EventDispatcher;
import com.cuiyongzhi.wechat.dispatcher.MsgDispatcher;
import com.cuiyongzhi.wechat.util.MessageUtil;
import com.cuiyongzhi.wechat.util.SignUtil;
 
@Controller
@RequestMapping("/wechat")
public class WechatSecurity {
 private static Logger logger = Logger.getLogger(WechatSecurity.class);
 
 /**
  * 
  * @Description: 用于接收get参数，返回验证参数
  * @param @param request
  * @param @param response
  * @param @param signature
  * @param @param timestamp
  * @param @param nonce
  * @param @param echostr
  * @author dapengniao
  * @date 2016年3月4日 下午6:20:00
  */
 @RequestMapping(value = "security", method = RequestMethod.GET)
 public void doGet(
   HttpServletRequest request,
   HttpServletResponse response,
   @RequestParam(value = "signature", required = true) String signature,
   @RequestParam(value = "timestamp", required = true) String timestamp,
   @RequestParam(value = "nonce", required = true) String nonce,
   @RequestParam(value = "echostr", required = true) String echostr) {
  try {
   if (SignUtil.checkSignature(signature, timestamp, nonce)) {
    PrintWriter out = response.getWriter();
    out.print(echostr);
    out.close();
   } else {
    logger.info("这里存在非法请求！");
   }
  } catch (Exception e) {
   logger.error(e, e);
  }
 }
 
 /**
  * @Description: 接收微信端消息处理并做分发
  * @param @param request
  * @param @param response 
  * @author dapengniao
  * @date 2016年3月7日 下午4:06:47
  */
 @RequestMapping(value = "security", method = RequestMethod.POST)
 public void DoPost(HttpServletRequest request,HttpServletResponse response) {
  try{
   Map<String, String> map=MessageUtil.parseXml(request);
   String msgtype=map.get("MsgType");
   if(MessageUtil.REQ_MESSAGE_TYPE_EVENT.equals(msgtype)){
    EventDispatcher.processEvent(map); //进入事件处理
   }else{
    MsgDispatcher.processMessage(map); //进入消息处理
   }
  }catch(Exception e){
   logger.error(e,e);
  }
 }
}

Nachdem wir das Projekt erfolgreich ausgeführt haben, können wir unseren Erfolg überprüfen Senden verschiedener Arten von Nachrichten. Die Korrektheit der Nachrichtenklassifizierung, wie in der folgenden Abbildung dargestellt:

Schließlich wurden so viele neue Dateien erstellt ein Blick auf die Verzeichnisstruktur unseres gesamten Projekts:

Das obige ist der detaillierte Inhalt vonJava-Codebeispiele für die WeChat-Klassifizierung zum Empfangen von Nachrichten und zum Erstellen von Entitäten. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!