转自：https://www.cnblogs.com/fengzheng/p/5027630.html
在将access_token之前，还有两个重要参数需要知晓，这两个参数分别是appID和appsecret，这是在申请公众号的时候自动分配给公众号的，相当于公众号的身份标示，在很多接口中需要这两个参数，接下来在请求access_token的时候就需要这两个参数。
公众号接入成功之后，接下来就要实现相应的逻辑了。在使用微信公众号接口中，发现有许多请求都需要access_token。access_token是公众号的全局唯一凭证，公众号调用各接口时都需使用access_token。开发者需要进行妥善保存。access_token的存储至少要保留512个字符空间。access_token的有效期目前为2个小时，需定时刷新，重复获取将导致上次获取的access_token失效。并且每天调用获取access_token接口的上限是2000次。
总结以上说明，access_token需要做到以下两点：
1.因为access_token有2个小时的时效性，要有一个机制保证最长2个小时重新获取一次；
2.因为接口调用上限每天2000次，所以不能调用太频繁；
就此，这里采用的方案是这样的，定义一个默认启动的servlet，在init方法中启动一个Thread,这个进程中定义一个无限循环的方法，用来获取access_token，当获取成功后，此进程休眠7000秒，否则休眠3秒钟继续获取。流程图如下：
下面正式开始在工程中实现以上思路，因为返回的数据都是json格式，这里会用到阿里的fastjson库，为构造请求和处理请求后的数据序列化和反序列化提供支持。后续的其它接口也会用到。
1.定义一个AccessToken实体
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
public class AccessToken
{
public String
getAccessToken() {
return accessToken;
}
public void setAccessToken(String
accessToken) {
this.accessToken
= accessToken;
}
public int getExpiresin()
{
return expiresin;
}
public void setExpiresin(int expiresin)
{
this.expiresin
= expiresin;
}
private String
accessToken;
private int expiresin;
}
|
2.定义一个默认启动的servlet，在init方法中启动一个Thread，并在web.xml中将这个servlet设置为默认自启动的。
|
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
|
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
/**
*
Created by huzhicheng on 2015/12/8.
*/
@WebServlet(name
= "AccessTokenServlet")
public class AccessTokenServlet extends HttpServlet
{
public void init() throws ServletException
{
TokenThread.appId
= getInitParameter("appid"); //获取servlet初始参数appid和appsecret
TokenThread.appSecret
= getInitParameter("appsecret");
System.out.println("appid:"+TokenThread.appId);
System.out.println("appSecret:"+TokenThread.appSecret);
new Thread(new TokenThread()).start(); //启动进程
}
protected void doPost(HttpServletRequest
request, HttpServletResponse response) throws ServletException,
IOException {
}
protected void doGet(HttpServletRequest
request, HttpServletResponse response) throws ServletException,
IOException {
}
}
|
在web.xml中设置servlet自启动，并设置初始化参数appid和appsecret
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
<servlet>
<servlet-name>initAccessTokenServlet</servlet-name>
<servlet-class>
org.fengzheng.wechat.accesstoken.AccessTokenServlet
</servlet-class>
<init-param>
<param-name>appid</param-name>
<param-value>your
appid</param-value>
</init-param>
<init-param>
<param-name>appsecret</param-name>
<param-value>your
appsecret</param-value>
</init-param>
<load-on-startup>0</load-on-startup>
</servlet>
|
3.定义Thread类，在此类中调用access_token获取接口，并将得到的数据抽象到静态实体，以便在其它地方使用。接口地址为https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET，其中grant_type固定写为client_credential即可。此请求为https的get请求，返回的数据格式为{"access_token":"ACCESS_TOKEN","expires_in":7200}。
进程类实现如下：
|
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
|
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.fengzheng.wechat.common.NetWorkHelper;
/**
*
Created by huzhicheng on 2015/11/5.
*/
public class TokenThread implements Runnable
{
public static String
appId = "";
public static String
appSecret= "";
<br> //注意是静态的
public static AccessToken
accessToken = null;
public void run(){
while (true){
try{
accessToken
= this.getAccessToken();
if(null!=accessToken){
System.out.println(accessToken.getAccessToken());
Thread.sleep(7000 * 1000); //获取到access_token
休眠7000秒
}else{
Thread.sleep(1000*3); //获取的access_token为空
休眠3秒
}
}catch(Exception
e){
System.out.println("发生异常："+e.getMessage());
e.printStackTrace();
try{
Thread.sleep(1000*10); //发生异常休眠1秒
}catch (Exception
e1){
}
}
}
}
/**
*
获取access_token
*
@return
*/
private AccessToken
getAccessToken(){
NetWorkHelper
netHelper = new NetWorkHelper();
String
Url = String.format("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s",this.appId,this.appSecret);
String
result = netHelper.getHttpsResponse(Url,"");
System.out.println(result);
//response.getWriter().println(result);
JSONObject
json = JSON.parseObject(result);
AccessToken
token = new AccessToken();
token.setAccessToken(json.getString("access_token"));
token.setExpiresin(json.getInteger("expires_in"));
return token;
}
}
|
其中NetWorkHelper中getHttpsResponse方法是请求一个https地址，参数requestMethod为字符串“GET”或者“POST”，传null或者“”默认为get方式。
实现如下：
|
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
|
public String
getHttpsResponse(String hsUrl,String requestMethod) {
URL
url;
InputStream
is = null;
String
resultData = "";
try {
url
= new URL(hsUrl);
HttpsURLConnection
con = (HttpsURLConnection) url.openConnection();
TrustManager[]
tm = {xtm};
SSLContext
ctx = SSLContext.getInstance("TLS");
ctx.init(null,
tm, null);
con.setSSLSocketFactory(ctx.getSocketFactory());
con.setHostnameVerifier(new HostnameVerifier()
{
@Override
public boolean verify(String
arg0, SSLSession arg1) {
return true;
}
});
con.setDoInput(true); //允许输入流，即允许下载
//在android中必须将此项设置为false
con.setDoOutput(false); //允许输出流，即允许上传
con.setUseCaches(false); //不使用缓冲
if(null!=requestMethod
&& !requestMethod.equals(""))
{
con.setRequestMethod(requestMethod); //使用指定的方式
}
else{
con.setRequestMethod("GET"); //使用get请求
}
is
= con.getInputStream(); //获取输入流，此时才真正建立链接
InputStreamReader
isr = new InputStreamReader(is);
BufferedReader
bufferReader = new BufferedReader(isr);
String
inputLine = "";
while ((inputLine
= bufferReader.readLine()) != null)
{
resultData
+= inputLine + "\n";
}
System.out.println(resultData);
Certificate[]
certs = con.getServerCertificates();
int certNum
= 1;
for (Certificate
cert : certs) {
X509Certificate
xcert = (X509Certificate) cert;
}
} catch (Exception
e) {
e.printStackTrace();
}
return resultData;
}
X509TrustManager
xtm = new X509TrustManager()
{
@Override
public X509Certificate[]
getAcceptedIssuers() {
//
TODO Auto-generated method stub
return null;
}
@Override
public void checkServerTrusted(X509Certificate[]
arg0, String arg1)
throws CertificateException
{
//
TODO Auto-generated method stub
}
@Override
public void checkClientTrusted(X509Certificate[]
arg0, String arg1)
throws CertificateException
{
//
TODO Auto-generated method stub
}
};
|
至此代码实现完毕，将项目部署，看到控制台输出如下：
为方面看效果，可以把休眠时间设置短一点，比如30秒获取一次，然后将access_token输出。下面做一个测试jsp页面，并把休眠时间设置为30秒，这样过30秒刷新页面，就可以看到变化，顺便演示一下在其它地方如何拿到access_token
|
1
2
3
4
5
6
7
8
9
10
|
<%@
page contentType="text/html;charset=UTF-8" language="java" %>
<%@
page import="org.fengzheng.wechat.accesstoken.TokenThread" %>
<html>
<head>
<title></title>
</head>
<body>
access_token为：<%=TokenThread.accessToken.getAccessToken()%>
</body>
</html>
|
这样在浏览器上浏览这个页面,显示效果如下：
30秒后刷新，这个值发生了变化：