## elab-cache 使用注意事项
#### 使用步骤:
1. 引入maven的依赖
```
<dependency>
<groupId>com.elab.cache</groupId>
<artifactId>elab-cache</artifactId>
<version>1.4</version>
</dependency>
```
2. 在配置文件中配置使用的对象
```
<!-- 默认生成的缓存key的实现策略 -->
<bean id="defaultCacheKeyGenerator" class="com.elab.cache.spring.generator.DefaultCacheKeyGenerator">
<property name="prefix" value="demo"/>
<property name="separator" value="_"/>
</bean>
<!-- 开启cache注解扫描 -->
<cache:annotation-driven cache-manager="cacheManager" key-generator="defaultCacheKeyGenerator"/>
<!-- redis 集群操作类 -->
<bean id="redisClusterClient" class="com.elab.cache.redis.RedisClusterClient" init-method="init" lazy-init="true">
<property name="redisBuilder" ref="redisClusterBuilder"></property>
</bean>
<!-- redis 主备操作类 -->
<bean id="redisSentineClient" class="com.elab.cache.redis.RedisSentinelClient" init-method="init" lazy-init="true">
<property name="redisBuilder" ref="redisSentinelBuilder"/>
<property name="password" value="elab@123"/>
<property name="dbIndex" value="2"/>
</bean>
<!-- redis 单机操作类 -->
<bean id="redisStandaloneClient" class="com.elab.cache.redis.RedisStandaloneClient" init-method="init"
lazy-init="true">
<property name="redisBuilder" ref="redisStandaloneBuilder"/>
<property name="password" value="elab@123"/>
<property name="dbIndex" value="2"/>
</bean>
<!-- 集群连接池配置 -->
<bean id="redisPoolConfig" class="org.apache.commons.pool2.impl.GenericObjectPoolConfig">
<property name="maxTotal" value="160"/>
<property name="maxIdle" value="160"/>
<property name="minIdle" value="80"/>
<property name="maxWaitMillis" value="1000"/>
<property name="jmxNamePrefix" value="jedis-pool"/>
<property name="jmxEnabled" value="true"/>
</bean>
<!-- 集群版redis操作 -->
<bean id="redisClusterBuilder" class="com.sohu.tv.builder.RedisClusterBuilder" lazy-init="true">
<constructor-arg value="10021"/>
<property name="jedisPoolConfig" ref="redisPoolConfig"/>
<property name="connectionTimeout" value="2000"/>
<property name="soTimeout" value="1000"/>
</bean>
<!-- 单机版redis 操作 -->
<bean id="redisStandaloneBuilder" class="com.sohu.tv.builder.RedisStandaloneBuilder" lazy-init="true">
<constructor-arg value="10002"/>
<property name="timeout" value="2000"/>
<property name="poolConfig" ref="redisPoolConfig"/>
</bean>
<!-- redisSentine操作 -->
<bean id="redisSentinelBuilder" class="com.sohu.tv.builder.RedisSentinelBuilder" lazy-init="true">
<constructor-arg value="10020"/>
<property name="poolConfig" ref="redisPoolConfig"/>
<property name="connectionTimeout" value="2000"/>
<property name="soTimeout" value="1000"/>
</bean>
<!-- 将默认的实现集成到spring-cache中 -->
<bean id="systemCacheManage" class="com.elab.cache.spring.manage.SystemCacheManage">
<property name="cacheClient" ref="redisStandaloneClient"/>
<property name="timeout" value="30000"/>
<property name="name" value="redisClient"/>
</bean>
<!-- 简单的缓存管理器 -->
<bean id="simpleCacheManager" class="org.springframework.cache.support.SimpleCacheManager">
<property name="caches" ref="systemCacheManage"/>
</bean>
<!-- 统一的缓存管理器 -->
<bean id="cacheManager"
class="org.springframework.cache.support.CompositeCacheManager">
<property name="cacheManagers">
<list>
<ref bean="simpleCacheManager"/>
</list>
</property>
<property name="fallbackToNoOpCache" value="true"/>
</bean>
```
3. 代码层面如何使用,具体需要
```
// 这里需要注意的是定义了CacheConfig相当于对这个类定义了全局的缓存配置
// 下面的value可以不用定义了 -> @Cacheable(value = "redisClient")
@CacheConfig(cacheNames = "redisClient")
public class ServiceImpl implements IService {
// 需要注意的是
// 第一个参数与配置文件中的systemCacheManage.name 参数要保持一致,这个注解是为了标识你要使用那个缓存
// 第二个参数是key生成的策略,不填默认[类_方法名_JSON参数],下面的生成最后lkx_test_2,表示自己指定的
// 第三个参数表示条件,表示redisModel的id不能为空才会进行缓存
@Cacheable(value = "redisClient", key = "'lkx_test_'+#redisModel.id" ,condition = "#redisModel.id != null")
public String test(RedisModel redisModel) {
System.out.println("执行完毕");
return "你好啊~~";
}
/**
* 每次都执行更新操作的注解
* @param redisModel
* @return
*/
@CachePut(value = "redisClient", key = "'lkx_test_'+#redisModel.id")
public String updateCache(RedisModel redisModel) {
System.out.println("执行修改完毕..");
return "OK";
}
/**
* allEntries : 是否清空所有缓存内容，缺省为 false，如果指定为 true，则方法调用后将立即清空所有缓存
* beforeInvocation : 是否在方法执行前就清空，缺省为 false，如果指定为 true，则在方法还没有执行的时候就清空缓存，缺省情况下，如果方法执行抛出异常，则不会清空缓存
*
* @param redisModel
* @return
*/
@CacheEvict(value = "redisClient", key = "'lkx_test_'+#redisModel.id", allEntries = false, beforeInvocation = false)
public String CacheEvict(RedisModel redisModel) {
System.out.println("执行del完毕..");
return "OK~";
}
}
```
**注意**
1. 集合如何更新
自定义的key的话最好有规律可循,例如再缓存了多个集合的情况出现数据更新就比较麻烦了,
所以推荐key的定义方式[project_class_list_method],这种的话,在更新缓存的时候,方便通过[project_class_list]为前缀的key全部删除掉,重新加载
2. CachePut在没有集合出现的情况比较适合,但是如果缓存的集合比较多,要做更新的话就会比较麻烦
5. 参考案例
RedisTest.testCache
6. 异常处理
> 当redis遇到异常导致停止时,不能导致应用无法使用
参考类: SimpleCacheErrorProcess , 里面是你具体的业务实现
```
public class SimpleCacheErrorProcess implements CacheErrorProcess {
Logger logger = LoggerFactory.getLogger(getClass());
@Override
public void handleCacheGetError(RuntimeException exception, ICacheClient cache, Object key) {
logger.error("==============handleCacheGetError==================== [key]" + key, exception);
}
@Override
public void handleCachePutError(RuntimeException exception, ICacheClient cache, Object key, Object value) {
logger.error("==============handleCachePutError==================== [key]" + key + "=======[value]" + value, exception);
}
@Override
public void handleCachePutError(RuntimeException exception, ICacheClient cache, Object key, Object filed, Object value) {
logger.error("==============handleCachePutError==================== [key]" + key + "=======[value]" + value + "========[filed]========" + filed, exception);
}
@Override
public void handleCacheEvictError(RuntimeException exception, ICacheClient cache, Object key) {
logger.error("==============handleCacheEvictError====================", exception);
}
@Override
public void handleCacheClearError(RuntimeException exception, ICacheClient cache) {
logger.error("==============handleCacheClearError====================", exception);
}
}
```
然后在spring中进行配置将这个SimpleCacheErrorProcess注入到每个redis的cacheErrorProcess属性中就行了
```
<bean id="redisStandaloneClient" class="com.elab.cache.redis.RedisStandaloneClient" init-method="init"
lazy-init="true">
<property name="redisBuilder" ref="redisStandaloneBuilder"/>
<property name="cacheErrorProcess" ref="你的实现类"/>
</bean>
```
## 升级日志
- 1.1 添加了日志容错功能,在redis报错的同时,不影响其他程序运行
- 1.2 升级spring-cache注解版功能
- 可以将注解添加到任意Spring扫描的包下
- 1.3 解决redis单机操作实现类在多线程下报错的原因。
- 将redis错误日志的exception也放入到了error日志中
- 1.4 解决问题:
- 解决reids连接未释放的问题
- redis配置添加密码配置
- redis配置选择数据库的问题