1. 程式人生 > >微信公眾號-訊息推送-實現固定模式下的私人訂製

微信公眾號-訊息推送-實現固定模式下的私人訂製

開發微信已經將近4個月了,但是還是不會本地除錯,只能部署到伺服器上,通過打日誌,來看是否有錯,@ALL哪位同志,如果有好的方法,可以告訴我。

先簡要介紹一下微信公眾號,訊息推送的原理。

微信公眾號只是一個平臺,這個平臺的功能是一樣的,但是這個功能的內容卻可以由這個公眾號的主人決定。這些內容實現了微信公眾號的私人訂製。

就像關注一個公眾號之後,會有一個歡迎詞,都是歡迎詞的功能。有的公眾號推送了滿滿一屏的文字,有的公眾號只是寥寥數字。

利用內容的不同,微信公眾號得以推廣。

這個功能一個測試公眾號就可以完成,對微信開發有興趣的同學可以嘗試一下。

本姑娘從事的是java開發,所以文中所有的程式碼均為java

  1. 第一步,我們要寫程式碼部署到一個解析了域名的伺服器上,讓外界可以訪問到。

為了實現訊息推送功能,我們需要@RequestMapping value值一樣的2個方法,但是RequestMethod一個為GET,一個為POST.

GET方法,用於微信公眾號後臺配置url+token,POST方法用於接收微信公眾號推送的訊息。

無論GET方法,還是POST方法,都需要驗證簽名的正確性。

程式碼附上:

/**

* 驗證url+token token+timestamp+nonce asc排序SHA1加密與signature對比,相同

*@param request

*@return

ture驗證通過,false驗證未通過

*/

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=============================:"

+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,配置成功,我們只做到了訊息推送的第一步。

  1. 接下來我們來看一下,我們第一步中強調的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秒之內給不出任何回覆,微信公眾號提示使用者的就:

       下篇部落格,說一下我遇到的“該公眾號暫時無法提供服務,請稍後再試”的坑。