springboot集成redisson的三種方式
更新時間：2024年03月03日 11:21:45 作者：結局之
本文主要介紹了springboot集成redisson的三種方式,包含自定義配置+手動注入,使用Yaml方式批量讀取配置和spring boot自動配置類這三種,具有一定的參考價值,感興趣的可以了解一下
前言
本文主要描述springboot繼承redisson的幾種方式以及redisson分布式鎖的使用；
一、redisson簡介？
Redisson是架設在Redis基礎上的一個Java駐內(nèi)存數(shù)據(jù)網(wǎng)格（In-Memory Data Grid）。
Redisson在基于NIO的Netty框架上，充分的利用了Redis鍵值數(shù)據(jù)庫提供的一系列優(yōu)勢，在Java實用工具包中常用接口的基礎上，為使用者提供了一系列具有分布式特性的常用工具類。使得原本作為協(xié)調單機多線程并發(fā)程序的工具包獲得了協(xié)調分布式多機多線程并發(fā)系統(tǒng)的能力，大大降低了設計和研發(fā)大規(guī)模分布式系統(tǒng)的難度。同時結合各富特色的分布式服務，更進一步簡化了分布式環(huán)境中程序相互之間的協(xié)作。
最熟為人知的是它的分布式鎖機制,它有比redis本身更多更強勁的功能
分布式鎖原理 : 發(fā)送一段lua腳本(保證原子性)用以加鎖,其本質是搶占key,誰先生成key誰就有鎖
以后再補一篇原理
二、集成方式
redisson 集成springBoot并不是特別友好,因為它沒有像redis這樣寫自動配置類,故不能僅寫配置就能用
引入pom坐標：
<!--分布式鎖-->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.13.6</version>
</dependency>2.1自定義配置+手動注入
要點：
1.自己寫配置屬性
2.自己寫@Bean注入redisson
配置類
import com.xkj.ecommerce.utils.RedissonLockUtil;
import lombok.Data;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.SentinelServersConfig;
import org.redisson.config.SingleServerConfig;
import org.springframework.boot.autoconfigure.AutoConfigureOrder;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.Arrays;
/**
* @createDate 2021/1/18
*/
@Configuration
@ConfigurationProperties(prefix = "redisson")
@Data
@AutoConfigureOrder
public class RedissonConfig {
private int timeout = 3000;
private String address;
private String password;
private int database = 0;
private int connectionPoolSize = 64;
private int connectionMinimumIdleSize = 10;
private int slaveConnectionPoolSize = 250;
private int masterConnectionPoolSize = 250;
private String[] sentinelAddresses;
private String masterName;
public void setSentinelAddresses(String sentinelAddresses) {
this.sentinelAddresses = Arrays.stream(sentinelAddresses.split(",")).map(s -> "redis://" + s).toArray(String[]::new);
}
public void setAddress(String address) {
this.address = "redis://" + address;
}
/**
* 哨兵模式自動裝配
*/
@Bean
@ConditionalOnMissingBean(RedissonClient.class)
@ConditionalOnProperty(name = "redisson.masterName")
public RedissonLockUtil redissonSentinel() {
Config config = new Config();
SentinelServersConfig serverConfig = config.useSentinelServers().addSentinelAddress(this.getSentinelAddresses())
.setMasterName(this.getMasterName())
.setTimeout(this.getTimeout())
.setMasterConnectionPoolSize(this.getMasterConnectionPoolSize())
.setSlaveConnectionPoolSize(this.getSlaveConnectionPoolSize());
if (StringUtils.isNotBlank(this.getPassword())) {
serverConfig.setPassword(this.getPassword());
}
RedissonClient redissonClient = Redisson.create(config);
RedissonLockUtil locker = new RedissonLockUtil();
locker.setRedissonClient(redissonClient);
return locker;
}
/**
* 單機模式自動裝配
*/
@Bean
@ConditionalOnProperty(name = "redisson.address")
public RedissonLockUtil redissonSingle() {
Config config = new Config();
SingleServerConfig serverConfig = config.useSingleServer()
.setAddress(this.getAddress())
.setTimeout(this.getTimeout())
.setConnectionPoolSize(this.getConnectionPoolSize())
.setConnectionMinimumIdleSize(this.getConnectionMinimumIdleSize());
if (StringUtils.isNotBlank(this.getPassword())) {
serverConfig.setPassword(this.getPassword());
}
RedissonClient redissonClient = Redisson.create(config);
RedissonLockUtil locker = new RedissonLockUtil();
locker.setRedissonClient(redissonClient);
return locker;
}
}application.properties
redisson.timeout=3000 .... # 哨兵配置(用英文逗號隔開) # redisson.sentinelAddresses=192.168.2.100:3408,192.168.2.101:3408 # 單機配置 redisson.address=192.168.2.100:3408
2.2使用Yaml方式批量讀取配置
要點：
1.使用redisson官方提供的工具類，讀取指定配置項
配置類
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.io.IOException;
@Configuration
public class RedissonConfig {
@Bean
public RedissonClient redisson() throws IOException {
// 本例子使用的是yaml格式的配置文件，讀取使用Config.fromYAML，如果是Json文件，則使用Config.fromJSON
Config config = Config.fromYAML(RedissonConfig.class.getClassLoader().getResource("redisson-config.yml"));
return Redisson.create(config);
}
}自行注入到工具類中,參考
RedissonClient redissonClient = Redisson.create(config);
RedissonLockUtil locker = new RedissonLockUtil();
locker.setRedissonClient(redissonClient);
redisson-config.yml
2.3使用spring boot自動配置類
引入springboot-redisson坐標
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/org.redisson/redisson-spring-boot-starter -->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
<version>3.12.0</version>
</dependency>與yaml方式類似，應該屬于進階版
application.yml
# 公共的spring配置 spring.redis.database= spring.redis.host= spring.redis.port= spring.redis.password= spring.redis.ssl= spring.redis.timeout= spring.redis.cluster.nodes= spring.redis.sentinel.master= spring.redis.sentinel.nodes= # Redisson 的特殊配置 # 可以從本地的類路徑下讀取配置文件 spring.redis.redisson.config=classpath:redisson-config.yml
然后可以直接使用
@Autowired RedissonClient redissonClient;
三、工具類
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import java.util.concurrent.TimeUnit;
public class RedissonLockUtil {
private static RedissonClient redissonClient;
public void setRedissonClient(RedissonClient redissonCli) {
redissonClient = redissonCli;
}
public static RLock lock(String lockKey) {
RLock lock = redissonClient.getLock(lockKey);
lock.lock();
return lock;
}
public static RLock lock(String lockKey, int leaseTime) {
RLock lock = redissonClient.getLock(lockKey);
lock.lock(leaseTime, TimeUnit.SECONDS);
return lock;
}
public static RLock lock(String lockKey, TimeUnit unit, int timeout) {
RLock lock = redissonClient.getLock(lockKey);
lock.lock(timeout, unit);
return lock;
}
/**
* 嘗試獲得鎖,自定義 時間單位;等待時長;加鎖時長
*/
public static boolean tryLock(String lockKey, int waitTime, int leaseTime, TimeUnit unit) {
RLock lock = redissonClient.getLock(lockKey);
try {
return lock.tryLock(waitTime, leaseTime, unit);
} catch (InterruptedException e) {
return false;
}
}
/**
* 嘗試獲得鎖,自定義 等待時長;加鎖時長 (默認為秒)
*/
public static boolean tryLock(String lockKey, int waitTime, int leaseTime) {
RLock lock = redissonClient.getLock(lockKey);
try {
return lock.tryLock(waitTime, leaseTime, TimeUnit.SECONDS);
} catch (InterruptedException e) {
return false;
}
}
/**
* 嘗試獲得鎖,自定義 等待時長 (加鎖時長不限制;默認為秒)
*/
public static boolean tryLock(String lockKey, int waitTime) {
RLock lock = redissonClient.getLock(lockKey);
try {
return lock.tryLock(waitTime, TimeUnit.SECONDS);
} catch (InterruptedException e) {
return false;
}
}
/**
* 嘗試獲得鎖,自定義 等待時長 (加鎖時長不限制)
*/
public static boolean tryLock(String lockKey, int waitTime, TimeUnit unit) {
RLock lock = redissonClient.getLock(lockKey);
try {
return lock.tryLock(waitTime, unit);
} catch (InterruptedException e) {
return false;
}
}
public static void unlock(String lockKey) {
RLock lock = redissonClient.getLock(lockKey);
lock.unlock();
}
public static void unlock(RLock lock) {
lock.unlock();
}
}用的時候就可以直接 RedissonLockUtil.lock("test")
總結
(據(jù)說redisson和redisson-spring-boot-starter用的不是同一套體系,如果考慮引包的兼容性,建議用第三種方式)
到此這篇關于springboot集成redisson的三種方式的文章就介紹到這了,更多相關springboot集成redisson內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
今天小編就為大家分享一篇關于java若依框架集成redis緩存的實現(xiàn)，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2021-08-08
優(yōu)化SpringBoot程序啟動速度的實現(xiàn)
本文主要介紹了優(yōu)化SpringBoot程序啟動速度的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-01-01
Java 反轉帶頭結點的單鏈表并顯示輸出的實現(xiàn)過程
這篇文章主要介紹了Java 反轉帶頭結點的單鏈表并顯示輸出,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-11-11
這篇文章主要給大家介紹了關于如何通過一張圖搞懂springBoot自動注入原理的相關資料,文中通過圖文以及實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2022-02-02
這篇文章主要介紹了java中sleep方法和wait方法的五個區(qū)別，sleep?方法和?wait?方法都是用來將線程進入休眠狀態(tài)，但是又有一些區(qū)別，下面我們就一起來看看吧2022-05-05
這篇文章主要介紹了使用springMVC所需要的pom配置，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
springboot項目連接不上nacos配置,報‘url‘異常問題
這篇文章主要介紹了springboot項目連接不上nacos配置,報‘url‘異常問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-06-06
這篇文章主要給大家介紹了關于java中static關鍵詞的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-12-12
下面小編就為大家?guī)硪黄狫ava的基本數(shù)據(jù)類型)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2021-08-08
這篇文章主要介紹了java實現(xiàn) 二叉搜索樹功能,代碼簡單易懂，非常不錯，具有一定的參考借鑒價值，需要的朋友可以參考下2018-07-07