微信公众号开发基础篇(五)

一、书写一个公共类型的类,进行消息类型的转换

       

package com.my.utils;

import java.io.InputStream;
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.my.pojo.TextMessage;
import com.thoughtworks.xstream.XStream;

/**
 * 
 * // @author liuya
 * 
 * // 后端接收,微信公众号发过来的消息功能
 * 
 * 
 * // 1、将XML转换成集合类型 (因为微信后台发过来的消息是一个XML类型,为了方便处理,需要把微信发来的消息,转化成集合类型)
 * 
 * // 2、对象类型转化成XML类型(因为我们这边发送消息,也需要把数据转化成XML类型给微信服务后台接收)
 */

public class MessageUtils {

    /**
     * 需要导入dom4j---jar包 //
     * 
     * //1、将XML转换成集合类型 (因为微信后台发过来的消息是一个XML类型,为了方便处理,需要把微信发来的消息,转化成集合类型)//
     * 
     * @param request
     * @return
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    public static Map<String, String> xmlToMap(HttpServletRequest request)
            throws Exception {

        Map<String, String> map = new HashMap<String, String>();
        SAXReader sReader = new SAXReader();

        // 从request中获取输入流
        InputStream inStream = request.getInputStream();
        Document document = sReader.read(inStream);

        // 获取xml中的根元素
        Element rootElement = document.getRootElement();

        // 得到根元素的所有子节点,把它放在list的集合中
        List<Element> list = rootElement.elements();

        // 遍历list对象,获取单个元素的数据
        for (Element element : list) {

            // 遍历的结果保存到集合中
            map.put(element.getName(), element.getText());
        }

        // 关闭流
        inStream.close();

        return map;
    }

    /**
     * 导入xsream---jar包
     * 
     * // 2、对象类型转化成XML类型(因为我们这边发送消息,也需要把数据转化成XML类型给微信服务后台接收)
     * 
     * // 3、创建文本消息需要的实体类
     * 
     * @param textMessage
     * @return
     */
    public static String textMessageToXml(TextMessage textMessage) {
        XStream xstream = new XStream();

        // 打印出根节点的<xml>
        xstream.alias("xml", textMessage.getClass());
        // 返回发来的消息到控制台
        return xstream.toXML(textMessage);
    }

}

二、书写消息属性的pojo类，属性是微信开发文档上的参数

       

package com.my.pojo;

/**
 * 
 * @author liuya
 * 
 * 
 *         // 文本消息使用的实体类
 */

public class TextMessage {

    // 需要的属性,通过开发文档得到6个属性

    // 开发者微信号
    private String FromUserName;
    // 发送方账号(一个OpenID)
    private String ToUserName;
    // 消息创建时间(整型)
    private long CreateTime;
    // text
    private String MsgType;
    // 文本消息内容
    private String Content;
    // 消息id,64位整数
    private String MsgId;

    public TextMessage() {
    }

    public TextMessage(String fromUserName, String toUserName, long createTime,
            String msgType, String content, String msgId) {
        FromUserName = fromUserName;
        ToUserName = toUserName;
        CreateTime = createTime;
        MsgType = msgType;
        Content = content;
        MsgId = msgId;
    }

    public String getFromUserName() {
        return FromUserName;
    }

    public void setFromUserName(String fromUserName) {
        FromUserName = fromUserName;
    }

    public String getToUserName() {
        return ToUserName;
    }

    public void setToUserName(String toUserName) {
        ToUserName = toUserName;
    }

    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 String getContent() {
        return Content;
    }

    public void setContent(String content) {
        Content = content;
    }

    public String getMsgId() {
        return MsgId;
    }

    public void setMsgId(String msgId) {
        MsgId = msgId;
    }

    @Override
    public String toString() {
        return "TextMessage [FromUserName=" + FromUserName + ", ToUserName="
                + ToUserName + ", CreateTime=" + CreateTime + ", MsgType="
                + MsgType + ", Content=" + Content + ", MsgId=" + MsgId + "]";
    }

}

三、文本消息类型的接收与响应（红色部分）

