Java微信公眾平臺開發(fā)（2）微信服務器post消息體的接收

2019-11-26 12:32:40

字體：大中小

來源：轉載

供稿：網(wǎng)友

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

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

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

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

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

事件消息類型：關注/取消關注事件、掃描帶參數(shù)二維碼事件、上報地理位置事件、自定義菜單事件、點擊菜單拉取消息時的事件推送、點擊菜單跳轉鏈接時的事件推送
消息類型：微信服務端推送的所有消息體的類型格式都是xml格式；

（二）消息重試機制

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

（三）消息接收處理

在前面我們有說道微信的消息體是采用xml格式，那么我在這里寫了一個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";     /**    * 返回消息類型：音樂    */   public static final String RESP_MESSAGE_TYPE_MUSIC = "music";     /**    * 返回消息類型：圖文    */   public static final String RESP_MESSAGE_TYPE_NEWS = "news";     /**    * 請求消息類型：文本    */   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_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";     /**   * @Description: 解析微信發(fā)來的請求（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 {     // 將解析結果存儲在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é)點      List<Element> elementList = root.elements();       // 遍歷所有子節(jié)點      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節(jié)點的轉換都增加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);           }         }       };     }   }); }

在這個方法體里需要用到部分依賴，需要在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方法用于接收微信服務端消息  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);    }  }

因為前面我們已經(jīng)開啟了我們的開發(fā)者模式，那么當我們在這里將我們代碼發(fā)布之后再公眾號上發(fā)送消息，在們的后臺就能看到我們的消息體進入并解析成功了，這里我輸出的是微信的【原始ID】,截圖大致如下：