spring-easy-starter

项目简介

使用

#注解缓存配置 
easy.namespace=EasyCache #分布式缓存 key前缀
#刷新缓存相关配置
easy.poolSize=10 
easy.maxPoolSize=20
easy.keepAliveTime=5
easy.queueCapacity=500
#redis配置 分布式缓存 及 分布式锁、分布式限流 也取该配置使用 于spring-data-redis配置一样
spring.redis.database=5
spring.redis.jedis.pool.max-idle=20
spring.redis.jedis.pool.min-idle=1
spring.redis.jedis.pool.max-active=20
spring.redis.jedis.pool.max-wait=-1
# name of Redis server 哨兵监听的Redis server的名称
spring.redis.sentinel.master=mymaster
# comma-separated list of host:port pairs 哨兵的配置列表
spring.redis.sentinel.nodes=xxxx

限流

@GetMapping("/get")
@RateLimiter(key = "rate:getUser1",limit = 5,expire = 1,fallBackMethod = "getUser1FallBack")
#@RateLimiter(key = "rate:getUser1",limit = 5,expire = 1,fallBackMethod = "getUser1FallBack",type = RateLimiterType.DISTRIBUTED_RATELIMITER)
public String getUser1() {
 return JSON.toJSONString(userService.getUserById(1));
}
public String getUser1FallBack(){
 return "限流降级成功";
}

缓存

@Cache(keys ={"USER:getSpelById","#userId"},expire = 1200)
public UserDO getUserById(int userId) {
 UserDO userDO=new UserDO();
 userDO.setUserId(userId);
 userDO.setUserName("easyCache");
 userDO.setAge(20);
 userDO.setPassword("中文");
 return userDO;
}
---------------------------------------------------
@Cache(keys = {"USER:getHashUserById"},hFields ={"#userId"},expire = 1200)
public UserDO getHashUserById(int userId) {
 UserDO userDO=new UserDO();
 userDO.setUserId(userId);
 userDO.setUserName("easyCache");
 userDO.setAge(20);
 userDO.setPassword("123123");
 return userDO;
}
----------------------------------------------------
@Cache(keys = {"USER:queryUser:","#user.userName"})
public List<UserDO> queryUser(UserDO user) {
 List<UserDO> list=new ArrayList<>();
 UserDO userDO=new UserDO();
 userDO.setUserId(1);
 userDO.setUserName(user.getUserName());
 userDO.setAge(20);
 userDO.setPassword("123123");
 list.add(userDO);
 return list;
}

@Override
@DelCache(keys = {"USER:getSpelById","#userId"})
public int delUserById(int userId) {
 return 0;
}

分布式锁

@ELock(keys = {"and","#userId"},waitTime = 6000L,leaseTime = 6000L,lockType = LockType.Reentrant)
public UserDO getUserById(int userId) {
 UserDO userDO=new UserDO();
 userDO.setUserId(userId);
 userDO.setUserName("easyCache");
 userDO.setAge(20);
 userDO.setPassword("中文");
 return userDO;
}
锁类型
/**
* 可重入锁
*/
Reentrant,
/**
* 公平锁
*/
Fair,
/**
* 读锁
*/
Read,
/**
* 写锁
*/
Write;