Java微信公众平台开发(二)--微信服务器post消息体的接收
轉自:?http://www.cuiyongzhi.com/post/39.html
在上一篇的文章中我們詳細講述了如何將我們的應用服務器和微信騰訊服務器之間的對接操作,最后接入成功,不知道你有沒有發現在上一篇的【controller】中我定義了一個get方法和一個post方法,但是在使用過程中我們就用了get方法,這里我們就來說說我們預留的post的方法的使用!
當我們在完成了服務器驗證之后,此后用戶每次向公眾號發送消息、或者產生自定義菜單點擊事件時,開發者填寫的服務器配置URL將得到微信服務器推送過來的消息和事件,然后開發者可以依據自身業務邏輯進行響應,例如回復消息等!通過這句話我們能知道后面所有的微信服務器和我們應用服務器之間的溝通都是通過post消息體來完成的,那么我們這里將講述如何接受微信post的消息體!
(一)消息類型和消息格式
上面有說道我們所有的和微信服務器之間進行溝通基本都是通過post消息體完成的,首先我們了解下消息體的類型,大致類型有兩種:
-
普通消息類型:文本消息、圖片消息、語音消息、視頻消息、小視頻消息、地理位置消息、鏈接消息
-
事件消息類型:關注/取消關注事件、掃描帶參數二維碼事件、上報地理位置事件、自定義菜單事件、點擊菜單拉取消息時的事件推送、點擊菜單跳轉鏈接時的事件推送
消息類型:微信服務端推送的所有消息體的類型格式都是xml格式;
(二)消息重試機制
微信服務器在五秒內收不到響應會斷掉連接,并且重新發起請求,總共重試三次。假如服務器無法保證在五秒內處理并回復,可以直接回復空串,微信服務器不會對此作任何處理,并且不會發起重試,但是這里后期可以使用【客服消息接口】去完成消息再次推送。
(三)消息接收處理
在前面我們有說道微信的消息體是采用xml格式,那么我在這里寫了一個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";?? ??? ????/**? ?????*?返回消息類型:音樂? ?????*/?? ????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:?解析微信發來的請求(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();?? ????????//?得到根元素的所有子節點??? ????????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);?? ????????????????????}?? ????????????????}?? ????????????};?? ????????}?? ????});?? } |
在這個方法體里需要用到部分依賴,需要在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方法用于接收微信服務端消息 ????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); ????????} ????} |
因為前面我們已經開啟了我們的開發者模式,那么當我們在這里將我們代碼發布之后再公眾號上發送消息,在們的后臺就能看到我們的消息體進入并解析成功了,這里我輸出的是微信的【原始ID】,截圖大致如下:
在這里我只是做了消息體的接收和轉換成Map,并沒有對消息做出來,那么下一篇我們將講述對消息的分類處理!感謝你的翻閱,如有疑問可以留言討論!
總結
以上是生活随笔為你收集整理的Java微信公众平台开发(二)--微信服务器post消息体的接收的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: scrapy爬虫值Items
- 下一篇: 泛圈科技:YottaChain区块链存储