簡(jiǎn)述
整篇文章寫的比較粗糙，大佬看了輕噴。前半部分 是整合spring boot和redisson， 后半部分是驗(yàn)證分布式鎖。在整個(gè)過程中遇見了不少的問題，在此做個(gè)記錄少走彎路
redisson是官方推薦的分布式鎖實(shí)現(xiàn)方案，采用redis自身的原子命令和lua腳本來實(shí)現(xiàn)
1. 在idea中新建spring boot工程并引入所需依賴
idea中直接新建一個(gè)spring boot項(xiàng)目即可，再在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. 編寫相關(guān)代碼實(shí)現(xiàn)
采用一個(gè)票卷庫存來進(jìn)行鎖的驗(yàn)證,需要預(yù)先在redis里面設(shè)置一個(gè)key為ticket的信息，值為100之類的數(shù)字即可 代碼示例編寫：
@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鎖時(shí)報(bào)錯(cuò), 需要和待鎖住的數(shù)據(jù)的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("扣除成功：剩余票數(shù)：" + realTicketCount);
redisTemplate.opsForValue().set(lockKey, realTicketCount + "");
return realTicketCount + "";
} else {
log.error("扣除失敗");
return "error";
}
return "end";
} finally {
lock.unlock();
}
}
}application.yml配置信息如下
server:
port: 8899 # web服務(wù)對(duì)外端口
redis:
host: 192.168.0.160 #redis地址
database: 0 #采用的庫編號(hào)
port: 6379 #redis端口
password: 123456 #redis密碼,如果redis沒有設(shè)置密碼直接去掉該配置不寫空3. 模擬實(shí)際環(huán)境驗(yàn)證
一個(gè)簡(jiǎn)單的分布式鎖驗(yàn)證的demo完成了，比較粗糙，驗(yàn)證的方式有多樣的，可以采用java本身的多線程進(jìn)行驗(yàn)證，也可以類似實(shí)際環(huán)境部署多個(gè)節(jié)點(diǎn)來驗(yàn)證，這里為了技術(shù)的廣度的一個(gè)應(yīng)用，采用后面的方式。
3.1 下載idea的docker插件并配置相關(guān)鏡像信息
- docker插件下載
idea配置docker連接虛擬機(jī)上的docker
開啟docker遠(yuǎn)程連接
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鏡像、容器相關(guān)信息
3.2 將spring boot打包的jar構(gòu)建為docker鏡像
編寫Dockerfile
在工程目錄中新建Dockerfile,與pom.xml文件同級(jí)
Dockerfile內(nèi)容如下
FROM openjdk:8-jdk-alpine # 指定基礎(chǔ)鏡像為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"] #啟動(dòng)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構(gòu)建配置
此處操作的目的是為了便于在idea中直接構(gòu)建鏡像啟動(dòng)容器
配置信息如下
（1）Dockerfile文件位置
（2）鏡像tag
（3）構(gòu)建成功后啟動(dòng)的容器名稱
（4）端口映射 宿主機(jī)端口:容器內(nèi)端口
jar包打好之后可直接點(diǎn)擊
如果沒有問題idea的docker控制臺(tái)會(huì)輸出容器內(nèi)啟動(dòng)相關(guān)日志信息
此處為了驗(yàn)證分布式鎖，需要兩個(gè)節(jié)點(diǎn)以上，所以這里我手動(dòng)啟動(dòng)了另外一個(gè)docker容器（暫時(shí)沒有編寫shell腳本）
啟動(dòng)命令如下
docker run -d --name demo2 -p 8900:8899 demo:1.1容器名稱demo2 映射到宿主機(jī)端口 8900
查看應(yīng)用日志可使用 docker logs -f 容器名稱
spring boot 構(gòu)建docker鏡像應(yīng)該有更簡(jiǎn)單的方式，歡迎在評(píng)論區(qū)交流補(bǔ)充
3.2 配置nginx
可以更改默認(rèn)的日志格式如下，為了記錄代理的具體節(jié)點(diǎn)信息
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"';配置負(fù)載均衡
upstream tomcat {
server 192.168.0.160:8899 weight=10; # 此處設(shè)置權(quán)重為相同的即可
server 192.168.0.160:8900 weight=10;
}配置代理
location / {
proxy_pass http://tomcat;
proxy_redirect default;
}完整的代理配置如下
配置完成后
nginx -s reload進(jìn)行訪問驗(yàn)證
192.168.0.160/lock
可查看nginx、容器內(nèi)日志信息來驗(yàn)證是否訪問成功
nginx如何訪問出現(xiàn)error，可查看nginx中的錯(cuò)誤日志。如果是權(quán)限問題（# failed (13: Permission denied) while connecting to upstream） 可用root用戶啟動(dòng)或使用命令 setsebool -P httpd_can_network_connect 1 來解決
3.3 下載安裝Jmeter進(jìn)行測(cè)試
Jmeter下載地址：jmeter.apache.org/download_jm…
下載解壓后在bin目錄中店家jmeter.bat即可啟動(dòng)jmeter
新增計(jì)劃
配置線程信息
(1) 請(qǐng)求線程數(shù)
(2) 多少s內(nèi)啟動(dòng)完線程 設(shè)置為0代表同時(shí)啟動(dòng) 設(shè)置為2代表2s內(nèi)啟動(dòng)完20個(gè)線程，1s啟動(dòng)10個(gè)線程
添加請(qǐng)求
(1) ip地址
(2) 端口
(3) path信息，這里設(shè)置為jar中的地址信息
點(diǎn)擊綠色三角箭頭啟動(dòng)并進(jìn)行驗(yàn)證
查看redis緩存中設(shè)置的數(shù)據(jù)是否在測(cè)試完成后符合預(yù)期值，也可查看nginx中的日志來確定請(qǐng)求是否平均分配到了兩個(gè)節(jié)點(diǎn)
參考文章：
juejin.cn/post/684490…
juejin.cn/post/709110…
到此這篇關(guān)于Spring boot 整合 Redisson實(shí)現(xiàn)分布式鎖并驗(yàn)證的文章就介紹到這了,更多相關(guān)Spring boot 分布式鎖內(nèi)容請(qǐng)搜索html5模板網(wǎng)以前的文章希望大家以后多多支持html5模板網(wǎng)！