微信用户关注微信公众账号之后，有可能不会点击菜单(具体如何接收和响应用户点击菜单请求下一章节介绍)而是直接在发送框中给公众账号发送消息，用户用可能发送文本、图片、视频、音频、地理位置等消息类型，那么我们如何接收和响应并且判断区分这些消息类型呢。其实用户发送这些消息类型后，微信服务器会将消息通过POST方式提交给我们在接口配置信息中填写的URL,这个URL就是我们微信接入的时候在基本配置-服务器配置中的URL，doGet方法验证接入，doPOST方法处理用户各种请求。
现在首先贴出服务器配置中的URL所指的servelet类，含有doGET 和doPOST方法
package com.test;
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;
/**
* 核心请求处理类
* @author V型知识库 www.vxzsk.com
*
* doGet方法里 有个weixinTest，这个是公众管理平台里面自己设置的token 大家根据自己的token替换
*/
public class WeChatServlet extends HttpServlet {
private static final long serialVersionUID = 1508798736675904038L;
/**
* 确认请求来自微信服务器
*/
public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
System.out.println("V型知识库原创www.vxzsk.com");
// 微信加密签名
String signature = request.getParameter("signature");
System.out.println("微信加密签名signature：-----------------------"+signature);
// 时间戳
String timestamp = request.getParameter("timestamp");
System.out.println("时间戳timestamp：-----------------------"+timestamp);
// 随机数
String nonce = request.getParameter("nonce");
System.out.println("随机数nonce：-----------------------"+nonce);
// 随机字符串
String echostr = request.getParameter("echostr");
System.out.println("随机字符串echostr：-----------------------"+echostr);
//System.out.println("token-----------------------:"+token);
PrintWriter out = response.getWriter();
// 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败
if (SignUtil.checkSignature("weixinTest", signature, timestamp, nonce)) {
out.print(echostr);
//System.out.println("这是："+echostr);
}
out.close();
out = null;
}
/**
* 处理微信服务器发来的消息
* 实例源码在文章顶部有下载连接
*/
public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
System.out.println("V型知识库原创www.vxzsk.com");
System.out.println("微信服务器发来消息------------");
// 将请求、响应的编码均设置为UTF-8（防止中文乱码）
request.setCharacterEncoding("UTF-8");
response.setCharacterEncoding("UTF-8");
// 调用核心业务类接收消息、处理消息
String respMessage = HandleMessageService.processRequest(request);
// 响应回复消息
PrintWriter out = response.getWriter();
out.print(respMessage);
out.close();
}
}doGet方法里 有个weixinTest，这个是公众管理平台里面自己设置的token 大家根据自己的token替换
doget方法中有个验证token的SignUtil类，代码如下：
package com.test;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;
/***
*
* @author V型知识库 www.vxzsk.com
*
*
*/
public class SignUtil {
/**
* 验证签名
*
* @param signature
* @param timestamp
* @param nonce
* @return
*/
public static boolean checkSignature(String token, String signature, String timestamp, String nonce) {
String[] arr = new String[] { token, timestamp, nonce };
// 将token、timestamp、nonce三个参数进行字典序排序
Arrays.sort(arr);
StringBuilder content = new StringBuilder();
for (int i = 0; i < arr.length; i++) {
content.append(arr[i]);
}
MessageDigest md = null;
String tmpStr = null;
try {
md = MessageDigest.getInstance("SHA-1");
// 将三个参数字符串拼接成一个字符串进行sha1加密
byte[] digest = md.digest(content.toString().getBytes());
tmpStr = byteToStr(digest);
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
}
content = null;
// 将sha1加密后的字符串可与signature对比，标识该请求来源于微信
return tmpStr != null ? tmpStr.equals(signature.toUpperCase()) : false;
}
/**
* 将字节数组转换为十六进制字符串
* @param byteArray
* @return
*/
private static String byteToStr(byte[] byteArray) {
String strDigest = "";
for (int i = 0; i < byteArray.length; i++) {
strDigest += byteToHexStr(byteArray[i]);
}
return strDigest;
}
/**
* 将字节转换为十六进制字符串
* @param mByte
* @return
*/
private static String byteToHexStr(byte mByte) {
char[] Digit = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' };
char[] tempArr = new char[2];
tempArr[0] = Digit[(mByte >>> 4) & 0X0F];
tempArr[1] = Digit[mByte & 0X0F];
String s = new String(tempArr);
return s;
}
}好了，doGet方法已经介绍完毕，现在我们接下来重点介绍一下doPost方法
doPost方法中有两行设置UTF-8编码的代码，这是主要防止接收和响应用户消息中文乱码。
HandleMessageService类主要是接收消息，处理消息的核心业务类并且把响应消息返回，代码如下：
package com.test;
import java.util.Date;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import com.test.message.resp.TextMessage;
import com.test.util.MessageUtil;
/****
*
* @author www.vxzsk.com 消息处理类
*
*/
public class HandleMessageService {
/**
* 处理微信发来的请求
*
* @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;
}
}调用消息工具类MessageUtil解析微信发来的xml格式的消息，解析的结果放在HashMap里；
第33行根据MsgType判断属于哪种类型的消息。
最后返回的字符串调用消息工具类MessageUtil将要返回的文本消息对象TextMessage转化成xml格式的字符串；
消息工具类MessageUtil
package com.test.util;
/***
* V型知识库www.vxzsk.com
*
*/
import java.io.InputStream;
import java.io.Writer;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import com.test.message.resp.Article;
import com.test.message.resp.MusicMessage;
import com.test.message.resp.NewsMessage;
import com.test.message.resp.TextMessage;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.core.util.QuickWriter;
import com.thoughtworks.xstream.io.HierarchicalStreamWriter;
import com.thoughtworks.xstream.io.xml.PrettyPrintWriter;
import com.thoughtworks.xstream.io.xml.XppDriver;
/**
* 消息工具类
*/
public class MessageUtil {
/**
* 返回消息类型：文本
*/
public static final String RESP_MESSAGE_TYPE_TEXT = "text";
/**
* 返回消息类型：音乐
*/
public static final String RESP_MESSAGE_TYPE_MUSIC = "music";
/**
* 返回消息类型：图文
*/
public static final String RESP_MESSAGE_TYPE_NEWS = "news";
/**
* 请求消息类型：文本
*/
public static final String REQ_MESSAGE_TYPE_TEXT = "text";
/**
* 请求消息类型：图片
*/
public static final String REQ_MESSAGE_TYPE_IMAGE = "image";
/**
* 请求消息类型：链接
*/
public static final String REQ_MESSAGE_TYPE_LINK = "link";
/**
* 请求消息类型：地理位置
*/
public static final String REQ_MESSAGE_TYPE_LOCATION = "location";
/**
* 请求消息类型：音频
*/
public static final String REQ_MESSAGE_TYPE_VOICE = "voice";
/**
* 请求消息类型：推送
*/
public static final String REQ_MESSAGE_TYPE_EVENT = "event";
/**
* 事件类型：subscribe(订阅)
*/
public static final String EVENT_TYPE_SUBSCRIBE = "subscribe";
/**
* 事件类型：unsubscribe(取消订阅)
*/
public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe";
/**
* 事件类型：CLICK(自定义菜单点击事件)
*/
public static final String EVENT_TYPE_CLICK = "CLICK";
/**
* 解析微信发来的请求（XML）
*
* @param request
* @return
* @throws Exception
*/
@SuppressWarnings("unchecked")
public static Map<String, String> parseXml(HttpServletRequest request) throws Exception {
// 将解析结果存储在HashMap中
Map<String, String> map = new HashMap<String, String>();
// 从request中取得输入流
InputStream inputStream = request.getInputStream();
// 读取输入流
SAXReader reader = new SAXReader();
Document document = reader.read(inputStream);
// 得到xml根元素
Element root = document.getRootElement();
// 得到根元素的所有子节点
List<Element> elementList = root.elements();
// 遍历所有子节点
for (Element e : elementList) {
map.put(e.getName(), e.getText());
}
// 释放资源
inputStream.close();
inputStream = null;
return map;
}
/**
* 文本消息对象转换成xml
* @param textMessage 文本消息对象
* @return xml
*/
public static String textMessageToXml(TextMessage textMessage) {
xstream.alias("xml", textMessage.getClass());
return xstream.toXML(textMessage);
}
/**
* 音乐消息对象转换成xml
* @param musicMessage 音乐消息对象
* @return xml
*/
public static String musicMessageToXml(MusicMessage musicMessage) {
xstream.alias("xml", musicMessage.getClass());
return xstream.toXML(musicMessage);
}
/**
* 图文消息对象转换成xml
* @param newsMessage 图文消息对象
* @return xml
*/
public static String newsMessageToXml(NewsMessage newsMessage) {
xstream.alias("xml", newsMessage.getClass());
xstream.alias("item", new Article().getClass());
return xstream.toXML(newsMessage);
}
/**
* 扩展xstream，使其支持CDATA块
* @date
*/
private static XStream xstream = new XStream(new XppDriver() {
public HierarchicalStreamWriter createWriter(Writer out) {
return new PrettyPrintWriter(out) {
// 对所有xml节点的转换都增加CDATA标记
boolean cdata = true;
@SuppressWarnings("unchecked")
public void startNode(String name, Class clazz) {
super.startNode(name, clazz);
}
protected void writeText(QuickWriter writer, String text) {
if (cdata) {
writer.write("<![CDATA[");
writer.write(text);
writer.write("]]>");
} else {
writer.write(text);
}
}
};
}
});
}文本消息封装TextMessage类
package com.test.message.resp;
/**
* 文本消息
* v型知识库 www.vxzsk.com
*/
public class TextMessage extends BaseMessage {
// 回复的消息内容
private String Content;
public String getContent() {
return Content;
}
public void setContent(String content) {
Content = content;
}
}BaseMessage类
package com.test.message.resp;
/**
* 消息基类（公众帐号 -> 普通用户）
* V型知识库 www.vxzsk.com
*/
public class BaseMessage {
// 接收方帐号（收到的OpenID）
private String ToUserName;
// 开发者微信号
private String FromUserName;
// 消息创建时间 （整型）
private long CreateTime;
// 消息类型（text/music/news）
private String MsgType;
// 位0x0001被标志时，星标刚收到的消息
private int FuncFlag;
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 int getFuncFlag() {
return FuncFlag;
}
public void setFuncFlag(int funcFlag) {
FuncFlag = funcFlag;
}
}读者在复制上述代码后还是不能直接运行，因为还有其他封装好的代码，我在这里就不在贴出，有兴趣的读者可在文章底部有个案例下载按钮，可下载完整demo代码。
上述代码运行后效果如下:
依赖的jar包
关于事件推送（关注、取消关注、菜单点击）
对于消息类型的判断，像文本消息、图片消息、地理位置消息、链接消息和语音消息都比较好理解，有很多刚接触的朋友搞不懂事件推送消息有什么用，或者不清楚该如何判断用户关注的消息。那我们就专门来看下事件推送，下图是官方消息接口文档中关于事件推送的说明：
其实我们在时间推送用的最多的就是自定义菜单的点击，例如自定义菜单中有click，view等类型，当用户点击一个自定义菜单的连接时，我们代码中就可以接收用户的点击类型，例如刚才所说的click,view等，并相应的处理把用户想要的效果返回给用户。
这里我们只要关心两个参数：MsgType和Event。当MsgType=event时，就表示这是一条事件推送消息；而Event表示事件类型，包括订阅、取消订阅和自定义菜单点击事件。也就是说，无论用户是关注了公众帐号、取消对公众帐号的关注，还是在使用公众帐号的菜单，微信服务器都会发送一条MsgType=event的消息给我们，而至于具体这条消息表示关注、取消关注，还是菜单的点击事件，就需要通过Event的值来判断了。例如用户点击"绑定手机号"自定义菜单，这个菜单的click值为123，我们后台代码就可以判断EventKey是否等于123如果等于就跳转到绑定手机号界面，在这里只是大概说下，下一章节会做出详细介绍。
此文章本站原创，地址 https://www.vxzsk.com/125.html
转载请注明出处！谢谢！
感觉本站内容不错，读后有收获？小额赞助,鼓励网站分享出更好的教程