jetcache refresh error

• 一、背景描述
• 二、报错内容
• 三、报错原因
• 四、解决方案
• • 4.1 解决方案一，使用一级缓存
  • 4.2 解决方案二，开启写入权限

一、背景描述

技术栈：Spring Boot(2.1.5.RELEASE) + Spring Cloud
Oopenfeign(2.1.1.RELEASE) + jetCache(2.5.14) + redis(3.1.0)

由于项目使用了微服务架构，各个服务职责不同，又相互引用，所以就经常在服务A中调用服务B的接口，我们使用的是Feign客户端，即 FeignClient。通过接口调用返回的数据，在服务A中先进行了缓存（使用了JetCache），减少对服务B的频繁调用，减轻服务B的压力。

由于 jetCache 可以使用两级缓存（本地缓存 + 远程缓存），所以在代码中便开启了两级缓存，本地缓存（内存中）数量限制为50个，远程缓存（redis）不限制数量。

使用两个注解就可以实现添加缓存和刷新缓存。分别是 @Cached 添加缓存，@CacheRefresh 刷新缓存，如果开启两级缓存，那么两级缓存都会刷新，如果只有一级缓存，那么只会缓存一级缓存。

缓存时间为30分钟，每60秒对缓存进行刷新一次。于是代码如下：

package com.iot.back.message.process.rpc;import com.alicp.jetcache.anno.CacheRefresh;
import com.alicp.jetcache.anno.CacheType;
import com.alicp.jetcache.anno.Cached;
import com.iot.basic.iotsmarthome.api.client.floor.FloorClient;
import com.iot.framework.core.response.CommResponse;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;import javax.annotation.Resource;
import java.util.concurrent.TimeUnit;/*** 
FloorClientRpc 此类用于：调用基础家居服务楼层相关接口 
* 
@author：hujm
* 
@date：2022年07月20日 14:18
* 
@remark：
*/
@Slf4j
@Component
public class FloorClientRpc {@ResourceFloorClient floorClient;@Cached(name = "back-process-service:jetCache:singleFloor:", expire = 30, timeUnit = TimeUnit.MINUTES, cacheType = CacheType.BOTH, localLimit = 50)@CacheRefresh(refresh = 60)public Boolean singleFloor(String sn) {CommResponse commResponse = floorClient.singleFloor(sn);if (commResponse == null || commResponse.isFail()) {log.error("P0|FloorClientRpc|singleFloor|调用基础家居服务时，根据【sn = {}】获取当前家庭是否为单楼层失败！", sn);return null;}return commResponse.getData();}
}

出现的现象是在本机的电脑上（Windows 10）跑代码，刷新缓存正常，也不报错。部署到服务器上（Linux ）就会报刷新缓存错误的问题。

二、报错内容

[2022-11-22 16:38:59 ERROR com.alicp.jetcache.RefreshCache.run(RefreshCache.java:257) JetCacheHeavyIOExecutor5   :] refresh error: key=[Ljava.lang.Object;@1f4c18af
com.alicp.jetcache.CacheException: refresh errorat com.alicp.jetcache.RefreshCache$RefreshTask.lambda$externalLoad$0(RefreshCache.java:207)at com.alicp.jetcache.Cache.tryLockAndRun(Cache.java:272)at com.alicp.jetcache.RefreshCache$RefreshTask.externalLoad(RefreshCache.java:212)at com.alicp.jetcache.RefreshCache$RefreshTask.run(RefreshCache.java:252)at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.NullPointerException: null

三、报错原因

根据报错内容，查看源码后得知是 key 为空，发生了空指针异常。源码如下图所示：

这一行代码唯一可能为空的就是 lockKey，只有这里可能会发生空指针

使用 jetCache 之后，就开启了两级缓存（本地缓存 + 远程缓存）即在 @Cached 注解上添加了 cacheType = CacheType.BOTH 这个属性。开启了两级缓存，那么使用 @CacheRefresh 注解，会使两级缓存都进行刷新。

在Windows电脑上使用的是管理员用户，可以向本地缓存中写数据，所以在本机上运行代码不会报错，而程序部署到服务器上，由于不是超管账户所以没有向本地缓存中写入数据的权限，导致服务器上的本地缓存没有数据。而使用 refreshCache 注解之后，它是根据缓存数据中的 key 来刷新缓存的，由于服务器本地电脑并没有成功保存数据，而导致没有查到这个 key ，所以会才报 key 的NPE（NullPointerException）。

四、解决方案

知道了上述原因之后，对应的就会出现两种解决方案，第一种就是把本地缓存关了，只使用远程缓存；第二种就是把服务器上的写入本地缓存的权限放开。

4.1 解决方案一，使用一级缓存

@Cached 注解上修改 cacheType = CacheType.BOTH 为 cacheType = CacheType.REMOTE，并把 localLimit 属性删除，仅使用远程缓存，不使用本地缓存，修改过后再把代码部署到服务器上之后，刷新缓存时不再报错。已经验证可以使用。

4.2 解决方案二，开启写入权限

让运维工程师把写入本地缓存的权限放开。这个由于没有验证，只是理论上可行。有条件的可以验证一下。

完结！