SpringBoot 2.0集成Redisson實現分佈式鎖（redis-cluster集羣模式 與 單機模式）

通常說起到Redis的分佈式鎖咱們更多的使用的是Redisson的分佈式鎖，Redis的官方也是建議咱們這樣去作的。Redisson點我能夠直接跳轉到Redisson的官方文檔。

 

Redisson概述

 

 

Redisson是一個在Redis的基礎上實現的Java駐內存數據網格（In-Memory Data Grid）。它不只提供了一系列的分佈式的Java經常使用對象，還提供了許多分佈式服務。其中包括(BitSet, Set, Multimap, SortedSet, Map, List, Queue, BlockingQueue, Deque, BlockingDeque, Semaphore, Lock, AtomicLong, CountDownLatch, Publish / Subscribe, Bloom filter, Remote service, Spring cache, Executor service, Live Object service, Scheduler service) Redisson提供了使用Redis的最簡單和最便捷的方法。Redisson的宗旨是促進使用者對Redis的關注分離（Separation of Concern），從而讓使用者可以將精力更集中地放在處理業務邏輯上。

關於Redisson項目的詳細介紹能夠在官方網站找到。

每一個Redis服務實例都能管理多達1TB的內存。

可以完美的在雲計算環境裏使用，而且支持AWS ElastiCache主備版，AWS ElastiCache集羣版，Azure Redis Cache和阿里雲（Aliyun）的雲數據庫Redis版

如下是Redisson的結構：

Redisson做爲獨立節點 能夠用於獨立執行其餘節點發布到分佈式執行服務 和 分佈式調度任務服務 裏的遠程任務。

 

 

若是你如今正在使用其餘的Redis的Java客戶端，那麼Redis命令和Redisson對象匹配列表 可以幫助你輕鬆的將現有代碼遷徙到Redisson框架裏來。

Redisson底層採用的是Netty 框架。支持Redis 2.8以上版本，支持Java1.6+以上版本。

一、引入Maven依賴

<!-- https://mvnrepository.com/artifact/org.redisson/redisson -->
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.12.2</version>
</dependency>

 

二、配置redis信息

單機模式

spring: redis: port: 6379 host: 127.0.0.1 password: ****** database: 0 timeout: 2000

 

集成模式：

spring: redis: cluster: nodes: "192.168.1.11:7000,192.168.1.12:7000,192.168.1.12:7001" password: ****** lettuce: pool: max-active: 1500 max-wait: 5000 max-idle: 500 min-idle: 100 shutdown-timeout: 1000 timeout: 60000

三、增長一個RedisConfigProperties用於讀取配置文件信息

單機模式

/** * redisson 配置類 * Created on 2018/6/19 */ @Configuration public class RedissonConfig { @Value("${spring.redis.host}") private String host;
 @Value("${spring.redis.port}") private String port;
 @Value("${spring.redis.password}") private String password; @Bean public RedissonClient getRedisson(){ Config config = new Config(); config.useSingleServer().setAddress("redis://" + host + ":" + port).setPassword(password); //添加主從配置 // config.useMasterSlaveServers().setMasterAddress("").setPassword("").addSlaveAddress(new String[]{"",""});
        return Redisson.create(config); } }

 

集成模式

@Component @ConfigurationProperties(prefix = "spring.redis") public class RedisConfigProperties { private String password; private cluster cluster; public static class cluster { private List<String> nodes; public List<String> getNodes() { return nodes; } public void setNodes(List<String> nodes) { this.nodes = nodes; } } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public RedisConfigProperties.cluster getCluster() { return cluster; } public void setCluster(RedisConfigProperties.cluster cluster) { this.cluster = cluster; } }

 

@Configuration public class RedissonConfig { @Autowired private RedisConfigProperties redisConfigProperties; @Bean public RedissonClient redissonClient() { //redisson版本是3.5，集羣的ip前面要加上「redis://」，否則會報錯，3.2版本可不加
        List<String> clusterNodes = new ArrayList<>(); for (int i = 0; i < redisConfigProperties.getCluster().getNodes().size(); i++) { clusterNodes.add("redis://" + redisConfigProperties.getCluster().getNodes().get(i)); } Config config = new Config(); // 添加集羣地址
        ClusterServersConfig clusterServersConfig = config.useClusterServers().addNodeAddress(clusterNodes.toArray(new String[clusterNodes.size()])); // 設置密碼
 clusterServersConfig.setPassword(redisConfigProperties.getPassword()); RedissonClient redissonClient = Redisson.create(config); return redissonClient; } }

 

四、測試調用

@RestController @RequestMapping("") public class RedisLockController { private static String product1Count = "product1Count";//商品1的數量key
    private static String lockKey = "testLockKey";//分佈式鎖的key
 @Autowired private StringRedisTemplate redisTemplate; @Autowired private Redisson redisson; /** * 初始化設置商品數量 * * @return
     */ @RequestMapping("/setProductCount") public String setValue() { redisTemplate.opsForValue().set(product1Count, "100"); return "success"; } /** * 模擬秒殺搶購，併發多個請求過來，查看是否出現超賣 * * @return
     */ @RequestMapping("/spike") public String spike() { String flag = "success"; RLock lock = redisson.getLock(lockKey); try { //lock.lockAsync(5 , TimeUnit.SECONDS); //lock.lock(5, TimeUnit.SECONDS); //設置60秒自動釋放鎖 （默認是30秒自動過時）
            Future<Boolean> res = lock.tryLockAsync(100, 5, TimeUnit.SECONDS); boolean result = res.get(); System.out.println("result:" + result); if (result) { int stock = Integer.parseInt(redisTemplate.opsForValue().get(product1Count).toString()); if (stock > 0) { redisTemplate.opsForValue().set(product1Count, (stock - 1) + ""); } else { flag = "fail"; } } } catch (Exception e) { e.printStackTrace(); } finally { lock.unlock(); //釋放鎖
 } return flag; } }

 

 

其實Redisson還有其餘好多的方法來解決如今互聯網中的好多問題，你們若是想了解更多的東西，能夠去Redisson官網。

Redisson官網：https://redisson.org/

 參考：

https://www.cnblogs.com/milicool/p/9201271.html

https://www.cnblogs.com/zengnansheng/p/11426996.html

https://www.jianshu.com/p/3f3c3c733f32