Spring boot 整合 Redisson实现分布式锁并验证功能

  <!-- 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>

@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();
        }
    }
}

server:
  port: 8899  # web服务对外端口
  redis:
    host: 192.168.0.160 #redis地址
    database: 0 #采用的库编号
    port: 6379 #redis端口
    password: 123456 #redis密码,如果redis没有设置密码直接去掉该配置不写空

vim /usr/lib/systemd/system/docker.service

systemctl daemon-reload 
systemctl start docker

firewall-cmd --zone=public --add-port=2375/tcp --permanent

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包

<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>

docker run -d --name demo2 -p 8900:8899 demo:1.1

 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