簡述
整篇文章寫的比較粗糙，大佬看了輕噴。前半部分 是整合spring boot和redisson， 后半部分是驗證分布式鎖。在整個過程中遇見了不少的問題，在此做個記錄少走彎路
redisson是官方推薦的分布式鎖實現方案，采用redis自身的原子命令和lua腳本來實現
1. 在idea中新建spring boot工程并引入所需依賴
idea中直接新建一個spring boot項目即可，再在pom.xml中引入所需依賴，依賴信息如下
<!-- redis所需 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- web頁面訪問所需 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-data-25</artifactId>
<version>3.16.4</version>
</dependency>
<!-- Redisson所需依賴 -->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
<version>3.16.4</version>
</dependency>2. 編寫相關代碼實現
采用一個票卷庫存來進行鎖的驗證,需要預先在redis里面設置一個key為ticket的信息，值為100之類的數字即可 代碼示例編寫：
@RestController
@Slf4j
public class RedisController {
// spring boot 操作redis的模板方法類
@Autowired
private StringRedisTemplate redisTemplate;
// redisson操作bean
@Resource
private Redisson redisson;
@RequestMapping("/lock")
public String deductTicket(){
String lockKey = "ticket";
// 在spring boot 2.0.6版本中整合的redisson,key和鎖不能一樣
// redis setnx 操作,此處的lockKey在后面追加1是為了避免redisson鎖時報錯, 需要和待鎖住的數據的key信息不同
RLock lock = redisson.getLock(lockKey+"1");
try {
lock.lock();
int ticketCount = Integer.parseInt(redisTemplate.opsForValue().get(lockKey));
if (ticketCount > 0) {
int realTicketCount = ticketCount - 1;
log.info("扣除成功：剩余票數：" + realTicketCount);
redisTemplate.opsForValue().set(lockKey, realTicketCount + "");
return realTicketCount + "";
} else {
log.error("扣除失敗");
return "error";
}
return "end";
} finally {
lock.unlock();
}
}
}application.yml配置信息如下
server:
port: 8899 # web服務對外端口
redis:
host: 192.168.0.160 #redis地址
database: 0 #采用的庫編號
port: 6379 #redis端口
password: 123456 #redis密碼,如果redis沒有設置密碼直接去掉該配置不寫空3. 模擬實際環境驗證
一個簡單的分布式鎖驗證的demo完成了，比較粗糙，驗證的方式有多樣的，可以采用java本身的多線程進行驗證，也可以類似實際環境部署多個節點來驗證，這里為了技術的廣度的一個應用，采用后面的方式。
3.1 下載idea的docker插件并配置相關鏡像信息
- docker插件下載
idea配置docker連接虛擬機上的docker
開啟docker遠程連接
vim /usr/lib/systemd/system/docker.service找到 ExecStart，在最后面添加 -H tcp://0.0.0.0:2375
重啟docker
systemctl daemon-reload
systemctl start docker開放端口
firewall-cmd --zone=public --add-port=2375/tcp --permanentidea配置docker連接
配置完成后可在idea中看到連接的docker鏡像、容器相關信息
3.2 將spring boot打包的jar構建為docker鏡像
編寫Dockerfile
在工程目錄中新建Dockerfile,與pom.xml文件同級
Dockerfile內容如下
FROM openjdk:8-jdk-alpine # 指定基礎鏡像為jdk8
ADD target/spring-0.0.1-SNAPSHOT.jar app.jar #將打包的jar包放入鏡像中并重命名為app.jar
ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom","-jar","/app.jar"] #啟動jar包在pom.xml中添加插件信息
<plugin>
<groupId>com.spotify</groupId>
<artifactId>docker-maven-plugin</artifactId>
<version>1.0.0</version>
<configuration>
<imageName>com.demo/${project.artifactId}</imageName>
<dockerDirectory></dockerDirectory>
<resources>
<resource>
<targetPath>/</targetPath>
<directory>${project.build.directory}</directory>
<include>${project.build.finalName}.jar</include>
</resource>
</resources>
</configuration>
</plugin>idea添加docker構建配置
此處操作的目的是為了便于在idea中直接構建鏡像啟動容器
配置信息如下
（1）Dockerfile文件位置
（2）鏡像tag
（3）構建成功后啟動的容器名稱
（4）端口映射 宿主機端口:容器內端口
jar包打好之后可直接點擊
如果沒有問題idea的docker控制臺會輸出容器內啟動相關日志信息
此處為了驗證分布式鎖，需要兩個節點以上，所以這里我手動啟動了另外一個docker容器（暫時沒有編寫shell腳本）
啟動命令如下
docker run -d --name demo2 -p 8900:8899 demo:1.1容器名稱demo2 映射到宿主機端口 8900
查看應用日志可使用 docker logs -f 容器名稱
spring boot 構建docker鏡像應該有更簡單的方式，歡迎在評論區交流補充
3.2 配置nginx
可以更改默認的日志格式如下，為了記錄代理的具體節點信息
log_format main '$remote_addr - $remote_user [$time_local] "$request" '
'$status $body_bytes_sent "$http_referer" '
'"$http_user_agent" "$http_x_forwarded_for" ' '"$upstream_addr"';配置負載均衡
upstream tomcat {
server 192.168.0.160:8899 weight=10; # 此處設置權重為相同的即可
server 192.168.0.160:8900 weight=10;
}配置代理
location / {
proxy_pass http://tomcat;
proxy_redirect default;
}完整的代理配置如下
配置完成后
nginx -s reload進行訪問驗證
192.168.0.160/lock
可查看nginx、容器內日志信息來驗證是否訪問成功
nginx如何訪問出現error，可查看nginx中的錯誤日志。如果是權限問題（# failed (13: Permission denied) while connecting to upstream） 可用root用戶啟動或使用命令 setsebool -P httpd_can_network_connect 1 來解決
3.3 下載安裝Jmeter進行測試
Jmeter下載地址：jmeter.apache.org/download_jm…
下載解壓后在bin目錄中店家jmeter.bat即可啟動jmeter
新增計劃
配置線程信息
(1) 請求線程數
(2) 多少s內啟動完線程 設置為0代表同時啟動 設置為2代表2s內啟動完20個線程，1s啟動10個線程
添加請求
(1) ip地址
(2) 端口
(3) path信息，這里設置為jar中的地址信息
點擊綠色三角箭頭啟動并進行驗證
查看redis緩存中設置的數據是否在測試完成后符合預期值，也可查看nginx中的日志來確定請求是否平均分配到了兩個節點
參考文章：
juejin.cn/post/684490…
juejin.cn/post/709110…
到此這篇關于Spring boot 整合 Redisson實現分布式鎖并驗證的文章就介紹到這了,更多相關Spring boot 分布式鎖內容請搜索html5模板網以前的文章希望大家以后多多支持html5模板網！