微信企業(yè)號(hào)驗(yàn)證/發(fā)送/接收消息
更新時(shí)間：2016年10月21日 10:52:41 作者：hichinamobile
這篇文章主要介紹了微信企業(yè)號(hào)驗(yàn)證/發(fā)送/接收消息的相關(guān)資料,非常不錯(cuò)具有參考借鑒價(jià)值，需要的朋友可以參考下
1. 內(nèi)網(wǎng)映射
由于微信企業(yè)號(hào)回調(diào)模式的URL盡支持域名方式訪問(wèn)，估需要注冊(cè)花生殼，做一個(gè)內(nèi)網(wǎng)穿透（需要花16塊錢，購(gòu)買一個(gè)免費(fèi)版，購(gòu)買之后，第二天才能添加上域名）
2. 微信企業(yè)號(hào)
注冊(cè)微信企業(yè)號(hào)：https://qy.weixin.qq.com/ （選擇團(tuán)隊(duì)，團(tuán)隊(duì)不需要認(rèn)證）
通訊錄：新建組織 - > 關(guān)注成員
企業(yè)號(hào) -> 應(yīng)用中心 -> 新建應(yīng)用 -> 消息型應(yīng)用 -> 模式選擇(回調(diào)模式) -> 開(kāi)啟微信消息轉(zhuǎn)發(fā)，
回調(diào)模式說(shuō)明：http://qydev.weixin.qq.com/wiki/index.PHP?title=%E5%9B%9E%E8%B0%83%E6%A8%A1%E5%BC%8F
回調(diào)模式加密解密代碼：http://qydev.weixin.qq.com/wiki/index.php?title=%E5%8A%A0%E8%A7%A3%E5%AF%86%E5%BA%93%E4%B8%8B%E8%BD%BD%E4%B8%8E%E8%BF%94%E5%9B%9E%E7%A0%81
如圖1：
自定義菜單： 開(kāi)發(fā)應(yīng)用的請(qǐng)求路徑如圖2：
設(shè)置 -> 功能設(shè)置 -> 權(quán)限管理 -> 新建管理組 -> 應(yīng)用權(quán)限（ Secret ）
3. 利用Jersey開(kāi)發(fā)web Service服務(wù)
3.1 在類中定義token, 隨機(jī)密碼43位，公司corpId, secret
3.2 驗(yàn)證方法
/*
* ------------使用示例一：驗(yàn)證回調(diào)URL---------------企業(yè)開(kāi)啟回調(diào)模式時(shí)，企業(yè)號(hào)會(huì)向驗(yàn)證url發(fā)送一個(gè)get請(qǐng)求
* 假設(shè)點(diǎn)擊驗(yàn)證時(shí)，企業(yè)收到類似請(qǐng)求： GET
* /cgi-bin/wxpush?msg_signature=5c45ff5e21c57e6ad56bac8758b79b1d9ac89fd3
* ×tamp
* =1409659589&nonce=263014780&echostr=P9nAzCzyDtyTWESHep1vC5X9xho%
* 2FqYX3Zpb4yKa9SKld1DsH3Iyt3tP3zNdtp%2B4RPcs8TgAE7OaBO%2BFZXvnaqQ%3D%3D
* HTTP/1.1 Host: qy.weixin.qq.com
*
* 接收到該請(qǐng)求時(shí)，企業(yè)應(yīng)
* 1.解析出Get請(qǐng)求的參數(shù)，包括消息體簽名(msg_signature)，時(shí)間戳(timestamp)，隨機(jī)數(shù)字串(nonce
* )以及公眾平臺(tái)推送過(guò)來(lái)的隨機(jī)加密字符串(echostr), 這一步注意作URL解碼。 2.驗(yàn)證消息體簽名的正確性 3.
* 解密出echostr原文，將原文當(dāng)作Get請(qǐng)求的response，返回給公眾平臺(tái) 第2，3步可以用公眾平臺(tái)提供的庫(kù)函數(shù)VerifyURL來(lái)實(shí)現(xiàn)。
*/
/**
* 回調(diào)URL，微信調(diào)用此方法進(jìn)行驗(yàn)證
*
* @return
*/
@GET
@Path("station")
public String verify() {
String msgSignature = request.getParameter("msg_signature");
String timeStamp = request.getParameter("timestamp");
String nonce = request.getParameter("nonce");
System.out.println(timeStamp + " " + nonce);
String echostr = request.getParameter("echostr");
String sEchoStr = null;
try {
sEchoStr = wxcpt.VerifyURL(msgSignature, timeStamp, nonce, echostr);
} catch (Exception e) {
e.printStackTrace();// 驗(yàn)證URL失敗，錯(cuò)誤原因請(qǐng)查看異常
}
return sEchoStr;
}
3.3 接收用戶信息，并解密
/*
* ------------對(duì)用戶回復(fù)的消息解密---------------
* 用戶回復(fù)消息或者點(diǎn)擊事件響應(yīng)時(shí)，企業(yè)會(huì)收到回調(diào)消息，此消息是經(jīng)過(guò)公眾平臺(tái)加密之后的密文以post形式發(fā)送給企業(yè)，密文格式請(qǐng)參考官方文檔
* 假設(shè)企業(yè)收到公眾平臺(tái)的回調(diào)消息如下： POST /cgi-bin/wxpush?
* msg_signature=477715d11cdb4164915debcba66cb864d751f3e6
* ×tamp=1409659813&nonce=1372623149 HTTP/1.1 Host: qy.weixin.qq.com
* Content-Length: 613 <xml>
* <ToUserName><![CDATA[wx5823bf96d3bd56c7]]></ToUserName
* ><Encrypt><![CDATA[RypEvHKD8QQKFhvQ6QleEB4J58tiPdvo
* +rtK1I9qca6aM/wvqnLSV5zEPeusUiX5L5X/0lWfrf0QADHHhGd3QczcdCUpj911L3vg3W/
* sYYvuJTs3TUUkSUXxaccAS0qhxchrRYt66wiSpGLYL42aM6A8dTT
* +6k4aSknmPj48kzJs8qLjvd4Xgpue06DOdnLxAUHzM6
* +kDZ+HMZfJYuR+LtwGc2hgf5gsijff0ekUNXZiqATP7PF5mZxZ3Izoun1s4zG4LUMnvw2r
* +KqCKIw
* +3IQH03v+BCA9nMELNqbSf6tiWSrXJB3LAVGUcallcrw8V2t9EL4EhzJWrQUax5wLVMNS0
* +rUPA3k22Ncx4XXZS9o0MBH27Bo6BpNelZpS
* +/uh9KsNlY6bHCmJU9p8g7m3fVKn28H3KDYA5Pl
* /T8Z1ptDAVe0lXdQ2YoyyH2uyPIGHBZZIs2pDBS8R07+qN+E7Q==]]></Encrypt>
* <AgentID><![CDATA[218]]></AgentID> </xml>
*
* 企業(yè)收到post請(qǐng)求之后應(yīng)該
* 1.解析出url上的參數(shù)，包括消息體簽名(msg_signature)，時(shí)間戳(timestamp)以及隨機(jī)數(shù)字串(nonce)
* 2.驗(yàn)證消息體簽名的正確性。
* 3.將post請(qǐng)求的數(shù)據(jù)進(jìn)行xml解析，并將<Encrypt>標(biāo)簽的內(nèi)容進(jìn)行解密，解密出來(lái)的明文即是用戶回復(fù)消息的明文，明文格式請(qǐng)參考官方文檔
* 第2，3步可以用公眾平臺(tái)提供的庫(kù)函數(shù)DecryptMsg來(lái)實(shí)現(xiàn)。
*/
@POST
@Path("station")
public String receiveMsg(String reqData) {
String msgSignature = request.getParameter("msg_signature");
String timeStamp = request.getParameter("timestamp");
String nonce = request.getParameter("nonce");
// post請(qǐng)求的密文數(shù)據(jù)
// String sReqData =
// "<xml><ToUserName><![CDATA[wx5823bf96d3bd56c7]]></ToUserName><Encrypt><![CDATA[RypEvHKD8QQKFhvQ6QleEB4J58tiPdvo+rtK1I9qca6aM/wvqnLSV5zEPeusUiX5L5X/0lWfrf0QADHHhGd3QczcdCUpj911L3vg3W/sYYvuJTs3TUUkSUXxaccAS0qhxchrRYt66wiSpGLYL42aM6A8dTT+6k4aSknmPj48kzJs8qLjvd4Xgpue06DOdnLxAUHzM6+kDZ+HMZfJYuR+LtwGc2hgf5gsijff0ekUNXZiqATP7PF5mZxZ3Izoun1s4zG4LUMnvw2r+KqCKIw+3IQH03v+BCA9nMELNqbSf6tiWSrXJB3LAVGUcallcrw8V2t9EL4EhzJWrQUax5wLVMNS0+rUPA3k22Ncx4XXZS9o0MBH27Bo6BpNelZpS+/uh9KsNlY6bHCmJU9p8g7m3fVKn28H3KDYA5Pl/T8Z1ptDAVe0lXdQ2YoyyH2uyPIGHBZZIs2pDBS8R07+qN+E7Q==]]></Encrypt><AgentID><![CDATA[218]]></AgentID></xml>";
try {
String sMsg = wxcpt.DecryptMsg(msgSignature, timeStamp, nonce,
reqData);
// 解析出明文xml標(biāo)簽的內(nèi)容進(jìn)行處理
DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
DocumentBuilder db = dbf.newDocumentBuilder();
StringReader sr = new StringReader(sMsg);
InputSource is = new InputSource(sr);
Document document = db.parse(is);
Element root = document.getDocumentElement();
NodeList nodelist1 = root.getElementsByTagName("Content");
if (nodelist1.item(0) == null)
return "ok";
String Content = nodelist1.item(0).getTextContent();
System.out.println("Content：" + Content);
} catch (Exception e) {
e.printStackTrace();// 解密失敗，失敗原因請(qǐng)查看異常
}
return "ok";
}
3.4 發(fā)送信息到微信
設(shè)置 -> 功能設(shè)置 -> 權(quán)限管理 -> 新建管理組； 獲取secret
/**
* 此方法可以發(fā)送任意類型消息
*
* @param msgType
* text|image|voice|video|file|news
* @param touser
* 成員ID列表（消息接收者，多個(gè)接收者用‘|'分隔，最多支持1000個(gè)）。特殊情況：指定為@all，
* 則向關(guān)注該企業(yè)應(yīng)用的全部成員發(fā)送
* @param toparty
* 部門ID列表，多個(gè)接收者用‘|'分隔，最多支持100個(gè)。當(dāng)touser為@all時(shí)忽略本參數(shù)
* @param totag
* 標(biāo)簽ID列表，多個(gè)接收者用‘|'分隔。當(dāng)touser為@all時(shí)忽略本參數(shù)
* @param content
* msgType=text時(shí) ,文本消息內(nèi)容
* @param mediaId
* msgType=image|voice|video時(shí) ,對(duì)應(yīng)消息信息ID（--------）
* @param title
* msgType=news|video時(shí)，消息標(biāo)題
* @param description
* msgType=news|video時(shí)，消息描述
* @param url
* msgType=news時(shí)，消息鏈接
* @param picurl
* msgType=news時(shí)，圖片路徑
* @param safe
* 表示是否是保密消息，0表示否，1表示是，默認(rèn)0
*/
public void sendWeChatMsg(String msgType, String touser, String toparty,
String totag, String content, String mediaId, String title,
String description, String url, String picurl, String safe) {
URL uRl;
String ACCESS_TOKEN = getAccessToken();
// 拼接請(qǐng)求串
String action = CREATE_SESSION_URL + ACCESS_TOKEN;
// 封裝發(fā)送消息請(qǐng)求json
StringBuffer sb = new StringBuffer();
sb.append("{");
sb.append("\"touser\":" + "\"" + touser + "\",");
sb.append("\"toparty\":" + "\"" + toparty + "\",");
sb.append("\"totag\":" + "\"" + totag + "\",");
if (msgType.equals("text")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"text\":" + "{");
sb.append("\"content\":" + "\"" + content + "\"");
sb.append("}");
} else if (msgType.equals("image")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"image\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\"");
sb.append("}");
} else if (msgType.equals("voice")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"voice\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\"");
sb.append("}");
} else if (msgType.equals("video")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"video\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\",");
sb.append("\"title\":" + "\"" + title + "\",");
sb.append("\"description\":" + "\"" + description + "\"");
sb.append("}");
} else if (msgType.equals("file")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"file\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\"");
sb.append("}");
} else if (msgType.equals("news")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"news\":" + "{");
sb.append("\"articles\":" + "[");
sb.append("{");
sb.append("\"title\":" + "\"" + title + "\",");
sb.append("\"description\":" + "\"" + description + "\",");
sb.append("\"url\":" + "\"" + url + "\",");
sb.append("\"picurl\":" + "\"" + picurl + "\"");
sb.append("}");
sb.append("]");
sb.append("}");
}
sb.append(",\"safe\":" + "\"" + safe + "\",");
sb.append("\"agentid\":" + "\"" + 1 + "\",");
sb.append("\"debug\":" + "\"" + "1" + "\"");
sb.append("}");
String json = sb.toString();
try {
uRl = new URL(action);
HttpsURLConnection http = (HttpsURLConnection) uRl.openConnection();
http.setRequestMethod("POST");
http.setRequestProperty("Content-Type",
"application/json;charset=UTF-8");
http.setDoOutput(true);
http.setDoInput(true);
System.setProperty("sun.net.client.defaultConnectTimeout", "30000");//
// 連接超時(shí)30秒
System.setProperty("sun.net.client.defaultReadTimeout", "30000"); //
// 讀取超時(shí)30秒
http.connect();
OutputStream os = http.getOutputStream();
os.write(json.getBytes("UTF-8"));// 傳入?yún)?shù)
InputStream is = http.getInputStream();
int size = is.available();
byte[] jsonBytes = new byte[size];
is.read(jsonBytes);
String result = new String(jsonBytes, "UTF-8");
System.out.println("請(qǐng)求返回結(jié)果:" + result);
os.flush();
os.close();
} catch (Exception e) {
e.printStackTrace();
}
}
// 獲取接口訪問(wèn)權(quán)限碼
public String getAccessToken() {
HttpClient client = new HttpClient();
PostMethod post = new PostMethod(ACCESS_TOKEN_URL);
post.releaseConnection();
post.setRequestHeader("Content-Type",
"application/x-www-form-urlencoded;charset=UTF-8");
NameValuePair[] param = { new NameValuePair("corpid", corpId),
new NameValuePair("corpsecret", secret) };
// 設(shè)置策略，防止報(bào)cookie錯(cuò)誤
DefaultHttpParams.getDefaultParams().setParameter(
"http.protocol.cookie-policy",
CookiePolicy.BROWSER_COMPATIBILITY);
// 給post設(shè)置參數(shù)
post.setRequestBody(param);
String result = "";
try {
client.executeMethod(post);
result = new String(post.getResponseBodyAsString().getBytes("gbk"));
} catch (IOException e) {
e.printStackTrace();
}
// 將數(shù)據(jù)轉(zhuǎn)換成json
JSONObject jasonObject;
jasonObject = JSONObject.fromObject(result);
result = (String) jasonObject.get("access_token");
post.releaseConnection();
System.out.println(result);
return result;
}
public static void main(String[] args) {
StationResource weChat = new StationResource();
// weChat.sendWeChatMsgText("@all", "2", "", "信息中心通知", "0");
weChat.sendWeChatMsg("news", "@all", "", "", "測(cè)試senMsg", "", "測(cè)試的",
"真的是測(cè)試的", "http://www.baidu.com",
"http://file27.mafengwo.net/M00/B2/12/wKgB6lO0ahWAMhL8AAV1yBFJDJw20.jpeg", "0");
}
4. 開(kāi)發(fā)完成。 需要將該類在webx.xml中添加到rest中管理
<!-- RESTful支持 --> <!-- webserivce服務(wù)，如增加了服務(wù)，需要在param-value中增加服務(wù)的包路徑 --> <servlet> <servlet-name>JAX-RS REST Servlet</servlet-name> <servlet-class>com.sun.jersey.spi.container.servlet.ServletContainer</servlet-class> <init-param> <param-name>com.sun.jersey.config.property.packages</param-name> <param-value>com.base.pf.restful</param-value> </init-param> <load-on-startup>2</load-on-startup> </servlet> <servlet-mapping> <servlet-name>JAX-RS REST Servlet</servlet-name> <url-pattern>/rest/*</url-pattern> </servlet-mapping>
5. 開(kāi)發(fā)完成的全量代碼
package com.base.pf.restful;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.StringReader;
import java.net.URL;
import javax.net.ssl.HttpsURLConnection;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.core.Context;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import net.sf.json.JSONObject;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.cookie.CookiePolicy;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.params.DefaultHttpParams;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;
import com.qq.weixin.mp.aes.AesException;
import com.qq.weixin.mp.aes.WXBizMsgCrypt;
/**
* 微信企業(yè)號(hào)開(kāi)發(fā)
*
* @author ZHEN.L
*
*/
@Path("wx")
public class StationResource {
// http://hichinamobile.xicp.net/security/rest/wx
// https://qy.weixin.qq.com
private String token = "spm"; // 企業(yè)號(hào) -> 應(yīng)用中心 -> 新建應(yīng)用 -> 消息型應(yīng)用
private String agentId = "1"; // 企業(yè)號(hào) -> 應(yīng)用中心 -> 點(diǎn)開(kāi)應(yīng)用中 -> 應(yīng)用ID
private String encodingAesKey = "nT6ZWTVFlyNXOhFOGGOZWdJpAgeFSV8ln5CNeYw7mwl"; // 企業(yè)號(hào) -> 應(yīng)用中心 -> 新建應(yīng)用 -> 消息型應(yīng)用
private String corpId = "wxe49318eb604cf00b"; // 企業(yè)號(hào) -> 設(shè)置 -> 企業(yè)號(hào)信息 -> 賬號(hào)信息
private String secret = "M-YFKmgl_kXBVEtginZH3RQWbz4xb6MFeQXXLk77mkpxZenFDYq-UgerxdUF8rel"; // 企業(yè)號(hào) -> 設(shè)置 -> 功能設(shè)置 -> 權(quán)限管理中
@Context
HttpServletRequest request;
@Context
HttpServletResponse response;
WXBizMsgCrypt wxcpt = null;
public StationResource() {
try {
wxcpt = new WXBizMsgCrypt(token, encodingAesKey, corpId);
} catch (AesException e) {
e.printStackTrace();
}
}
// 獲取訪問(wèn)權(quán)限碼URL
private final static String ACCESS_TOKEN_URL = "https://qyapi.weixin.qq.com/cgi-bin/gettoken";
// 創(chuàng)建會(huì)話請(qǐng)求URL
private final static String CREATE_SESSION_URL = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=";
// 獲取接口訪問(wèn)權(quán)限碼
public String getAccessToken() {
HttpClient client = new HttpClient();
PostMethod post = new PostMethod(ACCESS_TOKEN_URL);
post.releaseConnection();
post.setRequestHeader("Content-Type",
"application/x-www-form-urlencoded;charset=UTF-8");
NameValuePair[] param = { new NameValuePair("corpid", corpId),
new NameValuePair("corpsecret", secret) };
// 設(shè)置策略，防止報(bào)cookie錯(cuò)誤
DefaultHttpParams.getDefaultParams().setParameter(
"http.protocol.cookie-policy",
CookiePolicy.BROWSER_COMPATIBILITY);
// 給post設(shè)置參數(shù)
post.setRequestBody(param);
String result = "";
try {
client.executeMethod(post);
result = new String(post.getResponseBodyAsString().getBytes("gbk"));
} catch (IOException e) {
e.printStackTrace();
}
// 將數(shù)據(jù)轉(zhuǎn)換成json
JSONObject jasonObject;
jasonObject = JSONObject.fromObject(result);
result = (String) jasonObject.get("access_token");
post.releaseConnection();
System.out.println(result);
return result;
}
/*
* ------------使用示例一：驗(yàn)證回調(diào)URL---------------企業(yè)開(kāi)啟回調(diào)模式時(shí)，企業(yè)號(hào)會(huì)向驗(yàn)證url發(fā)送一個(gè)get請(qǐng)求
* 假設(shè)點(diǎn)擊驗(yàn)證時(shí)，企業(yè)收到類似請(qǐng)求： GET
* /cgi-bin/wxpush?msg_signature=5c45ff5e21c57e6ad56bac8758b79b1d9ac89fd3
* ×tamp
* =1409659589&nonce=263014780&echostr=P9nAzCzyDtyTWESHep1vC5X9xho%
* 2FqYX3Zpb4yKa9SKld1DsH3Iyt3tP3zNdtp%2B4RPcs8TgAE7OaBO%2BFZXvnaqQ%3D%3D
* HTTP/1.1 Host: qy.weixin.qq.com
*
* 接收到該請(qǐng)求時(shí)，企業(yè)應(yīng)
* 1.解析出Get請(qǐng)求的參數(shù)，包括消息體簽名(msg_signature)，時(shí)間戳(timestamp)，隨機(jī)數(shù)字串(nonce
* )以及公眾平臺(tái)推送過(guò)來(lái)的隨機(jī)加密字符串(echostr), 這一步注意作URL解碼。 2.驗(yàn)證消息體簽名的正確性 3.
* 解密出echostr原文，將原文當(dāng)作Get請(qǐng)求的response，返回給公眾平臺(tái) 第2，3步可以用公眾平臺(tái)提供的庫(kù)函數(shù)VerifyURL來(lái)實(shí)現(xiàn)。
*/
/**
* 回調(diào)URL，微信調(diào)用此方法進(jìn)行驗(yàn)證
*
* @return
*/
@GET
@Path("station")
public String verify() {
String msgSignature = request.getParameter("msg_signature");
String timeStamp = request.getParameter("timestamp");
String nonce = request.getParameter("nonce");
System.out.println(timeStamp + " " + nonce);
String echostr = request.getParameter("echostr");
String sEchoStr = null;
try {
sEchoStr = wxcpt.VerifyURL(msgSignature, timeStamp, nonce, echostr);
} catch (Exception e) {
e.printStackTrace();// 驗(yàn)證URL失敗，錯(cuò)誤原因請(qǐng)查看異常
}
return sEchoStr;
}
/*
* ------------對(duì)用戶回復(fù)的消息解密---------------
* 用戶回復(fù)消息或者點(diǎn)擊事件響應(yīng)時(shí)，企業(yè)會(huì)收到回調(diào)消息，此消息是經(jīng)過(guò)公眾平臺(tái)加密之后的密文以post形式發(fā)送給企業(yè)，密文格式請(qǐng)參考官方文檔
* 假設(shè)企業(yè)收到公眾平臺(tái)的回調(diào)消息如下： POST /cgi-bin/wxpush?
* msg_signature=477715d11cdb4164915debcba66cb864d751f3e6
* ×tamp=1409659813&nonce=1372623149 HTTP/1.1 Host: qy.weixin.qq.com
* Content-Length: 613 <xml>
* <ToUserName><![CDATA[wx5823bf96d3bd56c7]]></ToUserName
* ><Encrypt><![CDATA[RypEvHKD8QQKFhvQ6QleEB4J58tiPdvo
* +rtK1I9qca6aM/wvqnLSV5zEPeusUiX5L5X/0lWfrf0QADHHhGd3QczcdCUpj911L3vg3W/
* sYYvuJTs3TUUkSUXxaccAS0qhxchrRYt66wiSpGLYL42aM6A8dTT
* +6k4aSknmPj48kzJs8qLjvd4Xgpue06DOdnLxAUHzM6
* +kDZ+HMZfJYuR+LtwGc2hgf5gsijff0ekUNXZiqATP7PF5mZxZ3Izoun1s4zG4LUMnvw2r
* +KqCKIw
* +3IQH03v+BCA9nMELNqbSf6tiWSrXJB3LAVGUcallcrw8V2t9EL4EhzJWrQUax5wLVMNS0
* +rUPA3k22Ncx4XXZS9o0MBH27Bo6BpNelZpS
* +/uh9KsNlY6bHCmJU9p8g7m3fVKn28H3KDYA5Pl
* /T8Z1ptDAVe0lXdQ2YoyyH2uyPIGHBZZIs2pDBS8R07+qN+E7Q==]]></Encrypt>
* <AgentID><![CDATA[218]]></AgentID> </xml>
*
* 企業(yè)收到post請(qǐng)求之后應(yīng)該
* 1.解析出url上的參數(shù)，包括消息體簽名(msg_signature)，時(shí)間戳(timestamp)以及隨機(jī)數(shù)字串(nonce)
* 2.驗(yàn)證消息體簽名的正確性。
* 3.將post請(qǐng)求的數(shù)據(jù)進(jìn)行xml解析，并將<Encrypt>標(biāo)簽的內(nèi)容進(jìn)行解密，解密出來(lái)的明文即是用戶回復(fù)消息的明文，明文格式請(qǐng)參考官方文檔
* 第2，3步可以用公眾平臺(tái)提供的庫(kù)函數(shù)DecryptMsg來(lái)實(shí)現(xiàn)。
*/
@POST
@Path("station")
public String receiveMsg(String reqData) {
String msgSignature = request.getParameter("msg_signature");
String timeStamp = request.getParameter("timestamp");
String nonce = request.getParameter("nonce");
// post請(qǐng)求的密文數(shù)據(jù)
// String sReqData =
// "<xml><ToUserName><![CDATA[wx5823bf96d3bd56c7]]></ToUserName><Encrypt><![CDATA[RypEvHKD8QQKFhvQ6QleEB4J58tiPdvo+rtK1I9qca6aM/wvqnLSV5zEPeusUiX5L5X/0lWfrf0QADHHhGd3QczcdCUpj911L3vg3W/sYYvuJTs3TUUkSUXxaccAS0qhxchrRYt66wiSpGLYL42aM6A8dTT+6k4aSknmPj48kzJs8qLjvd4Xgpue06DOdnLxAUHzM6+kDZ+HMZfJYuR+LtwGc2hgf5gsijff0ekUNXZiqATP7PF5mZxZ3Izoun1s4zG4LUMnvw2r+KqCKIw+3IQH03v+BCA9nMELNqbSf6tiWSrXJB3LAVGUcallcrw8V2t9EL4EhzJWrQUax5wLVMNS0+rUPA3k22Ncx4XXZS9o0MBH27Bo6BpNelZpS+/uh9KsNlY6bHCmJU9p8g7m3fVKn28H3KDYA5Pl/T8Z1ptDAVe0lXdQ2YoyyH2uyPIGHBZZIs2pDBS8R07+qN+E7Q==]]></Encrypt><AgentID><![CDATA[218]]></AgentID></xml>";
try {
String sMsg = wxcpt.DecryptMsg(msgSignature, timeStamp, nonce,
reqData);
// 解析出明文xml標(biāo)簽的內(nèi)容進(jìn)行處理
DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
DocumentBuilder db = dbf.newDocumentBuilder();
StringReader sr = new StringReader(sMsg);
InputSource is = new InputSource(sr);
Document document = db.parse(is);
Element root = document.getDocumentElement();
NodeList nodelist1 = root.getElementsByTagName("Content");
if (nodelist1.item(0) == null)
return "ok";
String Content = nodelist1.item(0).getTextContent();
System.out.println("Content：" + Content);
} catch (Exception e) {
e.printStackTrace();// 解密失敗，失敗原因請(qǐng)查看異常
}
return "ok";
}
/*
* ------------使用示例三：企業(yè)回復(fù)用戶消息的加密---------------
* 企業(yè)被動(dòng)回復(fù)用戶的消息也需要進(jìn)行加密，并且拼接成密文格式的xml串。 假設(shè)企業(yè)需要回復(fù)用戶的明文如下： <xml>
* <ToUserName><![CDATA[mycreate]]></ToUserName>
* <FromUserName><![CDATA[wx5823bf96d3bd56c7]]></FromUserName>
* <CreateTime>1348831860</CreateTime> <MsgType><![CDATA[text]]></MsgType>
* <Content><![CDATA[this is a test]]></Content>
* <MsgId>1234567890123456</MsgId> <AgentID>128</AgentID> </xml>
*
* 為了將此段明文回復(fù)給用戶，企業(yè)應(yīng)：
* 1.自己生成時(shí)間時(shí)間戳(timestamp),隨機(jī)數(shù)字串(nonce)以便生成消息體簽名，也可以直接用從公眾平臺(tái)的post
* url上解析出的對(duì)應(yīng)值。 2.將明文加密得到密文。
* 3.用密文，步驟1生成的timestamp,nonce和企業(yè)在公眾平臺(tái)設(shè)定的token生成消息體簽名。
* 4.將密文，消息體簽名，時(shí)間戳，隨機(jī)數(shù)字串拼接成xml格式的字符串，發(fā)送給企業(yè)。
* 以上2，3，4步可以用公眾平臺(tái)提供的庫(kù)函數(shù)EncryptMsg來(lái)實(shí)現(xiàn)。
*/
// @GET
// @Path("send")
public void sendMsg(String timeStamp, String nonce) {
String sRespData = "<xml><ToUserName><![CDATA[mycreate]]></ToUserName><FromUserName><![CDATA[wxe49318eb604cf00b]]></FromUserName><CreateTime>1348831860</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[this is a test]]></Content><MsgId>1234567890123456</MsgId><AgentID>1</AgentID></xml>";
try {
String sEncryptMsg = wxcpt.EncryptMsg(sRespData, timeStamp, nonce);
System.out.println("after encrypt sEncrytMsg: " + sEncryptMsg);
response.getWriter().print(sEncryptMsg);
} catch (Exception e) {
e.printStackTrace();// 加密失敗
}
// return sRespData;
}
/**
* 此方法可以發(fā)送任意類型消息
*
* @param msgType
* text|image|voice|video|file|news
* @param touser
* 成員ID列表（消息接收者，多個(gè)接收者用‘|'分隔，最多支持1000個(gè)）。特殊情況：指定為@all，
* 則向關(guān)注該企業(yè)應(yīng)用的全部成員發(fā)送
* @param toparty
* 部門ID列表，多個(gè)接收者用‘|'分隔，最多支持100個(gè)。當(dāng)touser為@all時(shí)忽略本參數(shù)
* @param totag
* 標(biāo)簽ID列表，多個(gè)接收者用‘|'分隔。當(dāng)touser為@all時(shí)忽略本參數(shù)
* @param content
* msgType=text時(shí) ,文本消息內(nèi)容
* @param mediaId
* msgType=image|voice|video時(shí) ,對(duì)應(yīng)消息信息ID（--------）
* @param title
* msgType=news|video時(shí)，消息標(biāo)題
* @param description
* msgType=news|video時(shí)，消息描述
* @param url
* msgType=news時(shí)，消息鏈接
* @param picurl
* msgType=news時(shí)，圖片路徑
* @param safe
* 表示是否是保密消息，0表示否，1表示是，默認(rèn)0
*/
public void sendWeChatMsg(String msgType, String touser, String toparty,
String totag, String content, String mediaId, String title,
String description, String url, String picurl, String safe) {
URL uRl;
String ACCESS_TOKEN = getAccessToken();
// 拼接請(qǐng)求串
String action = CREATE_SESSION_URL + ACCESS_TOKEN;
// 封裝發(fā)送消息請(qǐng)求json
StringBuffer sb = new StringBuffer();
sb.append("{");
sb.append("\"touser\":" + "\"" + touser + "\",");
sb.append("\"toparty\":" + "\"" + toparty + "\",");
sb.append("\"totag\":" + "\"" + totag + "\",");
if (msgType.equals("text")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"text\":" + "{");
sb.append("\"content\":" + "\"" + content + "\"");
sb.append("}");
} else if (msgType.equals("image")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"image\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\"");
sb.append("}");
} else if (msgType.equals("voice")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"voice\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\"");
sb.append("}");
} else if (msgType.equals("video")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"video\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\",");
sb.append("\"title\":" + "\"" + title + "\",");
sb.append("\"description\":" + "\"" + description + "\"");
sb.append("}");
} else if (msgType.equals("file")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"file\":" + "{");
sb.append("\"media_id\":" + "\"" + mediaId + "\"");
sb.append("}");
} else if (msgType.equals("news")) {
sb.append("\"msgtype\":" + "\"" + msgType + "\",");
sb.append("\"news\":" + "{");
sb.append("\"articles\":" + "[");
sb.append("{");
sb.append("\"title\":" + "\"" + title + "\",");
sb.append("\"description\":" + "\"" + description + "\",");
sb.append("\"url\":" + "\"" + url + "\",");
sb.append("\"picurl\":" + "\"" + picurl + "\"");
sb.append("}");
sb.append("]");
sb.append("}");
}
sb.append(",\"safe\":" + "\"" + safe + "\",");
sb.append("\"agentid\":" + "\"" + agentId + "\",");
sb.append("\"debug\":" + "\"" + "1" + "\"");
sb.append("}");
String json = sb.toString();
try {
uRl = new URL(action);
HttpsURLConnection http = (HttpsURLConnection) uRl.openConnection();
http.setRequestMethod("POST");
http.setRequestProperty("Content-Type",
"application/json;charset=UTF-8");
http.setDoOutput(true);
http.setDoInput(true);
System.setProperty("sun.net.client.defaultConnectTimeout", "30000");//
// 連接超時(shí)30秒
System.setProperty("sun.net.client.defaultReadTimeout", "30000"); //
// 讀取超時(shí)30秒
http.connect();
OutputStream os = http.getOutputStream();
os.write(json.getBytes("UTF-8"));// 傳入?yún)?shù)
InputStream is = http.getInputStream();
int size = is.available();
byte[] jsonBytes = new byte[size];
is.read(jsonBytes);
String result = new String(jsonBytes, "UTF-8");
System.out.println("請(qǐng)求返回結(jié)果:" + result);
os.flush();
os.close();
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
StationResource weChat = new StationResource();
// weChat.sendWeChatMsgText("@all", "2", "", "信息中心通知", "0");
weChat.sendWeChatMsg("news", "@all", "", "", "測(cè)試senMsg", "", "測(cè)試的",
"真的是測(cè)試的", "http://www.baidu.com",
"http://file27.mafengwo.net/M00/B2/12/wKgB6lO0ahWAMhL8AAV1yBFJDJw20.jpeg", "0");
}
}
以上所述是小編給大家介紹的微信企業(yè)號(hào)驗(yàn)證/發(fā)送/接收消息，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！
您可能感興趣的文章:
- 圖文介紹報(bào)表與企業(yè)微信公眾號(hào)集成方案
- 微信開(kāi)發(fā)--企業(yè)轉(zhuǎn)賬到用戶
- 微信企業(yè)號(hào) 根據(jù)錯(cuò)誤碼返回錯(cuò)誤信息類封裝
- java微信企業(yè)號(hào)開(kāi)發(fā)之通訊錄
- java微信企業(yè)號(hào)開(kāi)發(fā)之發(fā)送消息（文本、圖片、語(yǔ)音）
- java微信企業(yè)號(hào)開(kāi)發(fā)之開(kāi)發(fā)模式的開(kāi)啟
- 微信企業(yè)號(hào)開(kāi)發(fā)之微信考勤Cookies的使用
- 微信企業(yè)號(hào)開(kāi)發(fā)之微信考勤百度地圖定位
- 微信公眾號(hào)支付之坑：調(diào)用支付jsapi缺少參數(shù) timeStamp等錯(cuò)誤解決方法
- php版微信開(kāi)發(fā)Token驗(yàn)證失敗或請(qǐng)求URL超時(shí)問(wèn)題的解決方法
- [企業(yè)公眾號(hào)]升級(jí)到[企業(yè)微信]之后發(fā)送消息失敗的解決方法
相關(guān)文章
Spring實(shí)戰(zhàn)之使用@POSTConstruct和@PreDestroy定制生命周期行為操作示例
這篇文章主要介紹了Spring實(shí)戰(zhàn)之使用@POSTConstruct和@PreDestroy定制生命周期行為操作,結(jié)合實(shí)例形式詳細(xì)分析了Spring使用@POSTConstruct和@PreDestroy定制生命周期相關(guān)接口定義、配置與功能實(shí)現(xiàn)技巧,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了java 對(duì)象鎖與類鎖的相關(guān)資料，幫助大家更好的理解和學(xué)習(xí)Java，感興趣的朋友可以了解下2020-09-09
Java實(shí)現(xiàn)redis分布式鎖的三種方式
本文主要介紹了Java實(shí)現(xiàn)redis分布式鎖的三種方式，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08
eclipse啟動(dòng)一個(gè)Springboot項(xiàng)目
本文主要介紹了eclipse啟動(dòng)一個(gè)Springboot項(xiàng)目，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08
SpringBoot?RESTful?應(yīng)用中的異常處理梳理小結(jié)
這篇文章主要介紹了SpringBoot?RESTful?應(yīng)用中的異常處理梳理小結(jié)，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-05-05
Spring框架web項(xiàng)目實(shí)戰(zhàn)全代碼分享
這篇文章主要介紹了Spring框架web項(xiàng)目實(shí)戰(zhàn)全代碼分享，具有一定參考價(jià)值，需要的朋友可以了解下。2017-11-11
10張圖總結(jié)出并發(fā)編程最佳學(xué)習(xí)路線
這篇文章主要介紹了并發(fā)編程的最佳學(xué)習(xí)路線，文中通過(guò)圖片介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-08-08
這篇文章主要介紹了Java編程GUI中的事件綁定代碼示例，簡(jiǎn)單介紹了綁定的概念，然后分享了相關(guān)代碼，具有一定參考價(jià)值，需要的朋友可以參考下。2017-10-10
這篇文章主要介紹了JAVA利用遞歸刪除文件代碼實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-10-10
Java正則表達(dá)式matcher.group()用法代碼
這篇文章主要給大家介紹了關(guān)于Java正則表達(dá)式matcher.group()用法的相關(guān)資料,最近在做一個(gè)項(xiàng)目,需要使用matcher.group()方法匹配出需要的內(nèi)容,文中給出了詳細(xì)的代碼示例,需要的朋友可以參考下2023-08-08