dawdler-server-plug-jedis
模块介绍
实现dawdler-server端注入JedisOperator的功能.
1. pom中引入依赖
<groupId>club.dawdler</groupId>
<artifactId>dawdler-server-plug-jedis</artifactId>
dawdler-server-plug-jedis
模块介绍
实现dawdler-server端注入JedisOperator的功能.
1. pom中引入依赖
<groupId>club.dawdler</groupId>
<artifactId>dawdler-server-plug-jedis</artifactId>
2. 使用方式
2.1 Jedis的使用方式
通过@JedisInjector注解标识全局变量为JedisOperator类型的变量即可.
public class UserServiceImpl implements UserService {
@JedisInjector("myRedis")//myRedis为配置文件的名称,不包含后缀properties
JedisOperator jedisOperator;
public User getUser(String userId) {
jedisOperator.set("userId", userId);//使用jedisOperator对象
return null;
}
}
2.2 分布式锁的使用方式
通过@JedisLockInjector注解标识全局变量为 类型的变量即可.
public class UserServiceImpl implements UserService {
@JedisLockInjector(fileName = "myRedis")//myRedis为配置文件的名称,不包含后缀properties
JedisDistributedLockHolder jedisDistributedLockHolder;
public void synUser(String userId, Business business) {
JedisDistributedLock lock = jedisDistributedLockHolder.createLock("lockKey:"+userId);
try {
lock.lock();
// lock.lock(3000); //3秒等待锁
// 模拟业务处理
doSomething(business);
} finally {
lock.unlock();
}
}
public void synUserNoWait(String userId, Business business) {
JedisDistributedLock lock = jedisDistributedLockHolder.createLock("lockKey:"+userId);
try {
//获取不到锁 立即结束不等待
if(lock.tryLock()){
// 模拟业务处理
doSomething(business);
}
} finally {
lock.unlock();
}
}
}