java微信公衆号開發之(zhī)各種事件推送
發表時(shí)間:2020-11-5
發布人(rén):融晨科技
浏覽次數:52
1.配置微信公衆服務器
2.提前下好公衆号SHA1算法生成安全簽名類
/**
* SHA1 class
*
* 計算公衆平台的(de)消息簽名接口.
*/
public class SHA1 {
/**
* 用SHA1算法生成安全簽名
* @param token 票據
* @param timestamp 時(shí)間戳
* @param nonce 随機字符串
* @param encrypt 密文
* @return 安全簽名
*/
public static String getSHA1(String token, String timestamp, String nonce, String encrypt)
{
try {
String[] array = new String[] { token, timestamp, nonce, encrypt };
StringBuffer sb = new StringBuffer();
// 字符串排序
Arrays.sort(array);
for (int i = 0; i < 4; i++) {
sb.append(array[i]);
}
String str = sb.toString();
// SHA1簽名生成
MessageDigest md = MessageDigest.getInstance("SHA-1");
md.update(str.getBytes());
byte[] digest = md.digest();
StringBuffer hexstr = new StringBuffer();
String shaHex = "";
for (int i = 0; i < digest.length; i++) {
shaHex = Integer.toHexString(digest[i] & 0xFF);
if (shaHex.length() < 2) {
hexstr.append(0);
}
hexstr.append(shaHex);
}
return hexstr.toString();
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}
3.創建一個(gè)接口,就(jiù)是(shì)配置公衆号服務的(de)接口
//微信公衆号驗證
@RequestMapping("openWx/gzhVerification")
public String gzhVerification(HttpServletRequest request){
log.info("微信公衆号驗證");
String signature=request.getParameter("signature");
String timestamp=request.getParameter("timestamp");
String nonce=request.getParameter("nonce");
String echostr=request.getParameter("echostr");
String token="token";//這(zhè)裏填基本配置中的(de)token
String jiami="";
try {
jiami= SHA1.getSHA1(token, timestamp, nonce,"");//這(zhè)裏是(shì)對三個(gè)參數進行加密
if(echostr!=null && jiami.equals(signature)){
log.info("第一次申請驗證成功");
return echostr;
}
//判斷是(shì)否是(shì)公衆号發來(lái)的(de)請求
if(jiami==null || !jiami.equals(signature)){
log.info("錯誤的(de)請求");
return null;
}
//----------------------事件推送
Map<String, String> stringStringMap = parseXml(request);
//---按鈕事件
if("CLICK".equalsIgnoreCase(stringStringMap.get("Event"))){
log.info("按鈕事件");
//因爲(wéi / wèi)隻有一個(gè)按鈕所以(yǐ)不(bù)用判斷key了(le/liǎo)
String fromUserName = toXML(stringStringMap.get("FromUserName"),stringStringMap.get("ToUserName"));
log.info("fromUserName:"+fromUserName);
//發送消息
return fromUserName;
//關注公衆号數據
}else if("subscribe".equalsIgnoreCase(stringStringMap.get("Event")) && stringStringMap.get("EventKey")==null && stringStringMap.get("Ticket")==null){
log.info("關注公衆号");
customerWxGzhService._add(stringStringMap.get("FromUserName"),null);
//取消關注
}else if("unsubscribe".equalsIgnoreCase(stringStringMap.get("Event"))) {
log.info("取消關注");
customerWxGzhService._delete(stringStringMap.get("FromUserName"));
//二維碼關注
}else if("subscribe".equalsIgnoreCase(stringStringMap.get("Event")) && stringStringMap.get("EventKey")!=null && stringStringMap.get("Ticket")!=null){
log.info("二維碼關注");
//獲取二維碼參數值
String eventKey =stringStringMap.get("EventKey");
eventKey= eventKey.substring(8);
customerWxGzhService._add(stringStringMap.get("FromUserName"),eventKey);
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
/**
* dom4j 解析 xml 轉換爲(wéi / wèi) map
* @param request
* @return
* @throws Exception
*/
public static Map<String, String> parseXml(HttpServletRequest request) throws Exception {
// 将解析結果存儲在(zài)HashMap中
Map<String, String> map = new HashMap<String, String>();
// 從request中取得輸入流
InputStream inputStream = request.getInputStream();
// 讀取輸入流
SAXReader reader = new SAXReader();
Document document = reader.read(inputStream);
// 得到(dào)xml根元素
Element root = document.getRootElement();
// 得到(dào)根元素的(de)所有子(zǐ)節點
List<Element> elementList = root.elements();
// 遍曆所有子(zǐ)節點
for (Element e : elementList)
map.put(e.getName(), e.getText());
// 釋放資源
inputStream.close();
inputStream = null;
return map;
}
//發送聯系我們
public String toXML(String toUserName,String fromUserName){
StringBuilder sb = new StringBuilder();
sb.append("<xml>");
sb.append("<ToUserName><![CDATA["+toUserName+"]]></ToUserName>");
sb.append("<FromUserName><![CDATA["+fromUserName+"]]></FromUserName>");
sb.append("<CreateTime>"+System.currentTimeMillis()/1000+"</CreateTime>");
sb.append("<MsgType><![CDATA[text]]></MsgType>");
sb.append("<Content><![CDATA[您好]]></Content>");
sb.append("</xml>");
return sb.toString();
}
公衆号事件的(de)提示隻有一個(gè)接口 就(jiù)是(shì)不(bù)斷判斷Event參數來(lái)處理事件,