3.1 解析微信发来的请求

　　  微信服务器发来的请求消息都被封装在request对象中，可以从request对象中将请求参数取出来。通常是用request的getParament()方法获取请求中的参数，而在这里需要使用request对象的getInputStream()方法。通过getInputStream()方法获得输入流，再使用Dome4j读取输入流并解析XML格式的请求，最后将参数放入HashMap中。这样在我们调用此方法时就能轻易的得到回复消息时需要的对应参数。

　　

/**

         * 解析微信发来的请求（XML）

         *

         * @param request

         * @return Map<String, String>

         * @throws Exception

         */

        //@SuppressWarnings("unchecked")

public static HashMap<String, String> parseXML(HttpServletRequest request) throws Exception {

            // 将解析结果存储在HashMap中

            HashMap<String, String> map = new HashMap<String, String>();

            // 从request中取得输入流

            InputStream inputStream = request.getInputStream();

            // 读取输入流

            SAXReader reader = new SAXReader();

            Document document = reader.read(request.getInputStream());

            // 得到xml根元素

            Element root = document.getRootElement();

            recursiveParseXML(root,map);

            inputStream.close();

            inputStream = null;

            return map;

        }
private static void recursiveParseXML(Element root,HashMap<String, String> map){

            // 得到根元素的所有子节点

            List<Element> elementList = root.elements();

            //判断有没有子元素列表

            if(elementList.size() == 0){

                map.put(root.getName(), root.getText());

            }else{

                //遍历

                for (Element e : elementList){

                    recursiveParseXML(e,map);

                }

            }

        }

　　　3.2 回复消息封装成XML

　　　　公众号服务器在接受并处理完消息后，需要返回特定格式的XML结构进行响应。这里我们使用的是XStream库。

　　

/**

         * 扩展xstream使其支持CDATA

         */

        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);

                        }

                    }

                };

            }

        });

/**

         * 文本消息对象转换成xml

         *

         * @param textMessage 文本消息对象

         * @return xml

         */

        public static String messageToXML(TextMessage textMessage) {

            xstream.alias("xml", TextMessage.class);

            return xstream.toXML(textMessage);

        }

        /**

         * 图片消息对象转换成xml

         *

         * @param imageMessage 图片消息对象

         * @return xml

         */

        public static String messageToXML(ImageMessage imageMessage) {

            xstream.alias("xml", ImageMessage.class);

            return xstream.toXML(imageMessage);

        }

/**

         * 语音消息对象转换成xml

         *

         * @param voiceMessage 语音消息对象

         * @return xml

         */

        public static String messageToXML(VoiceMessage voiceMessage) {

            xstream.alias("xml", VoiceMessage.class);

            return xstream.toXML(voiceMessage);

        }

        /**

         * 视频消息对象转换成xml

         *

         * @param videoMessage 视频消息对象

         * @return xml

         */

        public static String messageToXML(VideoMessage videoMessage) {

            xstream.alias("xml", VideoMessage.class);

            return xstream.toXML(videoMessage);

        }

　　　　完整代码：

package com.util;

import java.io.InputStream;

import java.io.Writer;

import java.util.HashMap;

import java.util.List;

import javax.servlet.http.HttpServletRequest;

import org.dom4j.Document;

import org.dom4j.Element;

import org.dom4j.io.SAXReader;

import com.message.ImageMessage;

import com.message.TextMessage;

import com.message.VideoMessage;

import com.message.VoiceMessage;

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;

/**

 *

 * @author 黄路飞

 *

 * @data  2016年6月18日21:56:47

 */

public class MessageUtil {

    // 请求消息类型：文本

        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_VOICE = "voice";

        // 请求消息类型：视频

        public static final String REQ_MESSAGE_TYPE_VIDEO = "video";

        // 请求消息类型：地理位置

        public static final String REQ_MESSAGE_TYPE_LOCATION = "location";

        // 请求消息类型：链接

        public static final String REQ_MESSAGE_TYPE_LINK = "link";

        // 请求消息类型：事件推送

        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";

        // 事件类型：scan(用户已关注时的扫描带参数二维码)

        public static final String EVENT_TYPE_SCAN = "scan";

        // 事件类型：LOCATION(上报地理位置)

        public static final String EVENT_TYPE_LOCATION = "LOCATION";

        // 事件类型：CLICK(自定义菜单)

        public static final String EVENT_TYPE_CLICK = "CLICK";

        // 响应消息类型：文本

