轉(zhuǎn)自：?http://www.cuiyongzhi.com/post/39.html

在上一篇的文章中我們?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í)，開發(fā)者填寫的服務(wù)器配置URL將得到微信服務(wù)器推送過(guò)來(lá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格式，那么我在這里寫了一個(gè)MessageUtil去做消息格式的處理，大致代碼如下：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145

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文件加入如下部分：

1 2 3 4 5 6 7 8 9 10 11 12

<!--?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方法修改為如下，用于做消息的接收和處理：

1 2 3 4 5 6 7 8 9 10 11

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

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

總結(jié)

以上是生活随笔為你收集整理的Java微信公众平台开发(二)--微信服务器post消息体的接收的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。