Redisson实现分布式锁

在Spring Cloud项目中使用Redisson实现分布式锁可以帮助你在分布式系统中安全地管理共享资源。以下是一个详细的步骤，包括配置Redisson、集成到Spring Cloud项目中，以及使用分布式锁的示例代码。

1. 添加依赖

在你的Spring Cloud项目的pom.xml文件中添加Redisson的依赖：

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.16.4</version>
</dependency>

2. 配置Redisson

在Spring Cloud项目的application.yml文件中配置Redisson：

spring:
  redis:
    host: localhost
    port: 6379

redisson:
  singleServerConfig:
    address: "redis://${spring.redis.host}:${spring.redis.port}"
    password: null
    database: 0

3. 配置Redisson客户端

创建一个Redisson配置类：

import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.spring.starter.RedissonAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RedissonConfig {

    @Bean
    public RedissonClient redissonClient() {
        Config config = new Config();
        config.useSingleServer()
              .setAddress("redis://" + spring.redis.host + ":" + spring.redis.port);
        return Redisson.create(config);
    }
}

4. 使用Redisson分布式锁

在需要使用分布式锁的地方，可以通过注入RedissonClient来获取锁并使用它。以下是一个示例：

示例服务类

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Service
public class DistributedLockService {

    @Autowired
    private RedissonClient redissonClient;

    public void executeWithLock() {
        RLock lock = redissonClient.getLock("myDistributedLock");
        boolean isLocked = false;
        try {
            // 尝试加锁，等待时间为10秒，上锁后10秒自动解锁
            isLocked = lock.tryLock(10, 10, TimeUnit.SECONDS);
            if (isLocked) {
                // 执行需要同步的操作
                System.out.println("Lock acquired, executing protected code");
                // 模拟业务逻辑处理
                Thread.sleep(5000);
            } else {
                System.out.println("Unable to acquire lock");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            if (isLocked) {
                lock.unlock();
                System.out.println("Lock released");
            }
        }
    }
}

示例控制器类

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class LockController {

    @Autowired
    private DistributedLockService distributedLockService;

    @GetMapping("/executeWithLock")
    public String executeWithLock() {
        distributedLockService.executeWithLock();
        return "Lock execution finished";
    }
}

5. 启动应用并测试

启动你的Spring Cloud应用，并访问/executeWithLock端点来测试分布式锁的使用。你可以多次访问该端点，观察锁的行为。

注意事项

1. 锁的粒度：确保合理设计锁的粒度，避免过多的锁争用和死锁。
2. 自动释放时间：确保锁的自动释放时间足够长，以覆盖最长的业务处理时间。
3. 异常处理：在获取锁和业务处理过程中，要注意异常处理，确保在异常发生时能够释放锁。
4. 高可用配置：在生产环境中，考虑使用Redis的高可用配置（如主从复制、哨兵模式、集群模式）以确保Redis服务的稳定性和可靠性。

通过以上步骤，你可以在Spring Cloud项目中使用Redisson实现分布式锁，从而在分布式环境中安全地进行资源竞争。