基于Redisson實(shí)現(xiàn)注解式分布式鎖的示例代碼
更新時(shí)間：2023年07月26日 16:08:01 作者：叔牙
這篇文章主要為大家詳細(xì)介紹了如何基于Redisson實(shí)現(xiàn)注解式分布式鎖，文中的示例代碼講解詳細(xì)，具有一定的參考價(jià)值，需要的可以了解一下
一、背景
基于redisson的分布式鎖實(shí)現(xiàn),我們可以比較容易的控制競(jìng)態(tài)資源的分布式并發(fā)控制,但是使用的時(shí)候會(huì)出現(xiàn)很多重復(fù)的try-catch-finally代碼塊,獲取鎖、加鎖和釋放鎖等,用法大致如下:
RLock lock = redissonClient.getLock("lock_name");
try {
if(lock.tryLock(5,10, TimeUnit.SECONDS)) {
//do something
}
} catch (Exception e) {
log.error("occur error",e);
} finally {
if (lock.isLocked() && lock.isHeldByCurrentThread()) {
lock.unlock();
}
}寫(xiě)代碼講究一個(gè)優(yōu)雅和高效,作為一個(gè)有追求的程序員,項(xiàng)目中出現(xiàn)大面積重復(fù)性的手動(dòng)加鎖解鎖以及try-catch-finally代碼塊是不能接受的。 從鎖使用方式中,我們可以抽象出通用的部分,try-catch-finally代碼塊,以及獲取鎖、加鎖和解鎖邏輯,那么有沒(méi)有一種方式把這些邏輯抽取到一個(gè)地方管理,然后在需要使用鎖的地方,通過(guò)簡(jiǎn)單的方式引入加鎖解鎖邏輯? 答案是可以的,我們可以結(jié)合自定義注解和切面,把加鎖邏輯封裝起來(lái),然后攔截使用了解鎖注解的方法,把加鎖解鎖邏輯織入進(jìn)去就可以了。
二、寫(xiě)成starter復(fù)用
新建一個(gè)starter工程,把加鎖邏輯封裝到切面,然后通過(guò)注解的方式提供給業(yè)務(wù)使用。
1.引入依賴(lài)
引入redis和redisson相關(guān)依賴(lài):
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
</dependency>2.定義分布式鎖注解
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface XLock {
String key() default "";
@AliasFor("key")
String value() default "";
long waitTime() default 5;
long leaseTime() default 30;
TimeUnit unit() default TimeUnit.SECONDS;
}定義加鎖的key,等待時(shí)間,鎖釋放時(shí)間和時(shí)間單位。
3.定義分布式鎖屬性
@ConfigurationProperties(prefix = "redisson.redis")
@Data
public class RedissonProperties {
private String port;
private String password;
private int database = 0;
/**
* redis服務(wù)端類(lèi)型
* @see ServerType
*/
private Integer serverType;
private SingleServer singleServer;
private ClusterServers clusterServers;
private MasterSlaveServers masterSlaveServers;
private ReplicatedServers replicatedServers;
private SentinelServers sentinelServers;
@Data
public static class SingleServer {
private String host;
}
@Data
public static class ClusterServers {
private String hosts;//多個(gè)用逗號(hào)隔開(kāi)
}
@Data
public static class MasterSlaveServers {
private String masterHost;
private String slaveHosts;//多個(gè)用逗號(hào)隔開(kāi)
}
@Data
public static class ReplicatedServers {
private String hosts;
}
@Data
public static class SentinelServers {
private String masterName;
private String hosts;
}
}包含了端口,密碼，默認(rèn)數(shù)據(jù)庫(kù),以及redis server各種模式的支持。 在使用的時(shí)候需要在配置文件中添加如下類(lèi)似的配置:
redisson:
redis:
port: 6379
password: xxxxxx
database: 0
serverType: 1 #2,3,4,5
singleServer:
host: 127.0.0.1
clusterServers:
hosts: 192.168.0.1,192.168.0.2,192.168.0.3
masterSlaveServers:
masterHost: 127.0.0.1
slaveHosts: 192.168.0.1,192.168.0.2
replicatedServers:
hosts: 192.168.0.1,192.168.0.2,192.168.0.3
sentinelServers:
masterName: masterNode
hosts: 192.168.0.1,192.168.0.2,192.168.0.34.編寫(xiě)切面邏輯
@Slf4j
@Aspect
@Order(Ordered.LOWEST_PRECEDENCE - 1)
public class XLockInterceptor {
@Autowired
private RedissonClient redissonClient;
private ExpressionParser parser = new SpelExpressionParser();
private LocalVariableTableParameterNameDiscoverer discoverer = new LocalVariableTableParameterNameDiscoverer();
@Around("@annotation(lock.starter.annotation.XLock)")
public Object aroundMethod(ProceedingJoinPoint pjp) throws Throwable {
Object object = null;
MethodSignature joinPointObject = (MethodSignature) pjp.getSignature();
Method method = joinPointObject.getMethod();
XLock xlock = method.getAnnotation(XLock.class);
if(null == xlock) {
return pjp.proceed();
}
Object[] args = pjp.getArgs();
String[] params = discoverer.getParameterNames(method);
EvaluationContext context = new StandardEvaluationContext();
for (int i = 0; i < params.length; i++) {
context.setVariable(params[i],args[i]);
}
String keySpel = xlock.key();
Expression keyExpression = parser.parseExpression(keySpel);
String key = keyExpression.getValue(context,String.class);
RLock lock = redissonClient.getLock(key);
long waitTime = xlock.waitTime();
long leaseTime = xlock.leaseTime();
TimeUnit unit = xlock.unit();
try {
if(lock.tryLock(waitTime,leaseTime,unit)) {
object = pjp.proceed();
}
} catch (Exception e) {
throw new RuntimeException(e);
} finally {
//鎖被持有,并且被當(dāng)前線程持有
if (lock.isLocked() && lock.isHeldByCurrentThread()) {
lock.unlock();
}
}
return object;
}
}切面邏輯使用around攔截模式,解析使用了@XLock注解的方法,然后織入加鎖解鎖邏輯。
5.定義自動(dòng)注入配置
@Configuration
@ConditionalOnClass({RedissonClient.class, RedissonLock.class})
@EnableConfigurationProperties(RedissonProperties.class)
@Slf4j
public class XLockAutoConfiguration {
private RedissonProperties redissonProperties;
public XLockAutoConfiguration(RedissonProperties redissonProperties) {
this.redissonProperties = redissonProperties;
}
@Bean
@ConditionalOnMissingBean(RedissonClient.class)
public RedissonClient redisson() {
String password = this.redissonProperties.getPassword();
String port = this.redissonProperties.getPort();
int database = this.redissonProperties.getDatabase();
ServerType serverType = ServerType.of(this.redissonProperties.getServerType());
if(null == serverType) {
throw new RuntimeException("server type not support;serverType=" + this.redissonProperties.getServerType());
}
Config config = new Config();
if(ServerType.SINGLE_SERVER.equals(serverType)) {
String address = "redis://" + redissonProperties.getSingleServer().getHost() + ":" + port;
SingleServerConfig singleServerConfig = config.useSingleServer()
.setAddress(address)
.setDatabase(database);
if(null != password) {
singleServerConfig.setPassword(password);
}
} else if(ServerType.CLUSTER_SERVERS.equals(serverType)) {
ClusterServersConfig clusterServersConfig = config.useClusterServers();
String hosts = redissonProperties.getClusterServers().getHosts();
for (String host : hosts.split(",")) {
clusterServersConfig.addNodeAddress("redis://" + host + ":" + port);
}
if(null != password) {
clusterServersConfig.setPassword(password);
}
} else if (ServerType.MASTER_SLAVE_SERVERS.equals(serverType)) {
MasterSlaveServersConfig masterSlaveServersConfig = config.useMasterSlaveServers()
.setDatabase(database);
masterSlaveServersConfig.setMasterAddress("redis://" + redissonProperties.getMasterSlaveServers().getMasterHost() + ":" + port);
for (String slaveHost : redissonProperties.getMasterSlaveServers().getSlaveHosts().split(",")) {
masterSlaveServersConfig.addSlaveAddress("redis://" + slaveHost + ":" + port);
}
if(null != password) {
masterSlaveServersConfig.setPassword(password);
}
} else if (ServerType.REPLICATED_SERVERS.equals(serverType)) {
ReplicatedServersConfig replicatedServersConfig = config.useReplicatedServers()
.setDatabase(database);
for (String host : this.redissonProperties.getReplicatedServers().getHosts().split(",")) {
replicatedServersConfig.addNodeAddress("redis://" + host + ":" + port);
}
if(null != password) {
replicatedServersConfig.setPassword(password);
}
} else if (ServerType.SENTINEL_SERVERS.equals(serverType)) {
SentinelServersConfig sentinelServersConfig = config.useSentinelServers()
.setDatabase(database)
.setMasterName(this.redissonProperties.getSentinelServers().getMasterName());
for (String host : this.redissonProperties.getSentinelServers().getHosts().split(",")) {
sentinelServersConfig.addSentinelAddress("redis://" + host + ":" + port);
}
if(null != password) {
sentinelServersConfig.setPassword(password);
}
}
return Redisson.create(config);
}
@Bean
@ConditionalOnBean(RedissonClient.class)
public XLockInterceptor xLockInterceptor() {
return new XLockInterceptor();
}
}在用戶項(xiàng)目中如果沒(méi)有定義或者注入RedissonClient,那么通過(guò)starter注入RedissonClient,并且支持singleServer、clusterServers、masterSlave、replicatedServer和sentinelServer等模式。 并通過(guò)@Bean方式注入暴露鎖切面。
6.自動(dòng)配置
在starter工程的META-INF/spring.factories中定義自動(dòng)配置:
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\ lock.starter.config.XLockAutoConfiguration
基于spring的SPI模式在項(xiàng)目啟動(dòng)時(shí)自動(dòng)加載starter的分布式鎖相關(guān)配置,開(kāi)啟分布式鎖能力。 然后打成jar包到倉(cāng)庫(kù),業(yè)務(wù)項(xiàng)目就可以pom依賴(lài)引入,使用分布式鎖相關(guān)能力了。
三、使用
業(yè)務(wù)項(xiàng)目中使用分布式鎖starter的能力比較簡(jiǎn)單,引入依賴(lài)并定義相關(guān)配置即可。
1.引入分布式鎖starter
<dependency>
<groupId>xxx.xxx</groupId>
<artifactId>xlock-redisson-starter</artifactId>
</dependency>2.添加配置
在項(xiàng)目中添加分布式鎖所需的配置,以singleServer模式為例:
redisson:
redis:
port: 6379
password: xxxxxx
database: 0
serverType: 1 #2,3,4,5
singleServer:
host: 127.0.0.13.使用分布式鎖
在需要加鎖的方法上添加@XLock注解,并填入加鎖相關(guān)的屬性即可.
@XLock(key = "mylock + #uid",waitTime = 5,leaseTime = 10,unit = TimeUnit.SECONDS)
public void doSomething(String uid) {
//do some business...
}這樣就實(shí)現(xiàn)了redisson分布式鎖的使用。
到此這篇關(guān)于基于Redisson實(shí)現(xiàn)注解式分布式鎖的示例代碼的文章就介紹到這了,更多相關(guān)Redisson分布式鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
深入dom4j使用selectSingleNode方法報(bào)錯(cuò)分析
本篇文章是對(duì)dom4j使用selectSingleNode方法報(bào)錯(cuò)進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-05-05
這篇文章主要為大家介紹了vue組件通信的幾種方法，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來(lái)幫助2022-01-01
IDEA的Web項(xiàng)目右鍵無(wú)法創(chuàng)建Servlet問(wèn)題解決辦法
這篇文章主要介紹了IDEA的Web項(xiàng)目右鍵無(wú)法創(chuàng)建Servlet問(wèn)題解決辦法的相關(guān)資料,在IDEA中新建Servlet時(shí)發(fā)現(xiàn)缺失選項(xiàng),可以通過(guò)在pom.xml文件中添加servlet依賴(lài)解決,文中通過(guò)圖文介紹的非常詳細(xì),需要的朋友可以參考下2024-10-10
這篇文章主要介紹了mybatis是如何集成到spring的,將mybatis集成到spring之后，就可以被spring的ioc容器托管，再也不用自己創(chuàng)建SqlSessionFactory?、打開(kāi)SqlSession等操作，本文結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友可以參考下2023-05-05
java基于雙向環(huán)形鏈表解決丟手帕問(wèn)題的方法示例
這篇文章主要介紹了java基于雙向環(huán)形鏈表解決丟手帕問(wèn)題的方法,簡(jiǎn)單描述了丟手帕問(wèn)題,并結(jié)合實(shí)例形式給出了Java基于雙向環(huán)形鏈表解決丟手帕問(wèn)題的步驟與相關(guān)操作技巧,需要的朋友可以參考下2017-11-11
Reactor模型主要提供了一種在Java虛擬機(jī)上構(gòu)建非阻塞應(yīng)用的方式,這種方式使用了響應(yīng)式編程原理,通過(guò)響應(yīng)式流標(biāo)準(zhǔn)來(lái)實(shí)現(xiàn),下面我們就來(lái)看看它在SpringBoot中是如何使用的吧2024-04-04
本文主要介紹了Spring容器獲取Bean的9種方式小結(jié)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-07-07
Java從ftp服務(wù)器上傳與下載文件的實(shí)現(xiàn)
這篇文章主要給大家介紹了關(guān)于Java從ftp服務(wù)器上傳與下載文件的實(shí)現(xiàn)方法,最近項(xiàng)目中需要實(shí)現(xiàn)將文件先存放到ftp上,需要的時(shí)候再?gòu)膄tp上下載,做的過(guò)程中碰到了問(wèn)題,所以這里總結(jié)下,需要的朋友可以參考下2023-08-08
java8 forEach結(jié)合Lambda表達(dá)式遍歷 List操作
這篇文章主要介紹了java8 forEach結(jié)合Lambda表達(dá)式遍歷 List操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-09-09
數(shù)組在?Java?中是一種常用的數(shù)據(jù)結(jié)構(gòu)，用于存儲(chǔ)和操作大量數(shù)據(jù)。Arrays?是我們?cè)谔幚頂?shù)組時(shí)的一把利器。它提供了豐富的方法和功能，使得數(shù)組操作變得更加簡(jiǎn)單、高效和可靠。接下來(lái)我們一起看看?Arrays?的各種功能和用法，,需要的朋友可以參考下2023-05-05