Java微信公众平台之消息管理

作者：无名有名我无名_593 | 2022-11-29 19:38

这篇文章主要为大家详细介绍了Java微信公众平台之消息管理的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

Java微信公众平台开发之消息管理，一定要先看下官方文档

微信消息管理分为接收普通消息、接收事件推送、发送消息(被动回复)、客服消息、群发消息、模板消息这几部分

一、接收普通消息

当普通微信用户向公众账号发消息时，微信服务器将POST消息的XML数据包到开发者填写的URL上。

关于MsgId,官方给出解释，相当于每个消息ID，关于重试的消息排重，推荐使用msgid排重。微信服务器在五秒内收不到响应会断掉连接，并且重新发起请求，总共重试三次。

比如文本消息的Xml示例

 
  
  
 1348831860 
  
  
 1234567890123456

其他的消息去官方文档查看，简单封装如下
消息抽象基类AbstractMsg.java

package com.phil.wechat.msg.model.req; 
 
import java.io.Serializable; 
 
/** 
 * 基础消息类 
 * 
 * @author phil 
 * 
 */ 
public abstract class AbstractMsg implements Serializable { 
  
 private static final long serialVersionUID = -6244277633057415731L; 
 private String ToUserName; // 开发者微信号 
 private String FromUserName; // 发送方帐号（一个OpenID） 
 private String MsgType = SetMsgType(); // 消息类型 例如 /text/image 
 private long CreateTime; // 消息创建时间 （整型） 
 private long MsgId; // 消息id，64位整型 
 /** 
  * 消息类型 
  * 
  * @return 
  */ 
 public abstract String SetMsgType(); 
}

文本消息TextMsg.java

package com.phil.wechat.msg.model.req; 
 
/** 
 * 文本消息 
 * @author phil 
 * @date 2017年6月30日 
 * 
 */ 
public class TextMsg extends AbstractMsg { 
 
 private static final long serialVersionUID = -1764016801417503409L; 
 private String Content; // 文本消息 
 @Override 
 public String SetMsgType() { 
  return "text"; 
 } 
}

其他的依样画葫芦......

二、被动回复用户消息

微信服务器在将用户的消息发给公众号的开发者服务器地址（开发者中心处配置）后，微信服务器在五秒内收不到响应会断掉连接，并且重新发起请求，总共重试三次，如果在调试中，发现用户无法收到响应的消息，可以检查是否消息处理超时。假如服务器无法保证在五秒内处理并回复，可以直接回复空串，微信服务器不会对此作任何处理，并且不会发起重试。

如果出现“该公众号暂时无法提供服务，请稍后再试”，原因有两个

开发者在5秒内未回复任何内容
开发者回复了异常数据

比如回复的文本消息Xml示例

12345678

简单封装下

回复消息抽象基类RespAbstractMsg.java

package com.phil.wechat.msg.model.resp; 
 
import java.io.Serializable; 
 
/** 
 * 消息基类（公众帐号 -> 普通用户） 
 * 
 * @author phil 
 * 
 */ 
public abstract class RespAbstractMsg{ 
 // 接收方帐号（收到的OpenID） 
 private String ToUserName; 
 // 开发者微信号 
 private String FromUserName; 
 // 消息创建时间 （整型） 
 private long CreateTime; 
 // 消息类型（text/music/news） 
 private String MsgType = setMsgType(); // 消息类型 
 public abstract String setMsgType(); 
}

回复文本消息RespTextMsg.java

package com.phil.wechat.msg.model.resp; 
 
/** 
 * 回复图片消息 
 * 
 * @author phil 
 * @data 2017年3月26日 
 * 
 */ 
public class RespImageMsg extends RespAbstractMsg { 
 private Image Image; 
 @Override 
 public String setMsgType() { 
  return "image"; 
 } 
 
 /** 
  * 
  * @author phil 
  * @date 2017年7月19日 
  * 
  */ 
 public class Image { 
 
  // 通过素材管理中的接口上传多媒体文件，得到的id。 
  private String MediaId; 
 
