微信公号开发之各种消息的接收与响应

迈不过友情╰ 2022-05-25 13:52 135阅读 0赞

**明确在哪接收消息**

从微信公众平台接口消息指南中可以了解到，当用户向公众帐号发消息时，微信服务器会将消息通过POST方式提交给我们在接口配置信息中填写的URL，而我们就需要在URL所指向的请求处理类CoreServlet的doPost方法中接收消息、处理消息和响应消息。

**接收、处理、响应消息**

下面先来看我已经写好的CoreServlet的完整代码：

1.  **package** org.liufeng.course.servlet; 
2.   
3.  **import** java.io.IOException; 
4.  **import** java.io.PrintWriter; 
5.   
6.  **import** javax.servlet.ServletException; 
7.  **import** javax.servlet.http.HttpServlet; 
8.  **import** javax.servlet.http.HttpServletRequest; 
9.  **import** javax.servlet.http.HttpServletResponse; 
10.  
11. **import** org.liufeng.course.service.CoreService; 
12. **import** org.liufeng.course.util.SignUtil; 
13.  
14. /\*\* 
15.  \* 核心请求处理类 
16.  \*  
17.  \* @author liufeng 
18.  \* @date 2013-05-18 
19.  \*/ 
20. **public** **class** CoreServlet **extends** HttpServlet \{ 
21.     **private** **static** **final** **long** serialVersionUID = 4440739483644821986L; 
22.  
23.     /\*\* 
24.      \* 确认请求来自微信服务器 
25.      \*/ 
26.     **public** **void** doGet(HttpServletRequest request, HttpServletResponse response) **throws** ServletException, IOException \{ 
27.         // 微信加密签名 
28.         String signature = request.getParameter("signature"); 
29.         // 时间戳 
30.         String timestamp = request.getParameter("timestamp"); 
31.         // 随机数 
32.         String nonce = request.getParameter("nonce"); 
33.         // 随机字符串 
34.         String echostr = request.getParameter("echostr"); 
35.  
36.         PrintWriter out = response.getWriter(); 
37.         // 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败 
38.         **if** (SignUtil.checkSignature(signature, timestamp, nonce)) \{ 
39.             out.print(echostr); 
40.         \} 
41.         out.close(); 
42.         out = **null**; 
43.     \} 
44.  
45.     /\*\* 
46.      \* 处理微信服务器发来的消息 
47.      \*/ 
48.     **public** **void** doPost(HttpServletRequest request, HttpServletResponse response) **throws** ServletException, IOException \{ 
49.         // 将请求、响应的编码均设置为UTF-8（防止中文乱码） 
50.         request.setCharacterEncoding("UTF-8"); 
51.         response.setCharacterEncoding("UTF-8"); 
52.  
53.         // 调用核心业务类接收消息、处理消息 
54.         String respMessage = CoreService.processRequest(request); 
55.          
56.         // 响应消息 
57.         PrintWriter out = response.getWriter(); 
58.         out.print(respMessage); 
59.         out.close(); 
60.     \} 
61.  
62. \}

代码说明：

1）第51行代码：微信服务器POST消息时用的是UTF-8编码，在接收时也要用同样的编码，否则中文会乱码；

2）第52行代码：在响应消息（回复消息给用户）时，也将编码方式设置为UTF-8，原理同上；

3）第54行代码：调用CoreService类的processRequest方法接收、处理消息，并得到处理结果；

4）第57~59行：调用response.getWriter().write()方法将消息的处理结果返回给用户

从doPost方法的实现可以看到，它是通过调用CoreService类的processRequest方法接收、处理消息的，这样做的目的是为 了解耦，即业务相关的操作都不在Servlet里处理，而是完全交由业务核心类CoreService去做。下面来看CoreService类的代码实现：

