获取地区数据的api接口,原先的实现是初次访问时一次性加载到内存变量里,以后的调用则直接从内存变量读取。这样虽然快,但弊端显而易见,当数据有更新,只能通过重启站点服务的方式搞定。
所以,要改造。
直觉想到的是用redis缓存。
在coding的时候,突然觉得还是从内存上做文章多好啊,毕竟读内存是最快的方式了。于是,想到了一个办法,每到整点清空数据变量。代码如下:
import org.joda.time.DateTime; private static String areaStr = ""; private String getAreaStr(){ //整点清除数据,重新调用rpc并加载到内存 int minuteOfHour = DateTime.now().getMinuteOfHour(); if (0 == minuteOfHour) { areaStr = ""; } if (StringUtil.isBlank(areaStr)) { log.info("初始化地区数据到内存"); //rpc请求 areaStr = threeLevelClient.selectAreaList(); } return areaStr; }
使用地区数据的地方不再直接访问areaStr变量,而是调用getAreaStr()方法。
还没等自测,我就意识到不对头了。这是web接口,那整点没有被访问,岂不是就达不到刷新数据的预期了!
还是不忘初心的好!就用redis来搞。考虑到数据量大,我还是做了点改动:把数据放到内存里,通过redis来控制内存数据的刷新。
private static String areaStr = ""; private static JedisCluster jc = JedisClusterUtil.getJedisCluster(); // 地区数据量大,不宜直接放到redis里。这里通过redis控制内存数据的刷新。 private void resetAreaStr() { final String areaStr_Key = "payment_api_areaStr"; String value = jc.get(areaStr_Key); if (StringUtils.isBlank(value)) { areaStr = threeLevelClient.selectAreaList(); jc.setex(areaStr_Key, 300, "1"); log.info("重置redis缓存:" + areaStr_Key); } if (StringUtils.isBlank(areaStr)) { log.info("初始化地区数据到内存"); //rpc请求 areaStr = threeLevelClient.selectAreaList(); } }
这样无疑是不错的方案了。使用areaStr之前调用resetAreaStr()方法即可。
@RequestMapping("transferCityQuery") public void transferCityQuery(HttpServletResponse response) throws Exception { // log.debug("payment_api----获取地区列表:{}", areaStr); resetAreaStr(); List<JSONObject> areaList = JSON.parseArray(areaStr, JSONObject.class); List<Map<String, String>> showAreaList = new ArrayList<>(); areaList.forEach(one -> { Map<String, String> bankInfo = new HashMap<>(); bankInfo.put("provinceName", one.getString("provinceName")); bankInfo.put("areaName", one.getString("areaName")); showAreaList.add(bankInfo); }); log.info("集合size:{}", areaList.size()); WebUtil.outputJson(showAreaList, response); }
原文地址:https://www.cnblogs.com/buguge/p/10603438.html
时间: 2024-10-13 00:55:50