前面一篇有说道应用服务器和腾讯服务器是通过消息进行通讯的，并简单介绍了微信端post的消息类型，这里我们将建立消息实体以方便我们后面的使用！

（一）消息实体基础类

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

（二）普通消息pojo实体

①图片消息

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 {
 // 消息标题
 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; 
 // 地理位置经度 
 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 { 
 // 消息内容 
 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，可以调用多媒体文件下载接口拉取数据
 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;
 }
 
}

⑥语音消息

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

（三）消息分类处理

按照上面收到想消息类别分别做不同的分发处理，这里我们建立了自己的业务分发器（EventDispatcher、MsgDispatcher），分别做普通消息处理和事件消息处理！

①MsgDispatcher.java——用于普通消息的业务分发处理

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——事件消息的业务分发处理

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

这个时候我们需要把我们的消息入口【WechatSecurity.java】中的post方法做些修改，最终结果如下：

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

最后我们运行成功项目之后我们可以通过发送不同类型的消息来验证我们的消息分类的正确性，如下图所示：

新建了这么多文件，最后来看下我们的整个项目的目录结构：

前面讲述的都是消息的接收，那么下一篇起将讲述【回复消息的分类及实体的创建】，感谢你的翻阅，如有疑问可以留言一起讨论！

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# java微信公众平台开发  # java微信接收消息分类  # java微信实体创建  # java web在高并发和分布式下实现订单号生成唯一的解决方案  # java网上图书商城（8）订单模块3  # java网上图书商城（7）订单模块2  # java网上图书商城（6）订单模块1  # javaweb图书商城设计之订单模块(5)  # 微信支付java版本之查询订单  # Java实现创建运行时类的对象操作示例  # 详解Java的内置异常以及创建自定义异常子类的方法  # 基于Java创建一个订单类代码实例  # 这是  # 下午  # 自定义  # 自己的  # 都是  # 整型  # 视屏  # 如有  # 这么多  # 腾讯  # 我们可以  # 帐号  # 这个时候  # 所示  # 下一篇  # 做些  # 不同类型  # 大家多多  # 如下图  # 并做 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： Laravel Docker环境搭建教程_Laravel Sail使用指南  Midjourney怎样加参数调细节_Midjourney参数调整技巧【指南】  javascript日期怎么处理_如何格式化输出  Laravel如何创建和注册中间件_Laravel中间件编写与应用流程  网站制作价目表怎么做,珍爱网婚介费用多少？  Laravel如何配置和使用缓存？（Redis代码示例）  php在windows下怎么调试_phpwindows环境调试操作说明【操作】  Laravel怎么使用Collection集合方法_Laravel数组操作高级函数pluck与map【手册】  如何用景安虚拟主机手机版绑定域名建站？  高端建站如何打造兼具美学与转化的品牌官网？  北京网页设计制作网站有哪些,继续教育自动播放怎么设置？  JS碰撞运动实现方法详解  Swift中switch语句区间和元组模式匹配  教你用AI将一段旋律扩展成一首完整的曲子  Linux安全能力提升路径_长期防护思维说明【指导】  Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程  Laravel怎么实现前端Toast弹窗提示_Laravel Session闪存数据Flash传递给前端【方法】  android nfc常用标签读取总结  详解Nginx + Tomcat 反向代理 负载均衡 集群 部署指南  深圳网站制作培训,深圳哪些招聘网站比较好？  儿童网站界面设计图片,中国少年儿童教育网站-怎么去注册？  Laravel的Blade指令怎么自定义_创建你自己的Laravel Blade Directives  安克发布新款氮化镓充电宝：体积缩小 30%，支持 200W 输出  教学论文网站制作软件有哪些,写论文用什么软件 ？  宙斯浏览器视频悬浮窗怎么开启 边看视频边操作其他应用教程  如何获取PHP WAP自助建站系统源码？  Laravel软删除怎么实现_Laravel Eloquent SoftDeletes功能使用教程  百度输入法ai组件怎么删除 百度输入法ai组件移除工具  Android自定义控件实现温度旋转按钮效果  网站制作免费,什么网站能看正片电影？  laravel怎么配置Redis作为缓存驱动_laravel Redis缓存配置教程  百度浏览器ai对话怎么关 百度浏览器ai聊天窗口隐藏  如何在云服务器上快速搭建个人网站？  微信小程序制作网站有哪些,微信小程序需要做网站吗？  Laravel怎么集成Log日志记录_Laravel单文件与每日日志配置及自定义通道【详解】  Laravel如何实现登录错误次数限制_Laravel自带LoginThrottles限流配置【方法】  网站建设整体流程解析，建站其实很容易！  购物网站制作费用多少,开办网上购物网站，需要办理哪些手续？  千库网官网入口推荐 千库网设计创意平台入口  Laravel如何连接多个数据库_Laravel多数据库连接配置与切换教程  Windows家庭版如何开启组策略(gpedit.msc)？（安装方法）  Laravel Telescope怎么调试_使用Laravel Telescope进行应用监控与调试  javascript中闭包概念与用法深入理解  如何在阿里云虚拟机上搭建网站？步骤解析与避坑指南  免费的流程图制作网站有哪些,2025年教师初级职称申报网上流程？  在Oracle关闭情况下如何修改spfile的参数  JS经典正则表达式笔试题汇总  微信小程序 HTTPS报错整理常见问题及解决方案  手机怎么制作网站教程步骤,手机怎么做自己的网页链接？  北京企业网站设计制作公司,北京铁路集团官方网站？