package com.my.servlet;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;
import java.util.Map;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.my.pojo.TextMessage;
import com.my.utils.CheckUtil;
import com.my.utils.MessageUtils;

/**
 * 
 * @author liuya
 * 
 * 
 *         //微信连接
 * 
 *         微信消息的接收与发送
 * 
 */

public class WeXinServlet extends HttpServlet {

    /**
     * 随机生成的版本id
     */
    private static final long serialVersionUID = 1L;

    /**
     * 开发文档第一部分与微信的连接方式代码
     */
    @Override
    protected void doGet(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {

        
         System.out.println("request.getRequestURL()返回的结果："+request.getRequestURL());
        
        // 跟微信平台比较的参数
        String signature = request.getParameter("signature");
        String timestamp = request.getParameter("timestamp");
        String nonce = request.getParameter("nonce");
        String echostr = request.getParameter("echostr");

        PrintWriter pWriter = response.getWriter();
        // 微信get后进行比较
        if (CheckUtil.checkSignature(signature, timestamp, nonce)) {
            pWriter.print(echostr);
        }

    }

 59     /**
 60      * // 1、将XML转换成集合类型 (因为微信后台发过来的消息是一个XML类型,为了方便处理,需要把微信发来的消息,转化成集合类型)
 61      * 
 62      * 
 63      * // 2、对象类型转化成XML类型(因为我们这边发送消息,也需要把数据转化成XML类型给微信服务后台接收)
 64      * 
 65      * 
 66      * // 3、书写一个公共类型的类,进行消息类型的转换
 67      * 
 68      * 文本消息类型的接收与响应
 69      * 
 70      */
 71 
 72     @Override
 73     protected void doPost(HttpServletRequest requset,
 74             HttpServletResponse response) throws ServletException, IOException {
 75 
 76         // 设置消息发来的格式
 77         requset.setCharacterEncoding("UTF-8");
 78         // 设置接收的消息格式
 79         response.setCharacterEncoding("UTF-8");
 80 
 81         // 通过此方法进行消息返回
 82         PrintWriter outPrintWriter = response.getWriter();
 83 
 84         // 1.微信消息的接收 集合获取
 85         Map<String, String> map;
 86         try {
 87             map = MessageUtils.xmlToMap(requset);
 88 
 89             // 2.获取集合中的属性
 90             // 开发者微信号
 91             String toUserName = (String) map.get("ToUserName");
 92             // 发送方账号(一个OpenID)
 93             String fromUserName = (String) map.get("FromUserName");
 94             // 消息类型
 95             String msgType = (String) map.get("MsgType");
 96             // 文本消息内容
 97             String content = (String) map.get("Content");
 98 
 99             // 3.根据messageType判断消息是不是文本消息
100             // 设置消息回复变量
101             String message = null;
102 
103             // 如果是文本消息,就进行回复
104             if ("text".equals(msgType)) {
105 
106                 // 创建消息对象
107                 TextMessage text = new TextMessage();
108 
109                 // 开发者微信号
110                 text.setFromUserName(toUserName);
111 
112                 // 发送方账号(一个OpenID)
113                 text.setFromUserName(fromUserName);
114 
115                 // 消息类型
116                 text.setMsgType("text");
117 
118                 // 消息创建时间,当前时间
119                 text.setCreateTime(new Date().getTime());
120 
121                 // 文本消息内容(当微信输入消息的时候,返回给它,它输入的消息)
122                 text.setContent("客户发来的消息是   :***************" + content
123                         + "  *******************");
124 
125                 // 消息类型转化为微信可识别的xml类型
126                 message = MessageUtils.textMessageToXml(text);

                      // 打印消息到控制台
                      System.out.print(message);

127 
128             }
129 
130             // 消息返回
131             outPrintWriter.print(message);
132 
133         } catch (Exception e) {
134             e.printStackTrace();
135         } finally {
136             // 关闭流
137             outPrintWriter.close();
138         }
139 
140     }
141 
142 }

四、设置内网穿透工具

       

五、启动Tomcat

六、微信公众号上输入内容、查看控制台和微信上的结果