Java微信公眾平臺開發(fā)（3）接收消息的分類及實(shí)體的創(chuàng)建

更新時(shí)間：2017年04月20日 10:48:16 作者：dapengniao

這篇文章主要為大家詳細(xì)介紹了Java微信公眾平臺開發(fā)第三步，接收消息的分類及實(shí)體的創(chuàng)建，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

前面一篇有說道應(yīng)用服務(wù)器和騰訊服務(wù)器是通過消息進(jìn)行通訊的，并簡單介紹了微信端post的消息類型，這里我們將建立消息實(shí)體以方便我們后面的使用！

（一）消息實(shí)體基礎(chǔ)類

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ā)送方帳號（一個(gè)OpenID）
 private String FromUserName;
 // 消息創(chuàng)建時(shí)間 （整型）
 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;
 }
}

（二）普通消息pojo實(shí)體

①圖片消息

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;
 }
}

②連接消息

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;
 }
}

③地理位置消息

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; 
 } 
}

④文本消息

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; 
 } 
}

⑤視頻/小視屏消息

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;
 }
 
}

⑥語音消息

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; 
 } 
}

（三）消息分類處理

按照上面收到想消息類別分別做不同的分發(fā)處理，這里我們建立了自己的業(yè)務(wù)分發(fā)器（EventDispatcher、MsgDispatcher），分別做普通消息處理和事件消息處理！

①M(fèi)sgDispatcher.java——用于普通消息的業(yè)務(wù)分發(fā)處理

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——事件消息的業(yè)務(wù)分發(fā)處理

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)) { //位置上報(bào)事件
   System.out.println("==============這是位置上報(bào)事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_CLICK)) { //自定義菜單點(diǎn)擊事件
   System.out.println("==============這是自定義菜單點(diǎn)擊事件！");
  }
   
  if (map.get("Event").equals(MessageUtil.EVENT_TYPE_VIEW)) { //自定義菜單View事件
   System.out.println("==============這是自定義菜單View事件！");
  }
   
   
  return null;
 }
}

這個(gè)時(shí)候我們需要把我們的消息入口【W(wǎng)echatSecurity.java】中的post方法做些修改，最終結(jié)果如下：

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ù)，返回驗(yàn)證參數(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);
  }
 }
}

最后我們運(yùn)行成功項(xiàng)目之后我們可以通過發(fā)送不同類型的消息來驗(yàn)證我們的消息分類的正確性，如下圖所示：