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 {
 // 開發(fā)者微信號
 private String ToUserName;
 // 發(fā)送方帳號（一個OpenID）
 private String FromUserName;
 // 消息創(chuàng)建時間 （整型）
 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 {
 // 消息標(biāo)題
 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; 
 // 地理位置經(jīng)度 
 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 { 
 // 消息內(nèi)容 
 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，可以調(diào)用多媒體文件下載接口拉取數(shù)據(jù)
 private String ThumbMediaId; // 視頻消息縮略圖的媒體id，可以調(diào)用多媒體文件下載接口拉取數(shù)據(jù)
 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: 消息業(yè)務(wù)處理分發(fā)器
 * @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: 事件消息業(yè)務(wù)分發(fā)器
 * @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)) { //關(guān)注事件
   System.out.println("==============這是關(guān)注事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) { //取消關(guān)注事件
   System.out.println("==============這是取消關(guān)注事件！");
  }
   
  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參數(shù)，返回驗證參數(shù)
  * @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: 接收微信端消息處理并做分發(fā)
  * @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); //進(jìn)入事件處理
   }else{
    MsgDispatcher.processMessage(map); //進(jìn)入消息處理
   }
  }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!