1.  **package** org.liufeng.course.service; 
2.   
3.  **import** java.util.Date; 
4.  **import** java.util.Map; 
5.  **import** javax.servlet.http.HttpServletRequest; 
6.  **import** org.liufeng.course.message.resp.TextMessage; 
7.  **import** org.liufeng.course.util.MessageUtil; 
8.   
9.  /\*\* 
10.  \* 核心服务类 
11.  \*  
12.  \* @author liufeng 
13.  \* @date 2013-05-20 
14.  \*/ 
15. **public** **class** CoreService \{ 
16.     /\*\* 
17.      \* 处理微信发来的请求 
18.      \*  
19.      \* @param request 
20.      \* @return 
21.      \*/ 
22.     **public** **static** String processRequest(HttpServletRequest request) \{ 
23.         String respMessage = **null**; 
24.         **try** \{ 
25.             // 默认返回的文本消息内容 
26.             String respContent = "请求处理异常，请稍候尝试！"; 
27.  
28.             // xml请求解析 
29.             Map<String, String> requestMap = MessageUtil.parseXml(request); 
30.  
31.             // 发送方帐号（open\_id） 
32.             String fromUserName = requestMap.get("FromUserName"); 
33.             // 公众帐号 
34.             String toUserName = requestMap.get("ToUserName"); 
35.             // 消息类型 
36.             String msgType = requestMap.get("MsgType"); 
37.  
38.             // 回复文本消息 
39.             TextMessage textMessage = **new** TextMessage(); 
40.             textMessage.setToUserName(fromUserName); 
41.             textMessage.setFromUserName(toUserName); 
42.             textMessage.setCreateTime(**new** Date().getTime()); 
43.             textMessage.setMsgType(MessageUtil.RESP\_MESSAGE\_TYPE\_TEXT); 
44.             textMessage.setFuncFlag(0); 
45.  
46.             // 文本消息 
47.             **if** (msgType.equals(MessageUtil.REQ\_MESSAGE\_TYPE\_TEXT)) \{ 
48.                 respContent = "您发送的是文本消息！"; 
49.             \} 
50.             // 图片消息 
51.             **else** **if** (msgType.equals(MessageUtil.REQ\_MESSAGE\_TYPE\_IMAGE)) \{ 
52.                 respContent = "您发送的是图片消息！"; 
53.             \} 
54.             // 地理位置消息 
55.             **else** **if** (msgType.equals(MessageUtil.REQ\_MESSAGE\_TYPE\_LOCATION)) \{ 
56.                 respContent = "您发送的是地理位置消息！"; 
57.             \} 
58.             // 链接消息 
59.             **else** **if** (msgType.equals(MessageUtil.REQ\_MESSAGE\_TYPE\_LINK)) \{ 
60.                 respContent = "您发送的是链接消息！"; 
61.             \} 
62.             // 音频消息 
63.             **else** **if** (msgType.equals(MessageUtil.REQ\_MESSAGE\_TYPE\_VOICE)) \{ 
64.                 respContent = "您发送的是音频消息！"; 
65.             \} 
66.             // 事件推送 
67.             **else** **if** (msgType.equals(MessageUtil.REQ\_MESSAGE\_TYPE\_EVENT)) \{ 
68.                 // 事件类型 
69.                 String eventType = requestMap.get("Event"); 
70.                 // 订阅 
71.                 **if** (eventType.equals(MessageUtil.EVENT\_TYPE\_SUBSCRIBE)) \{ 
72.                     respContent = "谢谢您的关注！"; 
73.                 \} 
74.                 // 取消订阅 
75.                 **else** **if** (eventType.equals(MessageUtil.EVENT\_TYPE\_UNSUBSCRIBE)) \{ 
76.                     // TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息 
77.                 \} 
78.                 // 自定义菜单点击事件 
79.                 **else** **if** (eventType.equals(MessageUtil.EVENT\_TYPE\_CLICK)) \{ 
80.                     // TODO 自定义菜单权没有开放，暂不处理该类消息 
81.                 \} 
82.             \} 
83.  
84.             textMessage.setContent(respContent); 
85.             respMessage = MessageUtil.textMessageToXml(textMessage); 
86.         \} **catch** (Exception e) \{ 
87.             e.printStackTrace(); 
88.         \} 
89.  
90.         **return** respMessage; 
91.     \} 
92. \}

代码说明：

1）第29行：调用消息工具类MessageUtil解析微信发来的xml格式的消息，解析的结果放在HashMap里；

2）32~36行：从HashMap中取出消息中的字段；

3）39-44、84行：组装要返回的文本消息对象；

4）47~82行：演示了如何接收微信发送的各类型的消息，根据MsgType判断属于哪种类型的消息；

5）85行：调用消息工具类MessageUtil将要返回的文本消息对象TextMessage转化成xml格式的字符串；

**关于事件推送（关注、取消关注、菜单点击）**

对于消息类型的判断，像文本消息、图片消息、地理位置消息、链接消息和语音消息都比较好理解，有很多刚接触的朋友搞不懂事件推送消息有什么用，或者不清楚该如何判断用户关注的消息。那我们就专门来看下事件推送，下图是官方消息接口文档中关于事件推送的说明：

[![wKioOVKCVGTCEazIAACEStvEC8Q908.png-wh_651x-s_668880615.png][]][wKioOVKCVGTCEazIAACEStvEC8Q908.png-wh_651x-s_668880615.png]

这里我们只要关心两个参数：MsgType和Event。当MsgType=event时，就表示这是一条事件推送消息；而Event表示事件类型，包括订阅、取消订阅和自定义菜单点击事件。也就是说，无论用户是关注了公众帐号、取消对公众帐号的关注，还是在使用公众帐号的菜单，微信服务器都会发送一条MsgType=event的消息给我们，而至于具体这条消息表示关注、取消关注，还是菜单的点击事件，就需要通过Event的值来判断了。（注意区分Event和event）

[wKioOVKCVGTCEazIAACEStvEC8Q908.png-wh_651x-s_668880615.png]: /images/20220525/4ba2648e6b4c4c1f98f01e7016269684.png