1. 全栈程序员必看首页

[029] 微信公众帐号开发教程第5篇-各种消息的接收与响应[通俗易懂]

全栈程序员-站长 • • 未分类 • 阅读 0

[029] 微信公众帐号开发教程第5篇-各种消息的接收与响应[通俗易懂]前一篇文章里我们已经把微信公众平台接口中消息及相关操作都进行了封装，本章节将主要介绍如何接收微信服务器发送的消息并做出响应。明确在哪接收消息从微信公众平台接口消息指南中可以了解到，当用户向公众帐号发消息时，微信服务器会将消息通过POST方式提交给我们在接口配置信息中填写的URL，而我们就需要在URL所指向的请求处理类CoreServlet的doPost方法中接收消息、处理消息和响应

大家好，又见面了，我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

前一篇文章里我们已经把微信公众平台接口中消息及相关操作都进行了封装，本章节将主要介绍如何接收微信服务器发送的消息并做出响应。

明确在哪接收消息

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


接收、处理、响应消息

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

package org.liufeng.course.servlet;

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.liufeng.course.service.CoreService;
import org.liufeng.course.util.SignUtil;

/**
 * 核心请求处理类
 * 
 * @author liufeng
 * @date 2013-05-18
 */
public class CoreServlet extends HttpServlet {
	private static final long serialVersionUID = 4440739483644821986L;

	/**
	 * 确认请求来自微信服务器
	 */
	public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// 微信加密签名
		String signature = request.getParameter("signature");
		// 时间戳
		String timestamp = request.getParameter("timestamp");
		// 随机数
		String nonce = request.getParameter("nonce");
		// 随机字符串
		String echostr = request.getParameter("echostr");

		PrintWriter out = response.getWriter();
		// 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败
		if (SignUtil.checkSignature(signature, timestamp, nonce)) {
			out.print(echostr);
		}
		out.close();
		out = null;
	}

	/**
	 * 处理微信服务器发来的消息
	 */
	public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// 将请求、响应的编码均设置为UTF-8（防止中文乱码）
		request.setCharacterEncoding("UTF-8");
		response.setCharacterEncoding("UTF-8");

		// 调用核心业务类接收消息、处理消息
		String respMessage = CoreService.processRequest(request);
		
		// 响应消息
		PrintWriter out = response.getWriter();
		out.print(respMessage);
		out.close();
	}

}

代码说明：

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类的代码实现：

package org.liufeng.course.service;

import java.util.Date;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.liufeng.course.message.resp.TextMessage;
import org.liufeng.course.util.MessageUtil;

/**
 * 核心服务类
 * 
 * @author liufeng
 * @date 2013-05-20
 */
public class CoreService {
	/**
	 * 处理微信发来的请求
	 * 
	 * @param request
	 * @return
	 */
	public static String processRequest(HttpServletRequest request) {
		String respMessage = null;
		try {
			// 默认返回的文本消息内容
			String respContent = "请求处理异常，请稍候尝试！";

			// xml请求解析
			Map<String, String> requestMap = MessageUtil.parseXml(request);

			// 发送方帐号（open_id）
			String fromUserName = requestMap.get("FromUserName");
			// 公众帐号
			String toUserName = requestMap.get("ToUserName");
			// 消息类型
			String msgType = requestMap.get("MsgType");

			// 回复文本消息
			TextMessage textMessage = new TextMessage();
			textMessage.setToUserName(fromUserName);
			textMessage.setFromUserName(toUserName);
			textMessage.setCreateTime(new Date().getTime());
			textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);
			textMessage.setFuncFlag(0);

			// 文本消息
			if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
				respContent = "您发送的是文本消息！";
			}
			// 图片消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {
				respContent = "您发送的是图片消息！";
			}
			// 地理位置消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {
				respContent = "您发送的是地理位置消息！";
			}
			// 链接消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {
				respContent = "您发送的是链接消息！";
			}
			// 音频消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {
				respContent = "您发送的是音频消息！";
			}
			// 事件推送
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {
				// 事件类型
				String eventType = requestMap.get("Event");
				// 订阅
				if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {
					respContent = "谢谢您的关注！";
				}
				// 取消订阅
				else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {
					// TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息
				}
				// 自定义菜单点击事件
				else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {
					// TODO 自定义菜单权没有开放，暂不处理该类消息
				}
			}

			textMessage.setContent(respContent);
			respMessage = MessageUtil.textMessageToXml(textMessage);
		} catch (Exception e) {
			e.printStackTrace();
		}

		return respMessage;
	}
}

