在上一篇的文章中我們?cè)敿?xì)講述了如何將我們的應(yīng)用服務(wù)器和微信騰訊服務(wù)器之間的對(duì)接操作，最后接入成功，不知道你有沒(méi)有發(fā)現(xiàn)在上一篇的【controller】中我定義了一個(gè) get 方法和一個(gè) post 方法，但是在使用過(guò)程中我們就用了 get 方法，這里我們就來(lái)說(shuō)說(shuō)我們預(yù)留的 post 的方法的使用！

當(dāng)我們?cè)谕瓿闪朔?wù)器驗(yàn)證之后，此后用戶每次向公眾號(hào)發(fā)送消息、或者產(chǎn)生自定義菜單點(diǎn)擊事件時(shí)，開(kāi)發(fā)者填寫(xiě)的服務(wù)器配置 URL 將得到微信服務(wù)器推送過(guò)來(lái)的消息和事件，然后開(kāi)發(fā)者可以依據(jù)自身業(yè)務(wù)邏輯進(jìn)行響應(yīng)，例如回復(fù)消息等！通過(guò)這句話我們能知道后面所有的微信服務(wù)器和我們應(yīng)用服務(wù)器之間的溝通都是通過(guò) post 消息體來(lái)完成的，那么我們這里將講述如何接受微信 post 的消息體！

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

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

普通消息類型：文本消息、圖片消息、語(yǔ)音消息、視頻消息、小視頻消息、地理位置消息、鏈接消息事件消息類型：關(guān)注/取消關(guān)注事件、掃描帶參數(shù)二維碼事件、上報(bào)地理位置事件、自定義菜單事件、點(diǎn)擊菜單拉取消息時(shí)的事件推送、點(diǎn)擊菜單跳轉(zhuǎn)鏈接時(shí)的事件推送消息類型：微信服務(wù)端推送的所有消息體的類型格式都是 xml 格式；

（二）消息重試機(jī)制

微信服務(wù)器在五秒內(nèi)收不到響應(yīng)會(huì)斷掉連接，并且重新發(fā)起請(qǐng)求，總共重試三次。假如服務(wù)器無(wú)法保證在五秒內(nèi)處理并回復(fù)，可以直接回復(fù)空串，微信服務(wù)器不會(huì)對(duì)此作任何處理，并且不會(huì)發(fā)起重試，但是這里后期可以使用【客服消息接口】去完成消息再次推送。

（三）消息接收處理

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

package com.cuiyongzhi.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.PrettyPrintWriter;
import com.thoughtworks.xstream.io.xml.XppDriver;

/**
 * ClassName: MessageUtil
 * @Description: 消息工具類
 * @author dapengniao
 * @date 2016 年 3 月 7 日 上午 10:05:04
 */
public class MessageUtil {  

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

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

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

    /** 
     * 請(qǐng)求消息類型：文本 
     */  
    public static final String REQ_MESSAGE_TYPE_TEXT = "text";  

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

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

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

    /** 
     * 請(qǐng)求消息類型：音頻 
     */  
    public static final String REQ_MESSAGE_TYPE_VOICE = "voice";  

    /** 
     * 請(qǐng)求消息類型：推送 
     */  
    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(自定義菜單點(diǎn)擊事件) 
     */  
    public static final String EVENT_TYPE_CLICK = "CLICK";  

    /**
     * @Description: 解析微信發(fā)來(lái)的請(qǐng)求（XML） 
     * @param @param request
     * @param @return
     * @param @throws Exception   
     * @author dapengniao
     * @date 2016 年 3 月 7 日 上午 10:04:02
     */
    @SuppressWarnings("unchecked")
    public static Map<String, String> parseXml(HttpServletRequest request) throws Exception {  
        // 將解析結(jié)果存儲(chǔ)在 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();  
        // 得到根元素的所有子節(jié)點(diǎn)   
        List<Element> elementList = root.elements();  

        // 遍歷所有子節(jié)點(diǎn)   
        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) {  
                // 對(duì)所有 xml 節(jié)點(diǎn)的轉(zhuǎn)換都增加 CDATA 標(biāo)記   
                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);  
                    }  
                }  
            };  
        }  
    });  
}

在這個(gè)方法體里需要用到部分依賴，需要在 pom 文件加入如下部分：

<!-- xml -->
<dependency>
    <groupId>org.apache.directory.studio</groupId>
    <artifactId>org.dom4j.dom4j</artifactId>
    <version>1.6.1</version>
</dependency>

<dependency>
    <groupId>com.thoughtworks.xstream</groupId>
    <artifactId>xstream</artifactId>
    <version>1.4.8</version>
</dependency>

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

@RequestMapping(value = "security", method = RequestMethod.POST)
    // post 方法用于接收微信服務(wù)端消息
    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);
        }
    }

因?yàn)榍懊嫖覀円呀?jīng)開(kāi)啟了我們的開(kāi)發(fā)者模式，那么當(dāng)我們?cè)谶@里將我們代碼發(fā)布之后再公眾號(hào)上發(fā)送消息，在們的后臺(tái)就能看到我們的消息體進(jìn)入并解析成功了，這里我輸出的是微信的【原始 ID】,截圖大致如下：

http://wiki.jikexueyuan.com/project/java-wechat/images/19.png" alt="" />

在這里我只是做了消息體的接收和轉(zhuǎn)換成 Map,并沒(méi)有對(duì)消息做出來(lái)，那么下一篇我們將講述對(duì)消息的分類處理！感謝你的翻閱，如有疑問(wèn)可以留言討論！

下一篇：Java 微信公眾平臺(tái)開(kāi)發(fā)(十)--微信自定義菜單的創(chuàng)建實(shí)現(xiàn)