18608119775
电 话：18608119775（廖女士）
传 真：0838-2300890
邮 箱：1013933101@qq.com
地 址：四川省德阳市上美广场A座2105号
网 址：www.xcqyzx.com
这次要实现的功能是，微信公众号可以识别你发送的文本消息类型，比如你回复个"你好"，微信公众号会回复给你一句“你发送的是文本消息：你好”，就类似这样的功能，我们来看该怎么实现。
首先你要知道的是，你向微信公众号发送一个文本消息，这样会产生一个post请求给微信服务器，而微信服务器会将这个请求转发给我们的服务器，准确来说是交给我们的CoreServlet来处理。
要处理这块我们需要查看官方技术文档，也就是这块---接收普通消息
当普通微信用户向公众账号发消息时，微信服务器将POST消息的XML数据包到开发者填写的URL上。
文本消息的XML数据包结构是这样的
< ![CDATA[toUser] ]> < ![CDATA[fromUser] ]> 1348831860 < ![CDATA[text] ]> < ![CDATA[this is a test] ]> 1234567890123456
这里面包含一些参数如下
ToUserName开发者微信号
FromUserName发送方帐号（一个OpenID）
CreateTime消息创建时间 （整型）
MsgTypetextContent文本消息内容MsgId消息id，64位整型也就是说，现在你往微信公众号上发送一段文字，然后最终会形成一个XML数据包，我们通过我们的CoreServlet去处理这个数据包，也就是这些数据包含在request当中。
那接下来的重点就是去解析request中的XML数据包了，那么该如何解析，观察XML数据，可以将数据存放在Map集合中，然后将XML中的数据映射成一个object对象，这其中用到了一些开源库，首先我们需要创建一个Javabean对应着我们的文本消息XML数据结构中的那些参数。
public class TextMessage {
// 开发者微信号
private String ToUserName;
// 发送方帐号（一个OpenID）
private String FromUserName;
// 消息创建时间 （整型）
private long CreateTime;
// 消息类型（text/image/location/link）
private String MsgType;
// 消息id，64位整型
private long MsgId;
// 消息内容
private String Content;
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 long getMsgId() {
return MsgId;
}
public void setMsgId(long msgId) {
MsgId = msgId;
}
public String getContent() {
return Content;
}
public void setContent(String content) {
Content = content;
}
}接下来的重点就是要去解析我们的请求，将xml数据映射成JavaBean，我们新建一个CoreService去处理我们的请求，在C哦热Servlet中这样操作请求
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
// 将请求、响应的编码均设置为UTF-8（防止中文乱码）
req.setCharacterEncoding("UTF-8");
resp.setCharacterEncoding("UTF-8");
PrintWriter out = resp.getWriter();
CoreService coreService = new CoreService();
String s = coreService.parseWxRequest(req);
// 响应消息，将相应的xml数据转发给微信服务器
out.print(s);
System.out.println("消息："+s);
out.close();
}也就是将微信请求交给CoreService去解析，到这里要知道就是微信请求中是XML数据格式，所以我们返回给微信服务器的也应该是Xml数据，因此，这个parseWxRequest返回的应该是一个字符串，但是这个字符串是一个XML数据，下面看具体的如何解析请求，下面是CoreService的具体写法。关键词推广
public class CoreService {
public static String parseWxRequest(HttpServletRequest request) {
// xml格式的消息数据
String respXml = null;
// 默认返回的文本消息内容
String respContent = "未知的消息类型！";
try {
// 调用parseXml方法解析请求消息
Map requestMap = MessageUtil.parseXml(request);
// 发送方帐号,一个openID
String fromUserName = requestMap.get("FromUserName");
// 开发者微信号
String toUserName = requestMap.get("ToUserName");
// 消息类型
String msgType = requestMap.get("MsgType");
// 接收用户发送的文本消息内容
String content = requestMap.get("Content");
//回复文本消息
TextMessage textMessage = new TextMessage();
textMessage.setToUserName(fromUserName);
textMessage.setFromUserName(toUserName);
textMessage.setCreateTime(System.currentTimeMillis());
textMessage.setMsgType(MessageUtil.REQ_MESSAGE_TYPE_TEXT);
// 文本消息
if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
respContent = "你回复的是文本消息："+content;
textMessage.setContent(respContent);
String xml = MessageUtil.messageToXml(textMessage);
respXml = xml;
}
} catch (Exception e) {
e.printStackTrace();
}
return respXml;
}
}可以看出这里只是对解析后的消息做一个响应，通过
MessageUtil.parseXml(request);
将请求中的XML数据解析出来放在Map集合当中，然后从集合中拿出数据生成一个具体的TextMessage类供我们使用，那么具体的是如何将请求中的XML数据解析成一个Map集合呢。
public class MessageUtil {
// 请求消息类型：文本
public static final String REQ_MESSAGE_TYPE_TEXT = "text";
/**
* 解析微信发来的请求（XML）
*
* @param request
* @return Map
* @throws Exception
*/
@SuppressWarnings("unchecked")
public static Map parseXml(HttpServletRequest request) throws Exception {
// 将解析结果存储在HashMap中
Map map = new HashMap();
// 从request中取得输入流
InputStream inputStream = request.getInputStream();
// 读取输入流
SAXReader reader = new SAXReader();
Document document = reader.read(inputStream);
// 得到xml根元素
Element root = document.getRootElement();
// 得到根元素的所有子节点
List elementList = root.elements();
// 遍历所有子节点
for (Element e : elementList){
map.put(e.getName(), e.getText());
}
// 释放资源
inputStream.close();
inputStream = null;
return map;
}
/**
* 扩展xstream使其支持CDATA
*/
private static XStream xstream = new XStream(new XppDriver() {
@Override
public HierarchicalStreamWriter createWriter(Writer out) {
return new PrettyPrintWriter(out) {
// 对所有xml节点的转换都增加CDATA标记
boolean cdata = true;
@Override
@SuppressWarnings("unchecked")
public void startNode(String name, Class clazz) {
super.startNode(name, clazz);
}
@Override
protected void writeText(QuickWriter writer, String text) {
if (cdata) {
writer.write(" writer.write(text);
writer.write("]]>");
} else {
writer.write(text);
}
}
};
}
});
/**
* 文本消息对象转换成xml
*
* @param textMessage 文本消息对象
* @return xml
*/
public static String messageToXml(TextMessage textMessage) {
xstream.alias("xml", textMessage.getClass());
return xstream.toXML(textMessage);
}
}我们知道微信请求是一个XML格式的数据，这个类可以将XML的数据解析成Java对象，当然也 提供将Java对象再次转换成XML，以便我们作为响应数据返回给微信服务器。
