玩玩微信公眾號Java版之二：接收、處理及返回微信消息

前面已經配置了微信服務器，那么先開始最簡單的接收微信消息吧~

 

可以用我們的微信號來直接進行測試，下面先看測試效果圖：

 

 

這是最基本的文本消息的接收、處理及返回，來看看是怎么實現的吧！

 

首先可以參考微信消息相關的接口文檔： https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140453

 

具體實現如下：

第一步，接收微信發送的文本消息入口：

 

/**
     * 處理微信服務器發來的消息
     */
    public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
    {
        // TODO 消息的接收、處理、響應
        System.out.println("接口調用了一次");

        String ret = IOUtils.toString(request.getInputStream(), "utf-8").toString();
        System.out.println(ret);

        WeChatMsgBL tWeChatMsgBL = new WeChatMsgBL();
        String result = tWeChatMsgBL.dealWechatMsg(ret);

        response.setCharacterEncoding("UTF-8");

        // 返回文本消息，將處理結果返回
        PrintWriter out = response.getWriter();

        System.out.println(result);

        out.print(result);

        out.close();

    }

可以先輸出接收到的xml信息：

 

第二步，解析及處理接收到數據的內容：

從微信提供的接口文檔上，我們可以發現，不論是文本消息還是語音、圖片等消息，在xml報文中，有部分節點信息的一致的，因此可以創建一個父類在處理（變量名要與xml中節點名一致，大小寫也一樣，這樣后面返回消息結果時很方便）：

/**
 * 微信消息主要類
 * @author user
 */
public class WechatMsg
{
    // 開發者微信號
    private String ToUserName = "";

    // 發送方帳號（一個OpenID）
    private String FromUserName = "";

    // 消息創建時間 （整型）
    private String CreateTime = "";

    // 消息類型
    private String MsgType = "";

    // 消息id，64位整型
    private String MsgId = "";

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



}

然后對應的基本信息子類為（只用多一個變量）：

/**
 * 普通消息類
 * @author Damon
 */
public class WechatTextMsg extends WechatMsg
{

    // 文本內容
    private String Content = "";

    public String getContent()
    {
        return Content;
    }

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

 

下面來看具體的處理，涉及新增jar包：dom4j-1.6.1.jar  

    /**
     * 處理微信信息
     * @param reqInfo xml信息數據
     * @return 處理結果
     */
    public String dealWechatMsg(String reqInfo)
    {

        String ret = reqInfo;

        String result = "";

        WechatTextMsg tReturnMsg = new WechatTextMsg();

        try
        {
            Document returndoc = DocumentHelper.parseText(ret);

            Element rootElement = returndoc.getRootElement();

            String tMsgType = rootElement.elementText("MsgType");

            // 根據MsgType 返回具體的消息類

            if (SysCon.TEXT_MSG_TYPE.equals(tMsgType))
            {
                result = dealTextMsg(rootElement);
            }

            // 封裝返回信息
            tReturnMsg.setCreateTime(new Date().getTime() + "");
            tReturnMsg.setToUserName(rootElement.elementText("FromUserName"));
            tReturnMsg.setFromUserName(rootElement.elementText("ToUserName"));
            tReturnMsg.setContent(result);
            tReturnMsg.setMsgType(SysCon.TEXT_MSG_TYPE);
            // 將返回結果封裝成文本消息
            result = WeChatUtil.textToXML(tReturnMsg);
        }
        catch (DocumentException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        return result;
    }

    /**
     * 處理文本消息
     * @param msg
     * @return
     */
    private String dealTextMsg(Element rootElement)
    {

        WechatTextMsg tWechatTextMsg = new WechatTextMsg();
        // 依次賦值
        tWechatTextMsg.setCreateTime(rootElement.elementText("CreateTime"));
        tWechatTextMsg.setFromUserName(rootElement.elementText("FromUserName"));
        tWechatTextMsg.setToUserName(rootElement.elementText("ToUserName"));
        tWechatTextMsg.setMsgType(rootElement.elementText("MsgType"));
        tWechatTextMsg.setMsgId(rootElement.elementText("MsgId"));
        tWechatTextMsg.setContent(rootElement.elementText("Content"));

        System.out.println("傳入的消息是：" + tWechatTextMsg.getContent());

        // 后續可處理保存到數據庫及數據分析等，現在直接返回結果

        // 將數據轉存至數據庫
        // Connection conn = DBConnPool.getConnection();

        return "傳入的文本消息處理完畢";
    }

其中對於參數類型判斷，可以在SysCon類中添加基本參數

 

    // 定義微信消息類型--文本
    public static final String TEXT_MSG_TYPE = "text";

 

第三步，處理消息的返回

消息處理完成后，返回文本（可返回不同類型，僅以文本為例）處理結果

這里用到了工具類中 的方法如下：

    /**
     * 將對象轉為XML輸出
     * @param textMsg
     * @return
     */
    public static String textToXML(WechatTextMsg textMsg)
    {
        xstream.alias("xml", textMsg.getClass());
        return xstream.toXML(textMsg);

    }

    
    /**
     * 擴展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);
                    }
                }
            };
        }
    });

涉及到新增jar包：xstream-1.3.1.jar

可以在最后返回前輸出處理的結果：

微信上可接收到消息：傳入的文本消息處理完畢。

 

 到這，本節內容就結束了，可以自己去擴展語音消息的接收和處理哦~