微信公眾號-訊息推送-實現固定模式下的私人訂製
開發微信已經將近4個月了,但是還是不會本地除錯,只能部署到伺服器上,通過打日誌,來看是否有錯,@ALL哪位同志,如果有好的方法,可以告訴我。
先簡要介紹一下微信公眾號,訊息推送的原理。
微信公眾號只是一個平臺,這個平臺的功能是一樣的,但是這個功能的內容卻可以由這個公眾號的主人決定。這些內容實現了微信公眾號的私人訂製。
就像關注一個公眾號之後,會有一個歡迎詞,都是歡迎詞的功能。有的公眾號推送了滿滿一屏的文字,有的公眾號只是寥寥數字。
利用內容的不同,微信公眾號得以推廣。
這個功能一個測試公眾號就可以完成,對微信開發有興趣的同學可以嘗試一下。
本姑娘從事的是java開發,所以文中所有的程式碼均為java
- 第一步,我們要寫程式碼部署到一個解析了域名的伺服器上,讓外界可以訪問到。
為了實現訊息推送功能,我們需要@RequestMapping value值一樣的2個方法,但是RequestMethod一個為GET,一個為POST.
GET方法,用於微信公眾號後臺配置url+token,POST方法用於接收微信公眾號推送的訊息。
無論GET方法,還是POST方法,都需要驗證簽名的正確性。
程式碼附上: |
/** * 驗證url+token token+timestamp+nonce asc排序SHA1加密與signature對比,相同 * *@param request *@return */ public boolean checkSignature(HttpServletRequestrequest) { String signature = request.getParameter("signature"); String timestamp = request.getParameter("timestamp"); String nonce = request.getParameter("nonce"); String echostr = request.getParameter("echostr"); logger.debug("signature=============================:" logger.debug("timestamp=============================:" +timestamp); logger.debug("nonce=================================:" +nonce); logger.debug("echostr===============================:" +echostr); // 1.將token,timestamp,nonce三個引數排序 //TODO 這個引數之後可能會變,暫時先寫死 String token = "qichejiadaojavaweixintoken";//這裡的token值就是微信公眾號後臺配置的token,值必須一樣。 String[] str = new String[] { token, timestamp, nonce }; Arrays.sort(str); // 2.將三個引數字串接成一個字串 StringBuilder buff = new StringBuilder(); for (inti = 0; i <str.length;i++) { buff.append(str[i]); } // 3.進行sha1加密 MessageDigest md = null; String result = ""; try { md = MessageDigest.getInstance("SHA-1"); byte[]date = md.digest(buff.toString().getBytes()); // 將位元組陣列轉換成字串 result = bytesToStr(date); logger.debug("加密後" +result); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } returnresult != null ? (result.equals(signature.toUpperCase())) :false; } // 將直接陣列轉換成十六進位制字串 private static String bytesToStr(byte[]byteArray) { String strDigest = ""; for (inti = 0; i <byteArray.length;i++) { strDigest += byteToHexStr(byteArray[i]); } returnstrDigest; } // 將一個位元組轉換成16進位制字串 private static String byteToHexStr(bytemByte) { char[]Digit = { '0','1', '2', '3', '4', '5','6', '7', '8', '9', 'A','B', 'C', 'D', 'E', 'F' }; char[]temp1 = new char[2]; temp1[0] =Digit[mByte >>> 4 & 0X0F]; temp1[1] =Digit[mByte & 0X0F]; String str = new String(temp1); returnstr; } |
GET方法驗證簽名正確後,直接返回簽名,微信服務端得到的簽名與後臺配置的簽名一致。url+token,即可配置成功。
程式碼附上: |
/** * 驗證url和token,當所請求的方法為GET時,正常返回echostr即可 * *@param request *@param response *@throws IOException */ @RequestMapping(value ="/eventpush", method = RequestMethod.GET) public void EventPushGet(HttpServletRequestrequest, HttpServletResponse response) throws IOException { logger.debug("==================eventpush:Get========================"); PrintWriter out = response.getWriter(); if (checkSignature(request)) { out.write(request.getParameter("echostr")); } else { out.write("error"); } } |
完成了GET方法,我們將程式碼部署到伺服器上。到微信公眾號後臺,找到開發-->基本配置。
url處填寫,我們剛剛完成的get方法的訪問地址,當然要是全域名的例如:http://test.mywechat.cn/eventpush
Token處填寫我們程式碼中用到的token,這個值可以隨便定義,但是驗證簽名的程式碼用到的token值一定要和這裡的一致。否則驗證不通過。
EncodingASEKey處生成就可以。
訊息加解密方式沒有深的研究。
提交併啟用。
url+token,配置成功,我們只做到了訊息推送的第一步。
- 接下來我們來看一下,我們第一步中強調的POST方法能為我們做些什麼。
附上controller程式碼: |
@RequestMapping(value ="/eventpush", method = RequestMethod.POST) public void EventPushPost(HttpServletRequestrequest, HttpServletResponse response) throws IOException { // 1.判斷推動的資料型別 logger.debug("==================eventpush:POST========================"); PrintWriter out = response.getWriter(); if (checkSignature(request)) { String message = eventPushService.DoEvent(request); out.write(message); } else { out.write("error"); } } |
微信公眾號會將使用者傳送的訊息(語音,圖片),點選的事件(例如使用者點選的底部的選單)推送到我們上邊完成的POST方法中。
我們如何處理這些訊息,這些事件,就是我們的私人訂製。
附上service程式碼: |
public String DoEvent(HttpServletRequestrequest) { String respContent = "success"; try { // 呼叫parseXml方法解析請求訊息 Map<String, String> requestMap = MessageUtil.parseXml(request); // 傳送方帳號 String fromUserName = requestMap.get("FromUserName").toString(); logger.debug("FromUserName==================================>" +fromUserName); // 開發者微訊號 String toUserName = requestMap.get("ToUserName").toString(); logger.debug("ToUserName====================================>" +toUserName); // 訊息型別 String msgType = requestMap.get("MsgType").toString(); logger.debug("MsgType=======================================>" +msgType); String eventKey = requestMap.get("EventKey") ==null ? null :requestMap.get("EventKey").toString(); logger.debug("EventKey===========================>" +eventKey); String ticket = requestMap.get("Ticket") ==null ? null :requestMap.get("Ticket").toString(); logger.debug("Ticket===========================> " +ticket); // 回覆文字訊息 TextMessage textMessage = new TextMessage(); textMessage.setToUserName(fromUserName); textMessage.setFromUserName(toUserName); textMessage.setCreateTime(new Date().getTime()); textMessage.setMsgType(MessageConstant.RESP_MESSAGE_TYPE_TEXT); // 文字訊息 if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_TEXT)) { } // 圖片訊息 else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_IMAGE)) { } // 語音訊息 else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_VOICE)) { } // 視訊訊息 else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_VIDEO)) { } // 地理位置訊息 else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_LOCATION)) { } // 連結訊息 else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_LINK)) { } // 事件推送 else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_EVENT)) { // 事件型別 String eventType = requestMap.get("Event").toString(); logger.debug("Event================================>" +eventType); // 關注 if (eventType.equals(MessageConstant.EVENT_TYPE_SUBSCRIBE)) { booleanbool = false; logger.debug(eventType +"==" + MessageConstant.EVENT_TYPE_SUBSCRIBE +":" + eventType.equals(MessageConstant.EVENT_TYPE_SUBSCRIBE)); if (true ==bool) { String content = "關注歡迎詞"; Integer time = (int) (new Date().getTime() / 1000); respContent ="<xml><ToUserName><![CDATA[" + fromUserName + "]]></ToUserName><FromUserName><![CDATA[" + toUserName + "]]></FromUserName><CreateTime>" + time + "</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[" + content + "]]></Content></xml>"; } } // 取消關注 else if (eventType.equals(MessageConstant.EVENT_TYPE_UNSUBSCRIBE)) { logger.debug(eventType +"==" + MessageConstant.EVENT_TYPE_UNSUBSCRIBE +":" + eventType.equals(MessageConstant.EVENT_TYPE_UNSUBSCRIBE)); // wxUserService.AddOrUpdateWxUser(requestMap); } // 掃描帶引數二維碼 else if (eventType.equals(MessageConstant.EVENT_TYPE_SCAN)) { } // 上報地理位置 else if (eventType.equals(MessageConstant.EVENT_TYPE_LOCATION)) { } // 自定義選單 CLICK else if (eventType.equals(MessageConstant.EVENT_TYPE_CLICK)) { logger.debug("EVENTKEY==================>" +requestMap.get("EventKey").toString()); if (requestMap.get("EventKey").toString().equals("V1001_GOOD")) { String content = "推送訊息內容"; Integer time = (int) (new Date().getTime() / 1000); respContent ="<xml><ToUserName><![CDATA[" + fromUserName + "]]></ToUserName><FromUserName><![CDATA[" + toUserName + "]]></FromUserName><CreateTime>" + time + "</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[" + content + "]]></Content></xml>"; } } } } catch (Exception e) { e.printStackTrace(); } logger.debug("respContent==>" +respContent); returnrespContent; } |
MessageConstant類 |
/** * 此類用來彙總公眾號訊息型別和事件型別 *@author zeqi * */ public class MessageConstant { public static final StringRESP_MESSAGE_TYPE_TEXT = null; public static final StringREQ_MESSAGE_TYPE_TEXT = "text"; public static final StringREQ_MESSAGE_TYPE_IMAGE = "image"; public static final StringREQ_MESSAGE_TYPE_VOICE = "voice"; public static final StringREQ_MESSAGE_TYPE_VIDEO = "video"; public static final StringREQ_MESSAGE_TYPE_SHORT_VIDEO = "shortvideo"; public static final StringREQ_MESSAGE_TYPE_LOCATION = "location"; public static final StringREQ_MESSAGE_TYPE_LINK = "link"; public static final StringREQ_MESSAGE_TYPE_EVENT = "event"; public static final StringEVENT_TYPE_SUBSCRIBE = "subscribe"; public static final StringEVENT_TYPE_UNSUBSCRIBE = "unsubscribe"; public static final StringEVENT_TYPE_SCAN = "SCAN"; public static final StringEVENT_TYPE_LOCATION = "LOCATION"; public static final StringEVENT_TYPE_CLICK = "CLICK"; public static final StringEVENT_TYPE_VIEW = "VIEW"; } |
當然如果不是特別個性的公眾號,許多私人訂製是不需要的,那麼那些不需要回復的訊息,響應的事件,我們統一回復“success”字串,如果我們不回覆任何內容,微信這邊會發送5次重試,如果我們的伺服器5秒之內給不出任何回覆,微信公眾號提示使用者的就:
下篇部落格,說一下我遇到的“該公眾號暫時無法提供服務,請稍後再試”的坑。