在上一篇微信开发的博文中微信开发(01)之如何成为开发者，我们开启了微信开发者模式，本篇博文我们简单的处理微信关注者发给我们公众号的消息。
在开启微信开发者模式时，我们配置了一个URL地址，当我们提交开启微信开发者模式，腾讯的微信服务器会向该URL地址发送一个get请求，并且携带一些参数，让我们来验证。说到get请求，就必须说到post请求，关注我们公众号的微信粉丝发来的消息，触发的事件，腾讯的微信服务器则会像该URL地址发送一个post请求，请求的内容就是以xml文档形式的字符串。
所以该URL地址的get请求的处理方法，专门用于开启微信开发者模式；而post请求则用于处理微信粉丝发给我们的消息，或者触发的事件，所以我们后面的微信开发工作的起点就是该URL地址的post处理方法。
下面我们处理一个最简单的例子：粉丝发送任意一个文本信息给我们，我们给他回复一个消息：“你好，+ 他微信的openId”
下面直接贴代码：
URL对应的处理servlet:
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();
// 请求校验，若校验成功则原样返回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 signature = request.getParameter("signature");
String timestamp = request.getParameter("timestamp");
String nonce = request.getParameter("nonce");
PrintWriter out = response.getWriter();
// 请求校验
if (SignUtil.checkSignature(signature, timestamp, nonce)) {
Message msgObj = XMLUtil.getMessageObject(request); // 读取微信客户端发来的消息(xml字符串)，并将其转换为消息对象
if(msgObj != null){
String xml = "<xml>" +
"<ToUserName><![CDATA[" + msgObj.getFromUserName() + "]]></ToUserName>" + // 接收方帐号（收到的OpenID）
"<FromUserName><![CDATA[" + msgObj.getToUserName() + "]]></FromUserName>" + // 开发者微信号
"<CreateTime>12345678</CreateTime>" +
"<MsgType><![CDATA[text]]></MsgType>" +
"<Content><![CDATA[你好，"+ msgObj.getFromUserName() +"]]></Content>" +
"</xml>";
out.write(xml); // 回复微信客户端的消息(xml字符串)
out.close();
return;
}
}
out.write("");
out.close();
}
}
xml字符串的处理工具类，实现xml消息到消息对象的转换：
public class XMLUtil
{
/**
* 从request中读取用户发给公众号的消息内容
* @param request
* @return 用户发给公众号的消息内容
* @throws IOException
*/
public static String readRequestContent(HttpServletRequest request) throws IOException
{
// 从输入流读取返回内容
InputStream inputStream = request.getInputStream();
InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
String str = null;
StringBuilder buffer = new StringBuilder();
while ((str = bufferedReader.readLine()) != null) {
buffer.append(str);
}
// 释放资源
bufferedReader.close();
inputStreamReader.close();
inputStream.close();
return buffer.toString();
}
/**
* 将xml文档的内容转换成map
* @param xmlDoc
* @return map
*/
public static Map<String, String> xmlToMap(String xmlDoc)
{
//创建一个新的字符串
StringReader read = new StringReader(xmlDoc);
//创建新的输入源SAX 解析器将使用 InputSource 对象来确定如何读取 XML 输入
InputSource source = new InputSource(read);
//创建一个新的SAXBuilder
SAXBuilder sb = new SAXBuilder();
Map<String, String> xmlMap = new HashMap<String, String>();
try {
Document doc = sb.build(source); //通过输入源构造一个Document
Element root = doc.getRootElement(); //取的根元素
List<Element> cNodes = root.getChildren(); //得到根元素所有子元素的集合(根元素的子节点，不包括孙子节点)
Element et = null;
for(int i=0;i<cNodes.size();i++){
et = (Element) cNodes.get(i); //循环依次得到子元素
xmlMap.put(et.getName(), et.getText());
}
} catch (JDOMException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return xmlMap;
}
/**
* 将保存xml内容的map转换成对象
* @param map
* @return
*/
public static Message getMessageObject(Map<String, String> map)
{
if(map != null){
String MsgType = map.get("MsgType");
// 消息类型(文本消息:text, 图片消息:image, 语音消息:voice, 视频消息:video,
// 地理位置消息:location, 链接消息:link)
if("text".equals(MsgType)){
TextMessage msg = new TextMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setContent(map.get("Content"));
return msg;
}
if("ImageMessage".equals(MsgType)){
ImageMessage msg = new ImageMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setPicUrl(map.get("PicUrl"));
msg.setMediaId(map.get("MediaId"));
return msg;
}
if("video".equals(MsgType)){
VideoMessage msg = new VideoMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setMediaId(map.get("MediaId"));
msg.setThumbMediaId(map.get("ThumbMediaId"));
return msg;
}
if("voice".equals(MsgType)){
VoiceMessage msg = new VoiceMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setMediaId(map.get("MediaId"));
msg.setFormat(map.get("Format"));
return msg;
}
if("location".equals(MsgType)){
LocationMessage msg = new LocationMessage();
msg.setLocation_X(map.get("Location_X"));
msg.setLocation_Y(map.get("Location_Y"));
msg.setScale(map.get("Scale"));
msg.setLabel(map.get("Label"));
return msg;
}
if("link".equals(MsgType)){
LinkMessage msg = new LinkMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setTitle(map.get("Title"));
msg.setDescription(map.get("Description"));
msg.setUrl(map.get("Url"));
return msg;
}
}
return null;
}
/**
* 将保存xml内容的map转换成对象
* @param map
* @return
* @throws IOException
*/
public static Message getMessageObject(HttpServletRequest request) throws IOException
{
String xmlDoc = XMLUtil.readRequestContent(request); // 读取微信客户端发了的消息(xml)
Map<String, String> map = XMLUtil.xmlToMap(xmlDoc); // 将客户端发来的xml转换成Map
if(map != null){
String MsgType = map.get("MsgType");
// 消息类型(文本消息:text, 图片消息:image, 语音消息:voice, 视频消息:video,
// 地理位置消息:location, 链接消息:link)
if("text".equals(MsgType)){
TextMessage msg = new TextMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setContent(map.get("Content"));
return msg;
}
/*if("ImageMessage".equals(MsgType)){
ImageMessage msg = new ImageMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setPicUrl(map.get("PicUrl"));
msg.setMediaId(map.get("MediaId"));
return msg;
}
if("video".equals(MsgType)){
VideoMessage msg = new VideoMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setMediaId(map.get("MediaId"));
msg.setThumbMediaId(map.get("ThumbMediaId"));
return msg;
}
if("voice".equals(MsgType)){
VoiceMessage msg = new VoiceMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setMediaId(map.get("MediaId"));
msg.setFormat(map.get("Format"));
return msg;
}
if("location".equals(MsgType)){
LocationMessage msg = new LocationMessage();
msg.setLocation_X(map.get("Location_X"));
msg.setLocation_Y(map.get("Location_Y"));
msg.setScale(map.get("Scale"));
msg.setLabel(map.get("Label"));
return msg;
}
if("link".equals(MsgType)){
LinkMessage msg = new LinkMessage();
XMLUtil.initCommonMsg(msg, map);
msg.setTitle(map.get("Title"));
msg.setDescription(map.get("Description"));
msg.setUrl(map.get("Url"));
return msg;
}*/
}
return null;
}
public static void initCommonMsg(Message msg, Map<String, String> map)
{
msg.setMsgId(map.get("MsgId"));
msg.setMsgType(map.get("MsgType"));
msg.setToUserName(map.get("ToUserName"));
msg.setFromUserName(map.get("FromUserName"));
msg.setCreateTime(map.get("CreateTime"));
}
}
粉丝发来的消息分为了6中类型(文本消息, 图片消息, 语音消息, 视频消息, 地理位置消息, 链接消息)：
/**
* 微信消息基类
* @author yuanfang
* @date 2015-03-23
*/
public class Message
{
private String MsgId; // 消息id，64位整型
private String MsgType; // 消息类型(文本消息:text, 图片消息:image, 语音消息:voice, 视频消息:video, 地理位置消息:location, 链接消息:link)
private String ToUserName; //开发者微信号
private String FromUserName; // 发送方帐号（一个OpenID）
private String CreateTime; // 消息创建时间 （整型）
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 String getCreateTime() {
return CreateTime;
}
public void setCreateTime(String createTime) {
CreateTime = createTime;
}
public String getMsgType() {
return MsgType;
}
public void setMsgType(String msgType) {
MsgType = msgType;
}
public String getMsgId() {
return MsgId;
}
public void setMsgId(String msgId) {
MsgId = msgId;
}
}
文本消息类：
package com.sinaapp.wx.msg;
public class TextMessage extends Message
{
private String Content; // 文本消息内容
public String getContent() {
return Content;
}
public void setContent(String content) {
Content = content;
}
}
OK，对粉丝发送给我们公众号的任意的文本消息的最简单处理就完成，我们简单的回复他：你好，然后加上他微信的openId，类似于：你好，orJydljfkg3-r0_dj3rkdfvjl
更多微信开发之处理微信客户端发来的消息相关文章请关注PHP中文网！
声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
热AI工具
Undresser.AI Undress
人工智能驱动的应用程序，用于创建逼真的裸体照片
AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。
Undress AI Tool
免费脱衣服图片
Clothoff.io
AI脱衣机
Video Face Swap
使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸！
热门文章
刺客信条阴影：贝壳谜语解决方案
4 周前ByDDD
Windows 11 KB5054979中的新功能以及如何解决更新问题
3 周前ByDDD
在哪里可以找到原子中的起重机控制钥匙卡
4 周前ByDDD
<🎜>：死铁路 - 如何完成所有挑战
1 个月前ByDDD
Atomfall指南：项目位置，任务指南和技巧
1 个月前ByDDD
热工具
PhpStorm Mac 版本
最新（2018.2.1 ）专业的PHP集成开发工具
Atom编辑器mac版下载
最流行的的开源编辑器
WebStorm Mac版
好用的JavaScript开发工具
SecLists
SecLists是最终安全测试人员的伙伴。它是一个包含各种类型列表的集合，这些列表在安全评估过程中经常使用，都在一个地方。SecLists通过方便地提供安全测试人员可能需要的所有列表，帮助提高安全测试的效率和生产力。列表类型包括用户名、密码、URL、模糊测试有效载荷、敏感数据模式、Web shell等等。测试人员只需将此存储库拉到新的测试机上，他就可以访问到所需的每种类型的列表。
EditPlus 中文破解版
体积小，语法高亮，不支持代码提示功能