代码说明：

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

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

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

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

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


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

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

[029] 微信公众帐号开发教程第5篇-各种消息的接收与响应[通俗易懂]

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

连载五篇教程总结

经过5篇的讲解，已经把开发模式启用，接口配置，消息相关工具类的封装，消息的接收与响应全部讲解完了，而且贴上了完整的源代码，相信有一定Java基础的朋友可以看的明白，能够通过系列文章基本掌握微信公众平台开发的相关技术知识。下面我把目前项目的完整结构贴出，方便大家对照：

[029] 微信公众帐号开发教程第5篇-各种消息的接收与响应[通俗易懂]

如果觉得文章对你有所帮助，请留言支持或关注微信公众帐号xiaoqrobot支持柳峰哦！

[029] 微信公众帐号开发教程第5篇-各种消息的接收与响应[通俗易懂]

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/188271.html原文链接：https://javaforall.net

赞 (0)
全栈程序员-站长的头像全栈程序员-站长
0 0


相关推荐

  • GET请求方式的长度限制到底是多少？「建议收藏」

    GET请求方式的长度限制到底是多少？「建议收藏」

    GET请求方式的长度限制到底是多少？「建议收藏」在我的一贯认识中，一直认为get请求方式有长度限制，1024B。很抱歉在没有经过验证的情况下，一直奉为圭皋。直到项目中有一次用到get请求方式传值的时候，才发现之前一直记忆的网络知识一直都是错误的。今日，看到网络上关于get的知识总结，发现原来一直信奉的1024Get请求长度，是错误的。下面把从权威官网的解释复制过来，以做更正。1、Httpget方法提交的数据大小长度并没有限制，Http协议规范没有对URL长度进行限制。目前说的get长度有限制，是特定的浏览器及服务器

    全栈程序员-站长的头像 全栈程序员-站长
    2022年8月24日
  • STM32中文参考手册_STM32读取ESP8266数据

    STM32中文参考手册_STM32读取ESP8266数据

    STM32中文参考手册_STM32读取ESP8266数据http://blog.csdn.net/u012722571/article/details/47295245lanmanck原创】这篇文章已经说了STM32的启动过程：http://blog.csdn.net/lanmanck/article/details/8252560我们也知道怎么跳到main函数了，那么，中断发生后，又是怎么跑到中断入口地址的呢？从stm

    全栈程序员-站长的头像 全栈程序员-站长
    2022年10月25日
  • zabbix 监控服务器_docker监控工具有哪些

    zabbix 监控服务器_docker监控工具有哪些

    zabbix 监控服务器_docker监控工具有哪些服务器监控工具服务器监控工具功能相当强大，无论何时何地，我们都可以了解到服务器的功能以及性能。服务器监控工具的使用，可以让我们清楚的知道用户可以打开我们的网站，且确保网速不慢。只有这样做，才能留住宝贵的用户，以免因为系统停运的原因，导致用户丢失。监控工具：cacti、Nagios、Ganglia、zabbixcacti：它是一款数据采集、数据存储，外加web界面展示的工具，它的数据展示功能…

    全栈程序员-站长的头像 全栈程序员-站长
    2022年10月30日
  • Vue文件上传、下载

    Vue文件上传、下载

    Vue文件上传、下载代码示例：文件上传到接口，对接口返回的文件进行下载。<template><divclass=”hello”><h1>{{msg}}</h1><inputtype=”file”@change=”uploadFile($event)”accept=”.sql,.excel,.txt”/></div></template><script>exportdefau

    全栈程序员-站长的头像 全栈程序员-站长
    2022年6月16日
  • 智能手机功能_android是什么品牌手机

    智能手机功能_android是什么品牌手机

    智能手机功能_android是什么品牌手机标签：小米(194)HTC(27)三星(1202)手机(807)打开各手机论坛，看到许多朋友在问usb调试在哪？usb调试模式怎么打开？“USB调试”是Android系统提供的一个用于开发工作的功能软件，在每个Android系统上都会自带，“USB调试”主要作用是在在计算机和Android设备之间复制数据、移动设备上安装应用程序。所以在我们联接电脑时，系统都会提示我们要打开“USB调试”。今天，…

    全栈程序员-站长的头像 全栈程序员-站长
    2022年9月12日
  • socket编程与线程模型二

    socket编程与线程模型二

    socket编程与线程模型二

    全栈程序员-站长的头像 全栈程序员-站长
    2021年7月27日

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号