        public static final String RESP_MESSAGE_TYPE_TEXT = "text";

        // 响应消息类型：图片

        public static final String RESP_MESSAGE_TYPE_IMAGE = "image";

        // 响应消息类型：语音

        public static final String RESP_MESSAGE_TYPE_VOICE = "voice";

        // 响应消息类型：视频

        public static final String RESP_MESSAGE_TYPE_VIDEO = "video";

        // 响应消息类型：音乐

        public static final String RESP_MESSAGE_TYPE_MUSIC = "music";

        // 响应消息类型：图文

        public static final String RESP_MESSAGE_TYPE_NEWS = "news";

        /**

         * 解析微信发来的请求（XML）

         *

         * @param request

         * @return Map<String, String>

         * @throws Exception

         */

        //@SuppressWarnings("unchecked")

        public static HashMap<String, String> parseXML(HttpServletRequest request) throws Exception {

            // 将解析结果存储在HashMap中

            HashMap<String, String> map = new HashMap<String, String>();

            // 从request中取得输入流

            InputStream inputStream = request.getInputStream();

            // 读取输入流

            SAXReader reader = new SAXReader();

            Document document = reader.read(request.getInputStream());

            // 得到xml根元素

            Element root = document.getRootElement();

            recursiveParseXML(root,map);

            inputStream.close();

            inputStream = null;

            return map;

        }

        private static void recursiveParseXML(Element root,HashMap<String, String> map){

            // 得到根元素的所有子节点

            List<Element> elementList = root.elements();

            //判断有没有子元素列表

            if(elementList.size() == 0){

                map.put(root.getName(), root.getText());

            }else{

                //遍历

                for (Element e : elementList){

                    recursiveParseXML(e,map);

                }

            }

        }

        /**

         * 扩展xstream使其支持CDATA

         */

        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);

                        }

                    }

                };

            }

        });

        /**

         * 文本消息对象转换成xml

         *

         * @param textMessage 文本消息对象

         * @return xml

         */

        public static String messageToXML(TextMessage textMessage) {

            xstream.alias("xml", TextMessage.class);

            return xstream.toXML(textMessage);

        }

        /**

         * 图片消息对象转换成xml

         *

         * @param imageMessage 图片消息对象

         * @return xml

         */

        public static String messageToXML(ImageMessage imageMessage) {

            xstream.alias("xml", ImageMessage.class);

            return xstream.toXML(imageMessage);

        }

        /**

         * 语音消息对象转换成xml

         *

         * @param voiceMessage 语音消息对象

         * @return xml

         */

        public static String messageToXML(VoiceMessage voiceMessage) {

            xstream.alias("xml", VoiceMessage.class);

            return xstream.toXML(voiceMessage);

        }

        /**

         * 视频消息对象转换成xml

         *

         * @param videoMessage 视频消息对象

         * @return xml

         */

        public static String messageToXML(VideoMessage videoMessage) {

            xstream.alias("xml", VideoMessage.class);

            return xstream.toXML(videoMessage);

        }

    }

最新文章

  1. java判断输入的数是不是素数
  2. 牛顿法与拟牛顿法学习笔记（四）BFGS 算法
  3. 写出优美代码的两个方式：一步到位VS迭代优化
  4. [水煮 ASP.NET Web API 2 方法论] 目 录
  5. 37.Activity之间的转换以及数据的传递（Intent）学习
  6. 复制选中的listbox内容
  7. 实例--post请求，完成一个抽奖程序概率的测试
  8. 关于cmd的东西
  9. Oracle实例与Oracle数据库
  10. ASP.NET用户自定义控件配置
  11. C++中++运算符的重载
  12. C#生成随机汉字
  13. MySQL 异常错误码使用 及 对照表
  14. 微信小程序开发之详解生命周期方法
  15. C语言博客作业--字符数组-陈张鑫
  16. webpack学习笔记--其它配置项
  17. Why validation set ?
  18. c++冒号作用
  19. loadrunner&#160;Vugen-Tools&#160;General-Options-Replay设置
  20. RPC原理

热门文章

  1. java异常处理的设计
  2. moffiestyle
  3. YII2 缩略图生成 第三方包修改
  4. react-native start 运行流程
  5. 在CDH5.5.0上安装Phoenix1.2
  6. Android TelephonyManager电话管理器
  7. SQL SERVER 字符串常用函数
  8. hibernate 返回新插入数据的Id
  9. iOS UITableView 引起的崩溃问题
  10. jquery.get()