为什么要缓存token&＃xff1f;
这里的token指的是微信JSAPI中基础支持的ACCESS_TOKEN,并非网页授权ACCESS_TOKEN。网页授权Token每天的调用次数没有限制&＃xff0c;不需要缓存。
接口每日限额
获取access_token
2000
自定义菜单创建
1000
自定义菜单查询
10000
获取用户基本信息
5000000
获取网页授权access_token
无
刷新网页授权access_token
无
网页授权获取用户信息
无
从上面的表格我们可以看到&＃xff0c;微信基础支持的token每天调用频次为2000次。而token的有效时间为7200s&＃xff0c;当实现了token的全局缓存后&＃xff0c;理论每天只需要调用12次。相反&＃xff0c;2000次即使仅供微信分享回调&＃xff0c;在有一定用户基础的项目中完全满足不了。
缓存方案
项目启动时开启一个定时器&＃xff0c;每7180s执行一次Http请求&＃xff0c;从微信获取最新的access_token并将redis中旧的access_token替换掉。
代码中有需要使用access_token时&＃xff0c;直接从缓存中读取。
Spring Boot使用定时器
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.sql.SQLException;
import javax.annotation.Resource;
import org.apache.log4j.Logger;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import com.bjb.dao.impl.RedisTokenHelper;
import net.sf.json.JSONObject;
/**
* 全局定时器
* &＃64;author qiqj
*
*/
&＃64;Component
public class Scheduler {
private final Logger logger &＃61; Logger.getRootLogger();
&＃64;Resource
private RedisTokenHelper redisTokenHelper;
/**
* 定时获取access_token
* &＃64;throws SQLException
*/
&＃64;Scheduled(fixedDelay&＃61;7180000)
public void getAccessToken() throws SQLException{
logger.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;开始获取access_token&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");
String access_token &＃61; null;
String grant_type &＃61; "client_credential";
String AppId&＃61; WxPropertiseUtil.getProperty("appid");
String secret&＃61; WxPropertiseUtil.getProperty("secret");
String url &＃61; "https://api.weixin.qq.com/cgi-bin/token?grant_type&＃61;"&＃43;grant_type&＃43;"&appid&＃61;"&＃43;AppId&＃43;"&secret&＃61;"&＃43;secret;
try {
URL urlGet &＃61; new URL(url);
HttpURLConnection http &＃61; (HttpURLConnection) urlGet.openConnection();
http.setRequestMethod("GET"); // 必须是get方式请求
http.setRequestProperty("Content-Type","application/x-www-form-urlencoded");
http.setDoOutput(true);
http.setDoInput(true);
http.connect();
InputStream is &＃61; http.getInputStream();
int size &＃61; is.available();
byte[] jsonBytes &＃61; new byte[size];
is.read(jsonBytes);
String message &＃61; new String(jsonBytes, "UTF-8");
JSONObject demoJson &＃61; JSONObject.fromObject(message);
//System.out.println("JSON字符串&＃xff1a;"&＃43;demoJson);
access_token &＃61; demoJson.getString("access_token");
is.close();
logger.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;结束获取access_token&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");
} catch (Exception e) {
e.printStackTrace();
}
logger.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;开始写入access_token&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");
redisTokenHelper.saveObject("global_token", access_token);
logger.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;写入access_token成功&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");
}
}
读取配置文件工具类
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import org.apache.log4j.Logger;
/**
* 读取微信配置文件 wxconfig.properties工具类
*&＃64;author qiqj
*
*/
public class WxPropertiseUtil {
private static Properties properties &＃61; new Properties();
protected static final Logger logger &＃61; Logger.getRootLogger();
static{
InputStream in &＃61; WxPropertiseUtil.class.getClassLoader().getResourceAsStream("wxconfig.properties");
try {
properties.load(in);
} catch (IOException e) {
e.printStackTrace();
logger.error(e.getMessage());
}
}
public static String getProperty(String key){
return properties.getProperty(key);
}
public static void UpdateProperty(String key,String value){
properties.setProperty(key, value);
}
}
微信配置文件
appid&＃61;xxxx
secret&＃61;xxxxxx
Redis操作工具类
import java.util.concurrent.TimeUnit;
import javax.annotation.Resource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Repository;
/**
* 封装Redis存取Token对的工具类
*&＃64;author qiqj
*
*/
&＃64;Repository
public class RedisTokenHelper {
&＃64;Autowired
StringRedisTemplate stringRedisTemplate;
&＃64;Autowired
RedisTemplate redisTemplate;
&＃64;Resource(name&＃61;"stringRedisTemplate")
ValueOperations ops;
&＃64;Resource(name&＃61;"redisTemplate")
ValueOperations objOps;
/**
* 键值对存储 字符串 &＃xff1a;有效时间3分钟
*&＃64;param tokenType Token的key
*&＃64;param Token Token的值
*/
public void save(String tokenType,String Token){
ops.set(tokenType, Token, 180, TimeUnit.SECONDS);
}
/**
* 根据key从redis获取value
*&＃64;param tokenType
*&＃64;return String
*/
public String getToken(String tokenType){
return ops.get(tokenType);
}
/**
* redis 存储一个对象
*&＃64;param key
*&＃64;param obj
*&＃64;param timeout 过期时间 单位&＃xff1a;s
*/
public void saveObject(String key,Object obj,long timeout){
objOps.set(key, obj,timeout,TimeUnit.SECONDS);
}
/**
* redis 存储一个对象 ,不过期
*&＃64;param key
*&＃64;param obj
*/
public void saveObject(String key,Object obj){
objOps.set(key, obj);
}
/**
* 从redis取出一个对象
*&＃64;param key
*&＃64;param obj
*/
public Object getObject(String key){
return objOps.get(key);
}
/**
* 根据Key删除Object
*&＃64;param key
*/
public void removeObject(String key){
redisTemplate.delete(key);
}
}
简单测试
import org.apache.log4j.Logger;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.SpringApplicationConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.web.WebAppConfiguration;
import org.springframework.transaction.annotation.Transactional;
import com.bjb.Application;
import com.bjb.dao.impl.RedisTokenHelper;
/**
* Junit单元测试类
*&＃64;author qiqj
*
*/
&＃64;RunWith(SpringJUnit4ClassRunner.class)
&＃64;SpringApplicationConfiguration(classes&＃61;Application.class)
&＃64;WebAppConfiguration
&＃64;Transactional
public class JUnitTest {
private final Logger logger &＃61; Logger.getRootLogger();
&＃64;Resource
private RedisTokenHelper redisTokenHelper;
&＃64;Test
public void test(){
String access_token &＃61; (String) redisTokenHelper.getObject("global_token");
System.out.println("access_token:"&＃43;access_token);
}
}
京公网安备 11010802041100号