Java微信公眾平台開發(二)--微信服務器post消息體的接收

在上一篇的文章中我們詳細講述了如何將我們的應用服務器和微信騰訊服務器之間的對接操作，最后接入成功，不知道你有沒有發現在上一篇的【controller】中我定義了一個get方法和一個post方法，但是在使用過程中我們就用了get方法，這里我們就來說說我們預留的post的方法的使用！

當我們在完成了服務器驗證之后，此后用戶每次向公眾號發送消息、或者產生自定義菜單點擊事件時，開發者填寫的服務器配置URL將得到微信服務器推送過來的消息和事件，然后開發者可以依據自身業務邏輯進行響應，例如回復消息等！通過這句話我們能知道后面所有的微信服務器和我們應用服務器之間的溝通都是通過post消息體來完成的，那么我們這里將講述如何接受微信post的消息體！

（一）消息類型和消息格式

上面有說道我們所有的和微信服務器之間進行溝通基本都是通過post消息體完成的，首先我們了解下消息體的類型，大致類型有兩種：

• 普通消息類型：文本消息、圖片消息、語音消息、視頻消息、小視頻消息、地理位置消息、鏈接消息

• 事件消息類型：關注/取消關注事件、掃描帶參數二維碼事件、上報地理位置事件、自定義菜單事件、點擊菜單拉取消息時的事件推送、點擊菜單跳轉鏈接時的事件推送

消息類型：微信服務端推送的所有消息體的類型格式都是xml格式；

（二）消息重試機制

微信服務器在五秒內收不到響應會斷掉連接，並且重新發起請求，總共重試三次。假如服務器無法保證在五秒內處理並回復，可以直接回復空串，微信服務器不會對此作任何處理，並且不會發起重試，但是這里后期可以使用【客服消息接口】去完成消息再次推送。

（三）消息接收處理

在前面我們有說道微信的消息體是采用xml格式，那么我在這里寫了一個MessageUtil去做消息格式的處理，大致代碼如下：

package com.gede.wechat.util;

import java.io.InputStream;
import java.io.Writer;
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.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.core.util.QuickWriter;
import com.thoughtworks.xstream.io.HierarchicalStreamWriter;
import com.thoughtworks.xstream.io.xml.DomDriver;
import com.thoughtworks.xstream.io.xml.PrettyPrintWriter;
import com.thoughtworks.xstream.io.xml.XppDriver;
/**
* @author gede
* @version date：2019年5月22日 下午3:44:27
* @description ：
*/
public class MessageUtil {

    /**
     * 返回消息類型：文本
     */
    public static final String RESP_MESSAGE_TYPE_TEXT = "text";

    /**
     * 返回消息類型：音樂
     */
    public static final String RESP_MESSAGE_TYPE_MUSIC = "music";

    /**
     * 返回消息類型：圖文
     */
    public static final String RESP_MESSAGE_TYPE_NEWS = "news";

    /**
     * 返回消息類型：圖片
     */
    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 REQ_MESSAGE_TYPE_TEXT = "text";

    /**
     * 請求消息類型：圖片
     */
    public static final String REQ_MESSAGE_TYPE_IMAGE = "image";

    /**
     * 請求消息類型：鏈接
     */
    public static final String REQ_MESSAGE_TYPE_LINK = "link";

    /**
     * 請求消息類型：地理位置
     */
    public static final String REQ_MESSAGE_TYPE_LOCATION = "location";

    /**
     * 請求消息類型：音頻
     */
    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_EVENT = "event";

    /**
     * 事件類型：subscribe(訂閱)
     */
    public static final String EVENT_TYPE_SUBSCRIBE = "subscribe";

    /**
     * 事件類型：unsubscribe(取消訂閱)
     */
    public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe";

    /**
     * 事件類型：CLICK(自定義菜單點擊事件)
     */
    public static final String EVENT_TYPE_CLICK = "CLICK";

    /**
     * 事件類型：VIEW(自定義菜單 URl 視圖)
     */
    public static final String EVENT_TYPE_VIEW = "VIEW";

    /**
     * 事件類型：LOCATION(上報地理位置事件)
     */
    public static final String EVENT_TYPE_LOCATION = "LOCATION";

    /**
     * 事件類型：LOCATION(上報地理位置事件)
     */

    @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;  
    }  
   
    @SuppressWarnings("unused")
    private static XStream xstream = new XStream(new XppDriver() {  
        public HierarchicalStreamWriter createWriter(Writer out) {  
            return new PrettyPrintWriter(out) {  
                // 對所有xml節點的轉換都增加CDATA標記   
                boolean cdata = true;  
                @SuppressWarnings("rawtypes")
                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包錯誤，而如果按我前言中所提到的前輩的思路取走也許不會錯，后續也會省區很多麻煩，但前提你必須要學會maven的使用。這也正是我為什么要翻寫前輩的博客的原因。在成長的路上，也許有人不如我，但更多的人時比我強的，我只是想盡力去幫助那些不如我還在努力的人，同時也鞭策自己積極上進。在之后的開發中，每一次用到的jar包我都會在文末附上下載鏈接，大家放心下載即可。

然后將我們的WechatSecurity Controller中的post方法修改為如下，用於做消息的接收和處理：

@RequestMapping(value = "security", method = RequestMethod.POST)
    // post方法用於接收微信服務端消息
    public void DoPost(HttpServletRequest request,HttpServletResponse response) {
        System.out.println("這是post方法！");
        try{
        Map<String, String> map=MessageUtil.parseXml(request);
        System.out.println("============================="+map.get("Content"));
        }catch(Exception e){
            logger.error(e,e);
        }
    }

 

 重新運行項目，進行測試。下面是我的測試圖。

 

 

那么當我們在這里將我們代碼發布之后再公眾號上發送消息，在們的后台就能看到我們的消息體進入並解析成功了。

在這里我只是做了消息體的接收和轉換成Map,並沒有對消息做出來，那么下一篇我們將講述對消息的分類處理！

 

涉及到的相關jar包下載地址：dom4j-2.0.2　xmlpull-1.1.3.1　　xpp3_min-1.1.4c　　xstream-1.4.7-sources　　xstream-1.4.8