從官方文件翻譯並整理的，有地方可能表述不準確

1. lettuce的介紹

lettuce是一個執行緒安全的redis客戶端。提供同步，非同步和reactive（？）的 APIs.。如果可以避開阻塞和事務型的操作比如BLPOP 和MULTI/EXEC，多個執行緒可以分享同一個連線。多個連線被NIO框架netty有效的管理。

並且支援哨兵模式，叢集模式和資料模式。

他的大部分方法對正好對應redis的命令。

2. RedisURI

1. 建立

RedisURI是redis連線的一些標準資訊，比如需要提供資料庫名稱，密碼，url，超時時間等。有三種方式可以建立：

• RedisURI.create("redis://localhost/");
• RedisURI.Builder.redis("localhost", 6379).auth("password").database(1).build();
• new RedisURI("localhost", 6379, 60, TimeUnit.SECONDS);

2. uri的語法

• 單獨的redis：

redis :// [: [email protected]] host [: port] [/ database][? [timeout=timeout[d|h|m|s|ms|us|ns]] [&_database=database_]]

• 單獨的redis ssl：

rediss :// [:

• 單獨的redis unix的socket

redis-socket :// path [?[timeout=timeout[d|h|m|s|ms|us|ns]][&_database=database_]]

• redis哨兵模式

redis-sentinel :// [: [email protected]] host1[: port1] [, host2[: port2]] [, hostN[: portN]] [/ database][?[timeout=timeout[d|h|m|s|ms|us|ns]] [&_sentinelMasterId=sentinelMasterId_] [&_database=database_]]

3. 時間單位

• d 天
• h小時
• m分鐘
• s秒
• ms 毫秒
• us 微秒
• ns 納秒

4. 示例

• url和port

RedisClient client = RedisClient.create(RedisURI.create("localhost", 6379));
client.setDefaultTimeout(20, TimeUnit.SECONDS);

// …

client.shutdown();

•  builder

RedisURI redisUri = RedisURI.Builder.redis("localhost")
                                .withPassword("authentication")
                                .withDatabase(2)
                                .build();
RedisClient client = RedisClient.create(redisUri);

• ssl builder

RedisURI redisUri = RedisURI.Builder.redis("localhost")
                                .withSsl(true)
                                .withPassword("authentication")
                                .withDatabase(2)
                                .build();
RedisClient client = RedisClient.create(redisUri);

•  String RedisURI

RedisURI redisUri = RedisURI.create("redis://[email protected]/2");
RedisClient client = RedisClient.create(redisUri);

// …

client.shutdown();

3. 基本使用

• maven

<dependency>
			<groupId>biz.paluch.redis</groupId>
			<artifactId>lettuce</artifactId>
			<version>5.0.0.Beta1</version>
		</dependency>

• 建立連線

RedisClient client = RedisClient.create("redis://localhost");

StatefulRedisConnection<String, String> connect = client.connect();

• 同步方式

RedisCommands<String, String> commands = connect.sync(); 

String value = commands.get("foo");

• 非同步方式

RedisAsyncCommands<String, String> redisAsync = connect.async();
		RedisFuture<String> redisFuture = redisAsync.get("a");
		try {
			String a = redisFuture.get();
			System.out.println(a);
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (ExecutionException e) {
			e.printStackTrace();
		}

RedisFuture的get方法是阻塞方法，會一直阻塞到返回結果，可以新增超時時間 

• 關閉連線

connection.close(); 

client.shutdown(); 

4. Reactive API

懵逼ing...

5. Pub Sub

釋出訂閱的使用

6. Transactions

事務的使用

7. dynamic Redis Command Interfaces

自定義命令

8. Master Slave

主從模式的使用

9. Redis Sentinel

哨兵模式的使用

10. Redis Cluster

叢集模式的使用

11. 連線池的使用

lettuce是執行緒安全的，可以被多個執行緒同時使用，所以執行緒池不是必須的。lettuce提供了一般的連線池支援。

lettuce的連線池依賴common-pool2

<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
    <version>2.4.3</version>
</dependency>

1. 連線池的歸還兩種方式

• StatefulConnection.close()
• GenericObjectPool.returnObject(…)

2. 基本使用

RedisClient client = RedisClient.create(RedisURI.create(host, port));

GenericObjectPool<StatefulRedisConnection<String, String>> pool = ConnectionPoolSupport
               .createGenericObjectPool(() -> client.connect(), new GenericObjectPoolConfig());

// executing work
try (StatefulRedisConnection<String, String> connection = pool.borrowObject()) {

    RedisCommands<String, String> commands = connection.sync();
    commands.multi();
    commands.set("key", "value");
    commands.set("key2", "value2");
    commands.exec();
}

// terminating
pool.close();
client.shutdown();

3. 叢集使用

RedisClusterClient clusterClient = RedisClusterClient.create(RedisURI.create(host, port));

GenericObjectPool<StatefulRedisClusterConnection<String, String>> pool = ConnectionPoolSupport
               .createGenericObjectPool(() -> clusterClient.connect(), new GenericObjectPoolConfig());

// execute work
try (StatefulRedisClusterConnection<String, String> connection = pool.borrowObject()) {
    connection.sync().set("key", "value");
    connection.sync().blpop(10, "list");
}

// terminating
pool.close();
clusterClient.shutdown();