微信公众号开发小记（三）识别文本信息

淩亂°似流年 2021-09-16 01:40 472阅读 0赞

经过上一篇的讲解，我们已经将自己的服务器与微信服务器完成对接，现在，如果你在微信公众号上发消息，就会产生一个请求，而这个请求就会由我们写的CoreServlet来处理。

这次要实现的功能是，微信公众号可以识别你发送的文本消息类型，比如你回复个”你好”，微信公众号会回复给你一句“你发送的是文本消息：你好”，就类似这样的功能，我们来看该怎么实现。

首先你要知道的是，你向微信公众号发送一个文本消息，这样会产生一个post请求给微信服务器，而微信服务器会将这个请求转发给我们的服务器，准确来说是交给我们的CoreServlet来处理。

要处理这块我们需要查看官方技术文档，也就是这块—接收普通消息

![2v1xedk.png][]

这个需要你自己去仔细看看，然后我们会发现我们发送的消息最终是一个XML数据包，看官方的一句解释

> 当普通微信用户向公众账号发消息时，微信服务器将POST消息的XML数据包到开发者填写的URL上。

文本消息的XML数据包结构是这样的

这里面包含一些参数如下

<table> 
 <thead> 
  <tr> 
   <th>ToUserName</th> 
   <th>开发者微信号</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>FromUserName</td> 
   <td>发送方帐号（一个OpenID）</td> 
  </tr> 
  <tr> 
   <td>CreateTime</td> 
   <td>消息创建时间 （整型）</td> 
  </tr> 
  <tr> 
   <td>MsgType</td> 
   <td>text</td> 
  </tr> 
  <tr> 
   <td>Content</td> 
   <td>文本消息内容</td> 
  </tr> 
  <tr> 
   <td>MsgId</td> 
   <td>消息id，64位整型</td> 
  </tr> 
 </tbody> 
</table>

也就是说，现在你往微信公众号上发送一段文字，然后最终会形成一个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<String, String> 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<String, String> * @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;
        }
    
        /** * 扩展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("<![CDATA[");
                            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，以便我们作为响应数据返回给微信服务器。

这个类主要用到了dom4j和XStream，感兴趣的可以研究一下，不然这块看起来还是有点小难度的。

接下来将我们的项目打包上传到服务器，上传成功之后可以在公众号回复一个文字测试，如下

![29ar6ls.png][]

> 未完待续

[2v1xedk.png]: /images/20210813/b38352143b0c4a1ab02fe87609910502.png
[29ar6ls.png]: /images/20210813/5299aa9002ce4171914151d2ee069425.png