微信公众号之access_token获取与管理
转自：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 |
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= "" ; //注意是静态的 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" %> access_token为：<%=TokenThread.accessToken.getAccessToken()%> |
这样在浏览器上浏览这个页面,显示效果如下：
30秒后刷新，这个值发生了变化：
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！