  public String getMediaId() { 
   return MediaId; 
  } 
 
  public void setMediaId(String mediaId) { 
   MediaId = mediaId; 
  } 
 } 
}

其他消息类型依样画葫芦......

三、消息的处理

掌握xml解析

package com.phil.wechat.msg.controller; 
 
import java.io.IOException; 
import java.io.InputStream; 
import java.util.Map; 
import java.util.Objects; 
 
import org.apache.commons.lang3.StringUtils; 
import org.dom4j.DocumentException; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.stereotype.Controller; 
import org.springframework.web.bind.annotation.RequestMapping; 
import org.springframework.web.bind.annotation.RequestMethod; 
 
import com.phil.modules.config.WechatConfig; 
import com.phil.modules.util.MsgUtil; 
import com.phil.modules.util.SignatureUtil; 
import com.phil.modules.util.XmlUtil; 
import com.phil.wechat.base.controller.BaseController; 
import com.phil.wechat.base.result.WechatResult; 
import com.phil.wechat.msg.model.req.BasicMsg; 
import com.phil.wechat.msg.model.resp.RespAbstractMsg; 
import com.phil.wechat.msg.model.resp.RespNewsMsg; 
import com.phil.wechat.msg.service.WechatMsgService; 
 
/** 
 * @author phil 
 * @date 2017年9月19日 
 * 
 */ 
@Controller 
@RequestMapping("/wechat") 
public class WechatMsgController extends BaseController { 
  
 private Logger logger = LoggerFactory.getLogger(this.getClass()); 
  
 @Autowired 
 private WechatMsgService wechatMsgService; 
  
 /** 
  * 校验信息是否是从微信服务器发出，处理消息 
  * @param out 
  * @throws IOException 
  */ 
 @RequestMapping(value = "/handler", method = { RequestMethod.GET, RequestMethod.POST }) 
 public void processPost() throws Exception { 
  this.getRequest().setCharacterEncoding("UTF-8"); 
  this.getResponse().setCharacterEncoding("UTF-8"); 
  boolean ispost = Objects.equals("POST", this.getRequest().getMethod().toUpperCase()); 
  if (ispost) { 
   logger.debug("接入成功，正在处理逻辑"); 
   String respXml = defaultMsgDisPose(this.getRequest().getInputStream());//processRequest(request, response); 
   if (StringUtils.isNotBlank(respXml)) { 
    this.getResponse().getWriter().write(respXml); 
   } 
  } else { 
   String signature = this.getRequest().getParameter("signature"); 
   // 时间戳 
   String timestamp = this.getRequest().getParameter("timestamp"); 
   // 随机数 
   String nonce = this.getRequest().getParameter("nonce"); 
   // 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败 
   if (SignatureUtil.checkSignature(signature, timestamp, nonce)) { 
    // 随机字符串 
    String echostr = this.getRequest().getParameter("echostr"); 
    logger.debug("接入成功，echostr {}", echostr); 
    this.getResponse().getWriter().write(echostr); 
   } 
  } 
 } 
 
 /** 
  * 默认处理方法 
  * @param input 
  * @return 
  * @throws Exception 
  * @throws DocumentException 
  */ 
 private String defaultMsgDisPose(InputStream inputStream) throws Exception { 
  String result = null; 
  if (inputStream != null) { 
   Map params = XmlUtil.parseStreamToMap(inputStream); 
   if (params != null && params.size() > 0) { 
    BasicMsg msgInfo = new BasicMsg(); 
    String createTime = params.get("CreateTime"); 
    String msgId = params.get("MsgId"); 
    msgInfo.setCreateTime((createTime != null && !"".equals(createTime)) ? Integer.parseInt(createTime) : 0); 
    msgInfo.setFromUserName(params.get("FromUserName")); 
    msgInfo.setMsgId((msgId != null && !"".equals(msgId)) ? Long.parseLong(msgId) : 0); 
    msgInfo.setToUserName(params.get("ToUserName")); 
    WechatResult resultObj = coreHandler(msgInfo, params); 
    if(resultObj == null){ // 
     return null; 
    } 
    boolean success = resultObj.isSuccess(); //如果 为true,则表示返回xml文件, 直接转换即可,否则按类型 
    if (success) { 
     result = resultObj.getObject().toString(); 
    } else { 
     int type = resultObj.getType(); // 这里规定 1 图文消息 否则直接转换 
     if (type == WechatResult.NEWSMSG) { 
      RespNewsMsg newsMsg = (RespNewsMsg) resultObj.getObject(); 
      result = MsgUtil.newsMsgToXml(newsMsg); 
     } else { 
      RespAbstractMsg basicMsg = (RespAbstractMsg) resultObj.getObject(); 
      result = MsgUtil.msgToXml(basicMsg); 
     } 
    } 
   } else { 
    result = "msg is wrong"; 
   } 
  } 
  return result; 
 } 
  
