单例模式如何解决access_token全局缓存问题
程序员文章站
2022-03-16 18:13:58
...
最初将access_token放到数据库中,每次获取时判断是否过期。可以解决access_token的有效期及访问次数问题。但是最近需要将公众号与系统做接口,取消公众号的数据库,此时再将access_token等放到系统的数据库中就不合适了。
受益于薛喜麟的这篇文章:微信处理access_token全局缓存的问题,实现了用单例模式来缓存access_token。
记一下,供以后查用。
mark一下自己的代码结构:
public class TokenSingleton { //缓存accessToken 的Map ,map中包含 一个accessToken 和 缓存的时间戳 private Map<String, String> map = new HashMap<>(); private TokenSingleton() { } private static TokenSi ngleton single = null; // 静态工厂方法 public static TokenSingleton getInstance() { if (single == null) { single = new TokenSingleton(); } return single; } public Map<String, String> getMap() { String time = map.get("time"); String accessToken = map.get("access_token"); Long nowDate = new Date().getTime(); if (accessToken != null && time != null && nowDate - Long.parseLong(time) < 6000*1000) { System.out.println("accessToken存在,且没有超时 , 返回单例"); } else { System.out.println("accessToken 超时 , 或者不存在 , 重新获取"); String access_token=JSSDKUtil.getAccessToken(); //这里是直接调用微信的API去直接获取 accessToken 和Jsapi_ticket 获取 String jsapi_token = JSSDKUtil.getTicket(access_token); //"获取jsapi_token"; map.put("time", nowDate + ""); map.put("access_token", access_token); map.put("jsapi_token", jsapi_token); } return map; } public void setMap(Map<String, String> map) { this.map = map; } public static TokenSingleton getSingle() { return single; } public static void setSingle(TokenSingleton single) { TokenSingleton.single = single; } }
另外一个工具类JSSDKUtil.java截取了部分:
public static String getSignature(String accessToken,String jsapi_ticket,String noncestr,String timestamp,String url){ System.out.println("accessToken:"+accessToken+"\njsapi_ticket:"+jsapi_ticket+"\n时间戳:"+timestamp+"\n随机字符串:"+noncestr+"\nURL:"+url); //5、将参数排序并拼接字符串 String str = "jsapi_ticket="+jsapi_ticket+"&noncestr="+noncestr+"×tamp="+timestamp+"&url="+url; //6、将字符串进行sha1加密 String signature =SHA1(str); System.out.println("参数:"+str+"\n签名:"+signature); return signature; } public static String getAccessToken() { String wx_appid = getProperties("wx_appid"); String wx_appsecret = getProperties("wx_appsecret"); String access_token = ""; String grant_type = "client_credential";//获取access_token填写client_credential String AppId=wx_appid;//第三方用户唯一凭证 String secret=wx_appsecret;//第三方用户唯一凭证密钥,即appsecret //这个url链接地址和参数皆不能变 String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type="+grant_type+"&appid="+AppId+"&secret="+secret; try { URL urlGet = new URL(url); HttpURLConnection http = (HttpURLConnection) urlGet.openConnection(); http.setRequestMethod("GET"); // 必须是get方式请求 http.setRequestProperty("Content-Type","application/x-www-form-urlencoded"); http.setDoOutput(true); http.setDoInput(true); System.setProperty("sun.net.client.defaultConnectTimeout", "30000");// 连接超时30秒 System.setProperty("sun.net.client.defaultReadTimeout", "30000"); // 读取超时30秒 http.connect(); InputStream is = http.getInputStream(); int size = is.available(); byte[] jsonBytes = new byte[size]; is.read(jsonBytes); String message = new String(jsonBytes, "UTF-8"); JSONObject demoJson = JSONObject.fromObject(message); System.out.println("JSON字符串:"+demoJson); access_token = demoJson.getString("access_token"); is.close(); } catch (Exception e) { e.printStackTrace(); } return access_token; } public static String getTicket(String access_token) { String ticket = null; String url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token="+ access_token +"&type=jsapi";//这个url链接和参数不能变 try { URL urlGet = new URL(url); HttpURLConnection http = (HttpURLConnection) urlGet.openConnection(); http.setRequestMethod("GET"); // 必须是get方式请求 http.setRequestProperty("Content-Type","application/x-www-form-urlencoded"); http.setDoOutput(true); http.setDoInput(true); System.setProperty("sun.net.client.defaultConnectTimeout", "30000");// 连接超时30秒 System.setProperty("sun.net.client.defaultReadTimeout", "30000"); // 读取超时30秒 http.connect(); InputStream is = http.getInputStream(); int size = is.available(); byte[] jsonBytes = new byte[size]; is.read(jsonBytes); String message = new String(jsonBytes, "UTF-8"); JSONObject demoJson = JSONObject.fromObject(message); System.out.println("JSON字符串:"+demoJson); ticket = demoJson.getString("ticket"); is.close(); } catch (Exception e) { e.printStackTrace(); } return ticket; } public static String SHA1(String decript) { try { MessageDigest digest = java.security.MessageDigest.getInstance("SHA-1"); digest.update(decript.getBytes()); byte messageDigest[] = digest.digest(); // Create Hex String StringBuffer hexString = new StringBuffer(); // 字节数组转换为 十六进制 数 for (int i = 0; i < messageDigest.length; i++) { String shaHex = Integer.toHexString(messageDigest[i] & 0xFF); if (shaHex.length() < 2) { hexString.append(0); } hexString.append(shaHex); } return hexString.toString(); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } return ""; }
相关推荐:
浅析MySQL内存的使用说明(全局缓存+线程缓存)_MySQL
以上就是单例模式如何解决access_token全局缓存问题的详细内容,更多请关注其它相关文章!
上一篇: 小程序中动态获取列表对象信息的代码示例
下一篇: 什么是单例模式?