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

spring:
  data:
    redis:
      database: 
      host:
      port:
      password:
      ssl: 
      timeout:
      connectTimeout:
      clientName:
      cluster:
        nodes:
      sentinel:
        master:
        nodes:

spring:
  redis:
    database: 
    host:
    port:
    password:
    ssl: 
    timeout:
    connectTimeout:
    clientName:
    cluster:
      nodes:
    sentinel:
      master:
      nodes:

spring:
  redis:
   redisson: 
      config: |
        clusterServersConfig:
          idleConnectionTimeout: 10000
          connectTimeout: 10000
          timeout: 3000
          retryAttempts: 3
          retryInterval: 1500
          failedSlaveReconnectionInterval: 3000
          failedSlaveCheckInterval: 60000
          password: null
          subscriptionsPerConnection: 5
          clientName: null
          loadBalancer: !<org.redisson.connection.balancer.RoundRobinLoadBalancer> {}
          subscriptionConnectionMinimumIdleSize: 1
          subscriptionConnectionPoolSize: 50
          slaveConnectionMinimumIdleSize: 24
          slaveConnectionPoolSize: 64
          masterConnectionMinimumIdleSize: 24
          masterConnectionPoolSize: 64
          readMode: "SLAVE"
          subscriptionMode: "SLAVE"
          nodeAddresses:
          - "redis://127.0.0.1:7004"
          - "redis://127.0.0.1:7001"
          - "redis://127.0.0.1:7000"
          scanInterval: 1000
          pingConnectionInterval: 0
          keepAlive: false
          tcpNoDelay: false
        threads: 16
        nettyThreads: 32
        codec: !<org.redisson.codec.Kryo5Codec> {}
        transportMode: "NIO"

import org.junit.jupiter.api.Test;
import org.redisson.api.RedissonClient;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.locks.Lock;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;

@SpringBootTest(webEnvironment = WebEnvironment.RANDOM_PORT)
public class Application {

    static final Logger logger = LoggerFactory.getLogger(DemoApplicationTests.class);

    // 注入 RedissonClient
    @Autowired
    RedissonClient redissonClient;

    // 計數(shù)器
    private int count;

    @Test
    public void LockOp throws InterruptedException {

        CountDownLatch countDownLatch = new CountDownLatch(1000);

        for (int i = 0; i < 1000; i++) {

            new Thread(() -> {

                // 每個線程都創(chuàng)建自己的鎖對象
                // 這是基于 Redis 實現(xiàn)的分布式鎖
                Lock lock = this.redissonClient.getLock("counterLock");

                try {
                    // 上鎖
                    lock.lock();

                    // 計數(shù)器自增 1
                    this.count = this.count + 1;

                } finally {
                    // 釋放鎖
                    lock.unlock();
                }
                countDownLatch.countDown();
            }).start();
        }

        countDownLatch.await();

        logger.info("count = {}", this.count);
    }

RMap<RSet<RList>, RList<RMap>> map = redisson.getMap("myMap");
RSet<RList> set = redisson.getSet("mySet");
RList<RMap> list = redisson.getList("myList");

map.put(set, list);
// 在特殊引用對象的幫助下，我們甚至可以構(gòu)建一個循環(huán)引用，這是通過普通序列化方式實現(xiàn)不了的。
set.add(list);
list.add(map);

BatchOptions options = BatchOptions.defaults()
// 指定執(zhí)行模式
//
// ExecutionMode.REDIS_READ_ATOMIC - 所有命令緩存在Redis節(jié)點中，以原子性事務(wù)的方式執(zhí)行。
//
// ExecutionMode.REDIS_WRITE_ATOMIC - 所有命令緩存在Redis節(jié)點中，以原子性事務(wù)的方式執(zhí)行。
//
// ExecutionMode.IN_MEMORY - 所有命令緩存在Redisson本機(jī)內(nèi)存中統(tǒng)一發(fā)送，但逐一執(zhí)行（非事務(wù)）。默認(rèn)模式。
//
// ExecutionMode.IN_MEMORY_ATOMIC - 所有命令緩存在Redisson本機(jī)內(nèi)存中統(tǒng)一發(fā)送，并以原子性事務(wù)的方式執(zhí)行。
//
.executionMode(ExecutionMode.IN_MEMORY)

// 告知Redis不用返回結(jié)果（可以減少網(wǎng)絡(luò)用量）
.skipResult()

// 將寫入操作同步到從節(jié)點
// 同步到2個從節(jié)點，等待時間為1秒鐘
.syncSlaves(2, 1, TimeUnit.SECONDS)

// 處理結(jié)果超時為2秒鐘
.responseTimeout(2, TimeUnit.SECONDS)

// 命令重試等待間隔時間為2秒鐘
.retryInterval(2, TimeUnit.SECONDS);

// 命令重試次數(shù)。僅適用于未發(fā)送成功的命令
.retryAttempts(4);

RBatch batch = redisson.createBatch();
batch.getMap("test").fastPutAsync("1", "2");
batch.getMap("test").fastPutAsync("2", "3");
batch.getMap("test").putAsync("2", "5");
batch.getAtomicLongAsync("counter").incrementAndGetAsync();
batch.getAtomicLongAsync("counter").incrementAndGetAsync();

BatchResult res = batch.execute();
// 或者
Future<BatchResult> asyncRes = batch.executeAsync();
List<?> response = res.getResponses();
res.getSyncedSlaves();

TransactionOptions options = TransactionOptions.defaults()
// 設(shè)置參與本次事務(wù)的主節(jié)點與其從節(jié)點同步的超時時間。
// 默認(rèn)值是5秒。
.syncSlavesTimeout(5, TimeUnit.SECONDS)

// 處理結(jié)果超時。
// 默認(rèn)值是3秒。
.responseTimeout(3, TimeUnit.SECONDS)

// 命令重試等待間隔時間。僅適用于未發(fā)送成功的命令。
// 默認(rèn)值是1.5秒。
.retryInterval(2, TimeUnit.SECONDS)

// 命令重試次數(shù)。僅適用于未發(fā)送成功的命令。
// 默認(rèn)值是3次。
.retryAttempts(3)

// 事務(wù)超時時間。如果規(guī)定時間內(nèi)沒有提交該事務(wù)則自動滾回。
// 默認(rèn)值是5秒。
.timeout(5, TimeUnit.SECONDS);

RTransaction transaction = redisson.createTransaction(TransactionOptions.defaults());

RMap<String, String> map = transaction.getMap("myMap");
map.put("1", "2");
String value = map.get("3");
RSet<String> set = transaction.getSet("mySet")
set.add(value);

try {
   transaction.commit();
} catch(TransactionException e) {
   transaction.rollback();
}

// Transaction對象可以從所有兼容JTA接口的事務(wù)管理器中獲取。
Transaction globalTransaction = transactionManager.getTransaction();

RXAResource xaResource = redisson.getXAResource();
globalTransaction.enlistResource(xaResource);

RTransaction transaction = xaResource.getTransaction();
RBucket<String> bucket = transaction.getBucket("myBucket");
bucket.set("simple");
RMap<String, String> map = transaction.getMap("myMap");
map.put("myKey", "myValue");

transactionManager.commit();