 /** 
  * 核心处理 
  * 
  * @param msg 
  *   消息基类 
  * @param params 
  *   xml 解析出来的 数据 
  * @return 
  */ 
 private WechatResult coreHandler(BasicMsg msg, Map params) { 
  WechatResult result = null; 
  String msgType = params.get("MsgType"); 
  if (StringUtils.isEmpty(msgType)) { 
   switch (msgType) { 
   case WechatConfig.REQ_MESSAGE_TYPE_TEXT: // 文本消息 
    result = wechatMsgService.textMsg(msg, params); 
    break; 
   case WechatConfig.REQ_MESSAGE_TYPE_IMAGE: // 图片消息 
    result = wechatMsgService.imageMsg(msg, params); 
    break; 
   case WechatConfig.REQ_MESSAGE_TYPE_LINK: // 链接消息 
    result = wechatMsgService.linkMsg(msg, params); 
    break; 
   case WechatConfig.REQ_MESSAGE_TYPE_LOCATION: // 地理位置 
    result = wechatMsgService.locationMsg(msg, params); 
    break; 
   case WechatConfig.REQ_MESSAGE_TYPE_VOICE: // 音频消息 
    result = wechatMsgService.voiceMsg(msg, params); 
    break; 
   case WechatConfig.REQ_MESSAGE_TYPE_SHORTVIDEO: // 短视频消息 
    result = wechatMsgService.shortvideo(msg, params); 
    break; 
   case WechatConfig.REQ_MESSAGE_TYPE_VIDEO: // 视频消息 
    result = wechatMsgService.videoMsg(msg, params); 
    break; 
   case WechatConfig.REQ_MESSAGE_TYPE_EVENT: // 事件消息 
    String eventType = params.get("Event"); // 
    if (eventType != null && !"".equals(eventType)) { 
     switch (eventType) { 
     case WechatConfig.EVENT_TYPE_SUBSCRIBE: 
      result = wechatMsgService.subscribe(msg, params); 
      break; 
     case WechatConfig.EVENT_TYPE_UNSUBSCRIBE: 
      result = wechatMsgService.unsubscribe(msg, params); 
      break; 
     case WechatConfig.EVENT_TYPE_SCAN: 
      result = wechatMsgService.scan(msg, params); 
      break; 
     case WechatConfig.EVENT_TYPE_LOCATION: 
      result = wechatMsgService.eventLocation(msg, params); 
      break; 
     case WechatConfig.EVENT_TYPE_CLICK: 
      result = wechatMsgService.eventClick(msg, params); 
      break; 
     case WechatConfig.EVENT_TYPE_VIEW: 
      result = wechatMsgService.eventView(msg, params); 
      break; 
     case WechatConfig.KF_CREATE_SESSION: 
      result = wechatMsgService.kfCreateSession(msg, params); 
      break; 
     case WechatConfig.KF_CLOSE_SESSION: 
      result = wechatMsgService.kfCloseSession(msg, params); 
      break; 
     case WechatConfig.KF_SWITCH_SESSION: 
      result = wechatMsgService.kfSwitchSession(msg, params); 
      break; 
     default: 
      wechatMsgService.eventDefaultReply(msg, params); 
      break; 
     } 
    } 
    break; 
   default: 
    wechatMsgService.defaultMsg(msg, params); 
   } 
  } 
  return result; 
 } 
}

