Lettuce是一個(gè)高性能基于Java編寫的Redis驅(qū)動(dòng)框架，底層集成了Project Reactor提供天然的反應(yīng)式編程，通信框架集成了Netty使用了非阻塞IO，5.x版本之后融合了JDK1.8的異步編程特性，在保證高性能的同時(shí)提供了十分豐富易用的API，5.1版本的新特性如下：

支持Redis的新增命令ZPOPMIN, ZPOPMAX, BZPOPMIN, BZPOPMAX。 支持通過Brave模塊跟蹤Redis命令執(zhí)行。 支持Redis Streams。 支持異步的主從連接。 支持異步連接池。 新增命令最多執(zhí)行一次模式（禁止自動(dòng)重連）。 全局命令超時(shí)設(shè)置（對(duì)異步和反應(yīng)式命令也有效）。 ......等等

注意一點(diǎn)：Redis的版本至少需要2.6，當(dāng)然越高越好，API的兼容性比較強(qiáng)大。

引入依賴項(xiàng)：

<dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId><version>5.3.4.RELEASE</version></dependency>

一、連接Redis

單機(jī)、哨兵、集群模式下連接Redis需要一個(gè)統(tǒng)一的標(biāo)準(zhǔn)去表示連接的細(xì)節(jié)信息，在Lettuce中這個(gè)統(tǒng)一的標(biāo)準(zhǔn)是RedisURI。可以通過三種方式構(gòu)造一個(gè)RedisURI實(shí)例：

定制的字符串URI語法：

RedisURI uri = RedisURI.create('redis://localhost/');

使用建造器（RedisURI.Builder）：

RedisURI uri = RedisURI.builder().withHost('localhost').withPort(6379).build();

直接通過構(gòu)造函數(shù)實(shí)例化：

RedisURI uri = new RedisURI('localhost', 6379, 60, TimeUnit.SECONDS);

二、基本使用

Lettuce使用的時(shí)候依賴于四個(gè)主要組件：

RedisURI：連接信息。 RedisClient：Redis客戶端，特殊地，集群連接有一個(gè)定制的RedisClusterClient。 Connection：Redis連接，主要是StatefulConnection或者StatefulRedisConnection的子類，連接的類型主要由連接的具體方式（單機(jī)、哨兵、集群、訂閱發(fā)布等等）選定，比較重要。 RedisCommands：Redis命令A(yù)PI接口，基本上覆蓋了Redis發(fā)行版本的所有命令，提供了同步（sync）、異步（async）、反應(yīng)式（reative）的調(diào)用方式，對(duì)于使用者而言，會(huì)經(jīng)常跟RedisCommands系列接口打交道。

一個(gè)基本使用例子如下：

RedisURI redisUri = RedisURI.builder() // <1> 創(chuàng)建單機(jī)連接的連接信息 .withHost('localhost') .withPort(6379) .withTimeout(Duration.of(10, ChronoUnit.SECONDS)) .build();RedisClient redisClient = RedisClient.create(redisUri); // <2> 創(chuàng)建客戶端StatefulRedisConnection<String, String> connection = redisClient.connect(); // <3> 創(chuàng)建線程安全的連接RedisCommands<String, String> redisCommands = connection.sync();// <4> 創(chuàng)建同步命令SetArgs setArgs = SetArgs.Builder.nx().ex(5);String result = redisCommands.set('name', 'throwable', setArgs);result = redisCommands.get('name');System.out.println(result);// ... 其他操作connection.close(); // <5> 關(guān)閉連接redisClient.shutdown(); // <6> 關(guān)閉客戶端

關(guān)閉連接一般在應(yīng)用程序停止之前操作，一個(gè)應(yīng)用程序中的一個(gè)Redis驅(qū)動(dòng)實(shí)例不需要太多的連接（一般情況下只需要一個(gè)連接實(shí)例就可以，如果有多個(gè)連接的需要可以考慮使用連接池，其實(shí)Redis目前處理命令的模塊是單線程，在客戶端多個(gè)連接多線程調(diào)用理論上沒有效果）。

關(guān)閉客戶端一般應(yīng)用程序停止之前操作，如果條件允許的話，基于后開先閉原則，客戶端關(guān)閉應(yīng)該在連接關(guān)閉之后操作。

三、Lettuce API

同步（sync）：RedisCommands。 異步（async）：RedisAsyncCommands。 反應(yīng)式（reactive）：RedisReactiveCommands。

RedisURI redisUri = RedisURI.builder() .withHost('localhost') .withPort(6379) .withTimeout(Duration.of(10, ChronoUnit.SECONDS)) .build();RedisClient client = RedisClient.create(redisUri);StatefulRedisConnection<String, String> connection = client.connect();

Redis命令A(yù)PI的具體實(shí)現(xiàn)可以直接從StatefulRedisConnection實(shí)例獲取，見其接口定義：

public interface StatefulRedisConnection<K, V> extends StatefulConnection<K, V> { boolean isMulti(); RedisCommands<K, V> sync(); RedisAsyncCommands<K, V> async(); RedisReactiveCommands<K, V> reactive();}

值得注意的是，在不指定編碼解碼器RedisCodec的前提下，RedisClient創(chuàng)建的StatefulRedisConnection實(shí)例一般是泛型實(shí)例StatefulRedisConnection<String,String>，也就是所有命令A(yù)PI的KEY和VALUE都是String類型，這種使用方式能滿足大部分的使用場(chǎng)景。當(dāng)然，必要的時(shí)候可以定制編碼解碼器RedisCodec<K,V>。

同步API

先構(gòu)建RedisCommands實(shí)例

RedisCommands<String, String> redisCommands= connection.sync();String pong = redisCommands.ping();// 返回PONGSystem.out.println('pong：' + pong);

SetArgs setArgs = SetArgs.Builder.nx().ex(5);redisCommands.set('name', 'throwable', setArgs);String value = redisCommands.get('name');System.out.println('name:' + value);

同步API在所有命令調(diào)用之后會(huì)立即返回結(jié)果。如果熟悉Jedis的話，RedisCommands的用法其實(shí)和它相差不大。

異步API

先構(gòu)建RedisAsyncCommands實(shí)例：

RedisAsyncCommands<String, String> redisCommands = connection.async();

基本使用：

RedisAsyncCommands<String, String> redisCommands = connection.async();RedisFuture<String> redisFuture = redisCommands.ping();// 返回PONGSystem.out.println('pong：' + redisFuture.get());

SetArgs setArgs = SetArgs.Builder.nx().ex(5);RedisFuture<String> future = redisCommands.set('name', 'throwable', setArgs);System.out.println('name:' + future.get());

RedisAsyncCommands所有方法執(zhí)行返回結(jié)果都是RedisFuture實(shí)例，而RedisFuture接口的定義如下：

public interface RedisFuture<V> extends CompletionStage<V>, Future<V> { String getError(); boolean await(long timeout, TimeUnit unit) throws InterruptedException;}

也就是，RedisFuture可以無縫使用Future或者JDK1.8中引入的CompletableFuture提供的方法。

反應(yīng)式API

Lettuce引入的反應(yīng)式編程框架是Project Reactor，如果沒有反應(yīng)式編程經(jīng)驗(yàn)可以先自行了解一下Project Reactor。

構(gòu)建RedisReactiveCommands實(shí)例：

RedisReactiveCommands<String, String> redisCommands = connection.reactive();

根據(jù)Project Reactor，RedisReactiveCommands的方法如果返回的結(jié)果只包含0或1個(gè)元素，那么返回值類型是Mono，如果返回的結(jié)果包含0到N（N大于0）個(gè)元素，那么返回值是Flux。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。