只是提供个思路，如若参考代码请移步

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

推荐阅读

程序员
单击Submitt后平滑滚动到DIV

如何解决《单击Submitt后平滑滚动到DIV》经验，为你挑选了1个好方法。 ... [详细]
程序员
异步WebRequest冻结应用程序

如何解决《异步WebRequest冻结应用程序》经验，为你挑选了1个好方法。 ... [详细]
程序员
处理应用程序中的不同用户类型

如何解决《处理应用程序中的不同用户类型》经验，为你挑选了0个好方法。 ... [详细]
程序员
如何实现100万个节点的链表？

如何解决《如何实现100万个节点的链表？》经验，为你挑选了1个好方法。 ... [详细]
程序员
Windows应用认证工具包挂起

如何解决《Windows应用认证工具包挂起》经验，为你挑选了0个好方法。 ... [详细]
程序员
Java.exe退出代码1. Xamarin

如何解决《Java.exe退出代码1.Xamarin》经验，为你挑选了1个好方法。 ... [详细]
程序员
获取控制器中的环境值

如何解决《获取控制器中的环境值》经验，为你挑选了4个好方法。 ... [详细]
程序员
使用NOT IN的DELETE的性能（选择...）

如何解决《使用NOTIN的DELETE的性能（选择）》经验，为你挑选了1个好方法。 ... [详细]
程序员
针对Firefox-to-Chrome和Chrome-to-Firefox的WebRTC视频聊天无效

如何解决《针对Firefox-to-Chrome和Chrome-to-Firefox的WebRTC视频聊天无效》经验，为你挑选了0个好方法。 ... [详细]
程序员
如何在uwp上模糊网格背景？

如何解决《如何在uwp上模糊网格背景？》经验，为你挑选了1个好方法。 ... [详细]
程序员
查找文件的父ID:Google Drive API V3

如何解决《查找文件的父ID:GoogleDriveAPIV3》经验，为你挑选了2个好方法。 ... [详细]
程序员
通过读取Python的dask模块中的pickle文件来创建dask数据帧

如何解决《通过读取Python的dask模块中的pickle文件来创建dask数据帧》经验，为你挑选了1个好方法。 ... [详细]
程序员
将Hex字符串转换为Int时的java.lang.NumberFormatException

如何解决《将Hex字符串转换为Int时的java.lang.NumberFormatException》经验，为你挑选了1个好方法。 ... [详细]
程序员
管道多部分表单上传到另一台服务器

如何解决《管道多部分表单上传到另一台服务器》经验，为你挑选了0个好方法。 ... [详细]
程序员
在设置Android应用程序的区域设置后,SharedPrefs正在重置

如何解决《在设置Android应用程序的区域设置后,SharedPrefs正在重置》经验，为你挑选了0个好方法。 ... [详细]
程序员
如何将输出变为连续字符串而不是将其堆叠在每个字母的顶部 - c#

如何解决《如何将输出变为连续字符串而不是将其堆叠在每个字母的顶部-c#》经验，为你挑选了1个好方法。 ... [详细]
程序员
如何将数组拆分成组

如何解决《如何将数组拆分成组》经验，为你挑选了0个好方法。 ... [详细]
程序员
Worksheet_change:删除整列值,在此操作之前标识非空单元格

如何解决《Worksheet_change:删除整列值,在此操作之前标识非空单元格》经验，为你挑选了0个好方法。 ... [详细]
程序员
从数据透视表中查找一行

如何解决《从数据透视表中查找一行》经验，为你挑选了0个好方法。 ... [详细]
程序员
每次在ng-repeat上添加一个内联值

如何解决《每次在ng-repeat上添加一个内联值》经验，为你挑选了1个好方法。 ... [详细]

无名有名我无名_593

这个屌丝很懒，什么也没留下！

关注作者

Tags | 热门标签

RankList | 热门文章