式 API 實戰(zhàn)指南)
數(shù)據(jù)庫后端緩存【免費(fèi)下載鏈接】lettuce-coreRedis Java client項目地址https://gitcode.com/gh_mirrors/le/lettuce-core點擊查看免費(fèi)下載Lettuce 是一個可擴(kuò)展、線程安全的 Java Redis 客戶端同時支持同步synchronous、異步asynchronous與響應(yīng)式reactive三種執(zhí)行模型底層基于 Netty 構(gòu)建并原生支持 Sentinel、Cluster、Pipelining、自動重連及 Redis 數(shù)據(jù)模型等高級特性。閱讀本文后你將能夠完成 Lettuce 的依賴引入、連接創(chuàng)建與基礎(chǔ)命令調(diào)用掌握同步/異步/響應(yīng)式三種 API 的核心用法與差異并了解 Pub/Sub、RedisURI 連接配置以及如何從源碼構(gòu)建測試該項目。項目概覽一個連接三種執(zhí)行模型Lettuce 的核心設(shè)計理念是可擴(kuò)展且線程安全。官方文檔與 RedisClient 類源碼 均明確指出多個線程可以共享同一條連接前提是這些線程避免阻塞型操作如BLPOP和事務(wù)型操作如MULTI/EXEC。從 pom.xml 可以看到本項目當(dāng)前版本為7.9.0-SNAPSHOT底層依賴 Netty4.2.17.Final與 Reactor3.8.7這也是其能夠同時提供阻塞式調(diào)用和響應(yīng)式流Reactive Streams支持的基礎(chǔ)。Lettuce 支持的核心能力包括同步、異步、響應(yīng)式三種 API同一連接上通過sync()、async()、reactive()三個訪問器切換執(zhí)行模型互不沖突高可用方案Redis Sentinel、Redis Cluster連接安全與形態(tài)SSL / TLS、Unix Domain Socket流式 APIStreaming API以回調(diào)方式逐條消費(fèi)大數(shù)據(jù)量結(jié)果編解碼器Codecs自定義 key/value 的 UTF-8、二進(jìn)制、JSON 等序列化表示動態(tài)命令接口Command Interfaces以類型安全的方式聲明式調(diào)用 Redis 命令原生傳輸Native TransportsEpoll、Kqueue 等Redis 模塊支持RediSearch、RedisJSON、Redis Vector Sets、Bloom Filter、TDigest、TopK、Cuckoo Filter 等兼容性兼容 Java 8以隱式自動模塊方式提供無 module descriptor。引入依賴Maven 坐標(biāo)與快照倉庫Lettuce 的正式版本發(fā)布在 Maven Central 倉庫。以 Maven 為例在pom.xml中添加如下依賴dependency groupIdio.lettuce/groupId artifactIdlettuce-core/artifactId versionx.y.z/version /dependency其中x.y.z替換為實際使用的發(fā)布版本號例如當(dāng)前源碼對應(yīng)的主線版本為7.9.0-SNAPSHOT。如果你希望使用下一個大版本的每日構(gòu)建快照可以使用 Sonatype 快照倉庫并聲明BUILD-SNAPSHOT版本dependency groupIdio.lettuce/groupId artifactIdlettuce-core/artifactId versionx.y.z.BUILD-SNAPSHOT/version /dependency repositories repository idsonatype-snapshots/id nameSonatype Snapshot Repository/name urlhttps://oss.sonatype.org/content/repositories/snapshots//url snapshots enabledtrue/enabled /snapshots /repository /repositories注意快照版本不穩(wěn)定僅建議在嘗鮮新特性或參與上游開發(fā)時使用生產(chǎn)環(huán)境請鎖定 Maven Central 上的正式發(fā)布版本。基礎(chǔ)用法同步 API 與連接生命周期Lettuce 的最基本用法只需要三步創(chuàng)建客戶端、建立連接、獲取命令 API 并執(zhí)行命令。官方 README 給出了最精簡的示例RedisClient client RedisClient.create(redis://localhost); StatefulRedisConnectionString, String connection client.connect(); RedisStringCommands sync connection.sync(); String value sync.get(key);更完整的寫法含泛型與資源釋放可以參照倉庫中的官方示例 ConnectToRedis.java// Syntax: redis://[password]host[:port][/databaseNumber] // Syntax: redis://[username:password]host[:port][/databaseNumber] RedisClient redisClient RedisClient.create(redis://passwordlocalhost:6379/0); StatefulRedisConnectionString, String connection redisClient.connect(); // 通過 sync() 獲取同步命令 API RedisStringCommandsString, String sync connection.sync(); String value sync.get(key); connection.close(); redisClient.shutdown();命令命名約定Lettuce 中每個 Redis 命令都由一個或多個方法實現(xiàn)方法名與 Redis 命令的小寫名稱完全一致。對于帶多個修飾符、會改變結(jié)果類型的復(fù)雜命令其修飾符以駝峰形式拼接到命令名中例如zrangebyscore按分?jǐn)?shù)區(qū)間返回成員zrangebyscoreWithScores同樣命令但附帶分?jǐn)?shù)返回。也就是說方法名本身既是命令名也是結(jié)果形態(tài)的說明書。連接是昂貴的資源RedisClient 的類注釋 特別提醒RedisClient是一種昂貴資源它持有 Netty 的EventLoopGroup內(nèi)部使用多個線程。因此盡量復(fù)用同一個RedisClient實例或者在多個 client 實例之間共享一個ClientResources實例連接StatefulRedisConnection是線程安全的可被多線程共享詳見 StatefulRedisConnection 接口。自動重連機(jī)制StatefulRedisConnection內(nèi)部有一個ConnectionWatchdog監(jiān)控每條連接在close()被調(diào)用之前會自動重連所有尚未完成的命令在重連成功后會重新發(fā)送。這正是 Lettuce 在故障場景下保持高可用的底層保障。異步 APIRedisFuture 與 LettuceFutures異步 API 通過connection.async()獲得每個命令立即返回一個RedisFutureT繼承自 JDK 的CompletionStage可以組合、編排而不會阻塞調(diào)用線程StatefulRedisConnectionString, String connection client.connect(); RedisStringAsyncCommandsString, String async connection.async(); RedisFutureString set async.set(key, value); RedisFutureString get async.get(key); // 等待多個 future 全部完成 LettuceFutures.awaitAll(set, get) true set.get() OK get.get() valueLettuceFutures 工具類LettuceFutures是異步編程的配套工具源碼位于 LettuceFutures.java提供兩個關(guān)鍵方法awaitAll(Duration timeout, Future?... futures)/awaitAll(long timeout, TimeUnit unit, Future?... futures)等待所有 future 在超時前完成若全部按時完成返回true否則返回false。超時時不會取消命令。awaitOrCancel(RedisFutureT cmd, long timeout, TimeUnit unit)等待單個命令完成超時則取消命令。倉庫測試代碼中也實際使用了該工具例如 RediSearchIntegrationTests.java 中的批量等待assertThat(LettuceFutures.awaitAll(Duration.ofSeconds(60), futures.toArray(new RedisFuture[0]))).isTrue();與Future.get()直接阻塞不同異步 API 的價值在于可以在等待 I/O 的同時做其他工作或?qū)⒍鄠€命令的結(jié)果通過thenApply、thenCombine等CompletionStage操作組合起來。詳細(xì)的異步編程指南見 異步 API 文檔。響應(yīng)式 APIMono 與 Flux響應(yīng)式 API 通過connection.reactive()獲得基于 Reactor 的MonoT單個結(jié)果與FluxT流式多個結(jié)果StatefulRedisConnectionString, String connection client.connect(); RedisStringReactiveCommandsString, String reactive connection.reactive(); MonoString set reactive.set(key, value); MonoString get reactive.get(key); set.subscribe(); get.block() value響應(yīng)式模型的核心特征是背壓backpressure與訂閱即執(zhí)行MonoString set的創(chuàng)建并不立即發(fā)送命令只有subscribe()后命令才會真正執(zhí)行。在真實應(yīng)用中更推薦使用map、flatMap、zip等操作符組合多個命令并將最終結(jié)果交給上層訂閱者消費(fèi)。需要留意的是從 StatefulRedisConnection 的源碼注釋可知reactive()訪問器自 7.8 起已被標(biāo)記為Deprecated計劃在未來大版本中由commands(CommandsFactory)配合RedisReactiveCommands#factory()取代在 Lettuce 7.x 中它仍可正常使用。響應(yīng)式編程的完整講解見 響應(yīng)式 API 文檔。Pub/Sub 發(fā)布訂閱Lettuce 通過獨立的 Pub/Sub 連接提供發(fā)布訂閱能力。與普通連接不同Pub/Sub 連接需要先注冊監(jiān)聽器Listener再訂閱頻道消息到達(dá)時由監(jiān)聽器回調(diào)RedisPubSubCommandsString, String connection client.connectPubSub().sync(); connection.getStatefulConnection().addListener(new RedisPubSubListenerString, String() { // 實現(xiàn) message / subscribed / unsubscribed 等回調(diào) }); connection.subscribe(channel);監(jiān)聽器回調(diào)接口RedisPubSubListener 定義了以下核心回調(diào)message(K channel, V message)收到普通頻道消息message(K pattern, K channel, V message)收到模式pattern匹配的消息subscribed(K channel, long count)/psubscribed(K pattern, long count)訂閱成功count 為當(dāng)前訂閱總數(shù)unsubscribed(K channel, long count)/punsubscribed(K pattern, long count)退訂成功ssubscribed/sunsubscribed自 6.4 起新增的 Shard Channel 訂閱/退訂回調(diào)默認(rèn)委托給subscribed/unsubscribed。訂閱命令RedisPubSubCommands 接口 提供的訂閱命令與 Redis 一一對應(yīng)方法對應(yīng) Redis 命令說明subscribe(K... channels)SUBSCRIBE訂閱指定頻道unsubscribe(K... channels)UNSUBSCRIBE退訂指定頻道psubscribe(K... patterns)PSUBSCRIBE訂閱匹配模式的頻道punsubscribe(K... patterns)PUNSUBSCRIBE退訂匹配模式的頻道ssubscribe(K... shardChannels)SSUBSCRIBE訂閱 Shard 頻道6.4sunsubscribe(K... shardChannels)SUNSUBSCRIBE退訂 Shard 頻道6.4連接配置RedisURI 的創(chuàng)建與語法無論是 Standalone、Sentinel 還是 Cluster連接細(xì)節(jié)的統(tǒng)一載體都是RedisURI源碼見 RedisURI.java它可以在其中攜帶數(shù)據(jù)庫編號、客戶端名、密碼和超時等配置。RedisURI有三種創(chuàng)建方式// 1. 使用 URI 字符串 RedisURI.create(redis://localhost/); // 2. 使用 Builder RedisURI.Builder.redis(localhost, 6379).withPassword(password).withDatabase(1).build(); // 3. 直接構(gòu)造實例 RedisURI uri new RedisURI(localhost, 6379, Duration.ofSeconds(60)); // 或 RedisURI uri new RedisURI(); uri.setHost(localhost);URI 語法RedisURI支持 Standalone、SSL、Unix Domain Socket、Sentinel 等多種連接形態(tài)其 URI 語法由源碼注釋明確定義Redis Standaloneredis://[[username:]password]host[:port][/database] [?[timeouttimeout[d|h|m|s|ms|us|ns]][databasedatabase] [clientNameclientName][libraryNamelibraryName][libraryVersionlibraryVersion] [verifyPeerNONE|CA|FULL]]Redis StandaloneSSL使用rediss://前綴語法同上。Redis StandaloneUnix Domain Socketredis-socket://[[username:]password]path [?[timeout...][databasedatabase][clientNameclientName]...]Redis Sentinelredis-sentinel://[[username:]password]host1[:port1][,host2[:port2]][,hostN[:portN]][/database] [?[timeout...][sentinelMasterIdsentinelMasterId][databasedatabase]...]支持的 Scheme 一覽Scheme用途redisRedis StandaloneredissRedis Standalone SSLredis-socketRedis Standalone Unix Domain Socketredis-sentinelRedis Sentinelrediss-sentinelRedis Sentinel SSL源碼中同時保留了redisssl、redistls等別名 Scheme 常量。超時單位URI 中的timeout參數(shù)支持多種時間單位后綴d天、h小時、m分鐘、s秒、ms毫秒、us微秒、ns納秒。使用要點database 優(yōu)先級查詢參數(shù)?后中的database優(yōu)先級高于路徑中的/databaseSentinel 認(rèn)證URI 中的密碼只作用于數(shù)據(jù)節(jié)點Sentinel 節(jié)點的認(rèn)證需要對每個哨兵節(jié)點單獨配置用戶名Redis 6 起才支持用戶名庫名與庫版本在 Redis 7.2 上會自動設(shè)置libraryName/libraryVersion默認(rèn)取 LettuceVersion 中的版本信息。高級能力速覽Redis Cluster 與 Sentinel集群場景使用RedisClusterClient源碼同樣提供同步/異步/響應(yīng)式 API。集群客戶端按命令首個 key 計算槽位并路由到對應(yīng)節(jié)點維護(hù)集群分區(qū)視圖。倉庫官方示例 ConnectToRedisCluster.java 展示了基本連接方式。需要說明的是集群連接上不建議使用MULTI/EXEC/DISCARD等無 key 的事務(wù)命令——它們無法被分配到特定節(jié)點。Sentinel / 主從高可用場景參見 ha-sharding.md。流式 APIStreaming API對于結(jié)果集巨大的命令如SCAN、HGETALL的大批量數(shù)據(jù)Lettuce 提供StreamingChannel回調(diào)接口使數(shù)據(jù)以流的方式逐條輸出避免一次性在內(nèi)存中堆積。詳見 streaming-api.md。Codecs 編解碼器通過client.connect(RedisCodec)可傳入自定義編解碼器控制 key/value 在 UTF-8、二進(jìn)制、JSON 等表示形式之間的轉(zhuǎn)換。內(nèi)置StringCodec、ByteArrayCodec、CompressionCodec、CipherCodec等見 codec 包。Codecs 的接入方式詳見 integration-extension.md。動態(tài)命令接口Command Interfaces除 190 條內(nèi)置命令外Lettuce 還允許你通過聲明接口來自定義類型安全的命令調(diào)用減少樣板代碼。核心是Commands標(biāo)記接口例如public interface KeyCommands extends Commands { String get(String key); String set(String key, String value); String set(String key, byte[] value); }接口中方法名即命令名、參數(shù)即命令參數(shù)、返回類型即結(jié)果形態(tài)。完整的聲明式調(diào)用機(jī)制見 redis-command-interfaces.md。原生傳輸與 Redis 模塊Epoll / Kqueue 原生傳輸可在 Linux/macOS 上獲得更好的性能見 native-transports.md模塊支持RediSearchredis-search.md、RedisJSONredis-json.md、Vector Setsvector-sets.md等相應(yīng)命令構(gòu)建器位于 search、json、vector 包下。從源碼構(gòu)建與測試Lettuce 使用 Apache Maven 構(gòu)建。其測試需要多個運(yùn)行中的 Redis 實例實例的啟停通過倉庫根目錄的 Makefile 統(tǒng)一編排底層基于 Docker Compose測試環(huán)境定義見src/test/resources/docker-env/。當(dāng)前源碼默認(rèn)測試目標(biāo)是 Redis8.10同時支持8.12、8.8、8.6、8.4、8.2、8.0、7.4、7.2等版本見 Makefile。構(gòu)建流程如下git clone https://gitcode.com/gh_mirrors/le/lettuce-core cd lettuce-core make start # 啟動測試用 Redis 環(huán)境 make test # 運(yùn)行構(gòu)建與測試等價于 mvn -DskipITsfalse clean compile verify常用命令make test運(yùn)行完整構(gòu)建與測試make start手動啟動 Redis 測試環(huán)境make stop手動停止 Redis 測試環(huán)境make clean清理構(gòu)建產(chǎn)物。如果你已經(jīng)有本地 Redis也可以直接使用 Maven 運(yùn)行單元測試集成測試默認(rèn)通過skipITs跳過見 pom.xml。結(jié)語Lettuce 以一個線程安全連接承載三種執(zhí)行模型為核心設(shè)計覆蓋了從單機(jī)、主從、哨兵到集群的完整 Redis 部署形態(tài)并提供 Codec、流式 API、動態(tài)命令接口、模塊命令等豐富的擴(kuò)展機(jī)制。本文所述的入門路徑——引入依賴、創(chuàng)建連接、選擇sync()/async()/reactive()、按命令命名約定調(diào)用——即可支撐大部分日常開發(fā)場景。深入閱讀可繼續(xù)參考倉庫中的 connecting-redis.md、async-api.md、reactive-api.md 與 faq.md 等文檔。贊分享數(shù)據(jù)庫后端緩存【免費(fèi)下載鏈接】lettuce-coreRedis Java client項目地址https://gitcode.com/gh_mirrors/le/lettuce-core點擊查看免費(fèi)下載相關(guān)推薦Python異步Redis客戶端終極指南快速上手與實戰(zhàn)應(yīng)用Python異步Redis客戶端終極指南快速上手與實戰(zhàn)應(yīng)用 在現(xiàn)代Web開發(fā)中異步編程已經(jīng)成為提升應(yīng)用性能的關(guān)鍵技術(shù)。Python異步Redis客戶端通過結(jié)后端Lettuce-core 響應(yīng)式 API 終極指南構(gòu)建高性能異步 Redis 應(yīng)用 Lettuce core 響應(yīng)式 API 終極指南構(gòu)建高性能異步 Redis 應(yīng)用 Lettuce 是一個高級的 Java Redis 客戶端支持線程數(shù)據(jù)庫后端緩存python-binance 快速上手Binance REST API v3 同步 / 異步客戶端與 WebSocket 深度緩存實戰(zhàn)python binance 快速上手Binance REST API v3 同步 / 異步客戶端與 WebSocket 深度緩存實戰(zhàn) python bina金融科技上一篇Wand-Enhancer為WeMod用戶提供的高級本地化體驗增強(qiáng)實踐下一篇3分鐘解鎖WeMod專業(yè)版Wand-Enhancer終極免費(fèi)方案指南創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考 Lettuce 高級 Java Redis 客戶端快速上手：同步、異步與響應(yīng)式 API 實戰(zhàn)指南
數(shù)據(jù)庫后端緩存【免費(fèi)下載鏈接】lettuce-coreRedis Java client項目地址https://gitcode.com/gh_mirrors/le/lettuce-core點擊查看免費(fèi)下載Lettuce 是一個可擴(kuò)展、線程安全的 Java Redis 客戶端同時支持同步synchronous、異步asynchronous與響應(yīng)式reactive三種執(zhí)行模型底層基于 Netty 構(gòu)建并原生支持 Sentinel、Cluster、Pipelining、自動重連及 Redis 數(shù)據(jù)模型等高級特性。閱讀本文后你將能夠完成 Lettuce 的依賴引入、連接創(chuàng)建與基礎(chǔ)命令調(diào)用掌握同步/異步/響應(yīng)式三種 API 的核心用法與差異并了解 Pub/Sub、RedisURI 連接配置以及如何從源碼構(gòu)建測試該項目。項目概覽一個連接三種執(zhí)行模型Lettuce 的核心設(shè)計理念是可擴(kuò)展且線程安全。官方文檔與 RedisClient 類源碼 均明確指出多個線程可以共享同一條連接前提是這些線程避免阻塞型操作如BLPOP和事務(wù)型操作如MULTI/EXEC。從 pom.xml 可以看到本項目當(dāng)前版本為7.9.0-SNAPSHOT底層依賴 Netty4.2.17.Final與 Reactor3.8.7這也是其能夠同時提供阻塞式調(diào)用和響應(yīng)式流Reactive Streams支持的基礎(chǔ)。Lettuce 支持的核心能力包括同步、異步、響應(yīng)式三種 API同一連接上通過sync()、async()、reactive()三個訪問器切換執(zhí)行模型互不沖突高可用方案Redis Sentinel、Redis Cluster連接安全與形態(tài)SSL / TLS、Unix Domain Socket流式 APIStreaming API以回調(diào)方式逐條消費(fèi)大數(shù)據(jù)量結(jié)果編解碼器Codecs自定義 key/value 的 UTF-8、二進(jìn)制、JSON 等序列化表示動態(tài)命令接口Command Interfaces以類型安全的方式聲明式調(diào)用 Redis 命令原生傳輸Native TransportsEpoll、Kqueue 等Redis 模塊支持RediSearch、RedisJSON、Redis Vector Sets、Bloom Filter、TDigest、TopK、Cuckoo Filter 等兼容性兼容 Java 8以隱式自動模塊方式提供無 module descriptor。引入依賴Maven 坐標(biāo)與快照倉庫Lettuce 的正式版本發(fā)布在 Maven Central 倉庫。以 Maven 為例在pom.xml中添加如下依賴dependency groupIdio.lettuce/groupId artifactIdlettuce-core/artifactId versionx.y.z/version /dependency其中x.y.z替換為實際使用的發(fā)布版本號例如當(dāng)前源碼對應(yīng)的主線版本為7.9.0-SNAPSHOT。如果你希望使用下一個大版本的每日構(gòu)建快照可以使用 Sonatype 快照倉庫并聲明BUILD-SNAPSHOT版本dependency groupIdio.lettuce/groupId artifactIdlettuce-core/artifactId versionx.y.z.BUILD-SNAPSHOT/version /dependency repositories repository idsonatype-snapshots/id nameSonatype Snapshot Repository/name urlhttps://oss.sonatype.org/content/repositories/snapshots//url snapshots enabledtrue/enabled /snapshots /repository /repositories注意快照版本不穩(wěn)定僅建議在嘗鮮新特性或參與上游開發(fā)時使用生產(chǎn)環(huán)境請鎖定 Maven Central 上的正式發(fā)布版本。基礎(chǔ)用法同步 API 與連接生命周期Lettuce 的最基本用法只需要三步創(chuàng)建客戶端、建立連接、獲取命令 API 并執(zhí)行命令。官方 README 給出了最精簡的示例RedisClient client RedisClient.create(redis://localhost); StatefulRedisConnectionString, String connection client.connect(); RedisStringCommands sync connection.sync(); String value sync.get(key);更完整的寫法含泛型與資源釋放可以參照倉庫中的官方示例 ConnectToRedis.java// Syntax: redis://[password]host[:port][/databaseNumber] // Syntax: redis://[username:password]host[:port][/databaseNumber] RedisClient redisClient RedisClient.create(redis://passwordlocalhost:6379/0); StatefulRedisConnectionString, String connection redisClient.connect(); // 通過 sync() 獲取同步命令 API RedisStringCommandsString, String sync connection.sync(); String value sync.get(key); connection.close(); redisClient.shutdown();命令命名約定Lettuce 中每個 Redis 命令都由一個或多個方法實現(xiàn)方法名與 Redis 命令的小寫名稱完全一致。對于帶多個修飾符、會改變結(jié)果類型的復(fù)雜命令其修飾符以駝峰形式拼接到命令名中例如zrangebyscore按分?jǐn)?shù)區(qū)間返回成員zrangebyscoreWithScores同樣命令但附帶分?jǐn)?shù)返回。也就是說方法名本身既是命令名也是結(jié)果形態(tài)的說明書。連接是昂貴的資源RedisClient 的類注釋 特別提醒RedisClient是一種昂貴資源它持有 Netty 的EventLoopGroup內(nèi)部使用多個線程。因此盡量復(fù)用同一個RedisClient實例或者在多個 client 實例之間共享一個ClientResources實例連接StatefulRedisConnection是線程安全的可被多線程共享詳見 StatefulRedisConnection 接口。自動重連機(jī)制StatefulRedisConnection內(nèi)部有一個ConnectionWatchdog監(jiān)控每條連接在close()被調(diào)用之前會自動重連所有尚未完成的命令在重連成功后會重新發(fā)送。這正是 Lettuce 在故障場景下保持高可用的底層保障。異步 APIRedisFuture 與 LettuceFutures異步 API 通過connection.async()獲得每個命令立即返回一個RedisFutureT繼承自 JDK 的CompletionStage可以組合、編排而不會阻塞調(diào)用線程StatefulRedisConnectionString, String connection client.connect(); RedisStringAsyncCommandsString, String async connection.async(); RedisFutureString set async.set(key, value); RedisFutureString get async.get(key); // 等待多個 future 全部完成 LettuceFutures.awaitAll(set, get) true set.get() OK get.get() valueLettuceFutures 工具類LettuceFutures是異步編程的配套工具源碼位于 LettuceFutures.java提供兩個關(guān)鍵方法awaitAll(Duration timeout, Future?... futures)/awaitAll(long timeout, TimeUnit unit, Future?... futures)等待所有 future 在超時前完成若全部按時完成返回true否則返回false。超時時不會取消命令。awaitOrCancel(RedisFutureT cmd, long timeout, TimeUnit unit)等待單個命令完成超時則取消命令。倉庫測試代碼中也實際使用了該工具例如 RediSearchIntegrationTests.java 中的批量等待assertThat(LettuceFutures.awaitAll(Duration.ofSeconds(60), futures.toArray(new RedisFuture[0]))).isTrue();與Future.get()直接阻塞不同異步 API 的價值在于可以在等待 I/O 的同時做其他工作或?qū)⒍鄠€命令的結(jié)果通過thenApply、thenCombine等CompletionStage操作組合起來。詳細(xì)的異步編程指南見 異步 API 文檔。響應(yīng)式 APIMono 與 Flux響應(yīng)式 API 通過connection.reactive()獲得基于 Reactor 的MonoT單個結(jié)果與FluxT流式多個結(jié)果StatefulRedisConnectionString, String connection client.connect(); RedisStringReactiveCommandsString, String reactive connection.reactive(); MonoString set reactive.set(key, value); MonoString get reactive.get(key); set.subscribe(); get.block() value響應(yīng)式模型的核心特征是背壓backpressure與訂閱即執(zhí)行MonoString set的創(chuàng)建并不立即發(fā)送命令只有subscribe()后命令才會真正執(zhí)行。在真實應(yīng)用中更推薦使用map、flatMap、zip等操作符組合多個命令并將最終結(jié)果交給上層訂閱者消費(fèi)。需要留意的是從 StatefulRedisConnection 的源碼注釋可知reactive()訪問器自 7.8 起已被標(biāo)記為Deprecated計劃在未來大版本中由commands(CommandsFactory)配合RedisReactiveCommands#factory()取代在 Lettuce 7.x 中它仍可正常使用。響應(yīng)式編程的完整講解見 響應(yīng)式 API 文檔。Pub/Sub 發(fā)布訂閱Lettuce 通過獨立的 Pub/Sub 連接提供發(fā)布訂閱能力。與普通連接不同Pub/Sub 連接需要先注冊監(jiān)聽器Listener再訂閱頻道消息到達(dá)時由監(jiān)聽器回調(diào)RedisPubSubCommandsString, String connection client.connectPubSub().sync(); connection.getStatefulConnection().addListener(new RedisPubSubListenerString, String() { // 實現(xiàn) message / subscribed / unsubscribed 等回調(diào) }); connection.subscribe(channel);監(jiān)聽器回調(diào)接口RedisPubSubListener 定義了以下核心回調(diào)message(K channel, V message)收到普通頻道消息message(K pattern, K channel, V message)收到模式pattern匹配的消息subscribed(K channel, long count)/psubscribed(K pattern, long count)訂閱成功count 為當(dāng)前訂閱總數(shù)unsubscribed(K channel, long count)/punsubscribed(K pattern, long count)退訂成功ssubscribed/sunsubscribed自 6.4 起新增的 Shard Channel 訂閱/退訂回調(diào)默認(rèn)委托給subscribed/unsubscribed。訂閱命令RedisPubSubCommands 接口 提供的訂閱命令與 Redis 一一對應(yīng)方法對應(yīng) Redis 命令說明subscribe(K... channels)SUBSCRIBE訂閱指定頻道unsubscribe(K... channels)UNSUBSCRIBE退訂指定頻道psubscribe(K... patterns)PSUBSCRIBE訂閱匹配模式的頻道punsubscribe(K... patterns)PUNSUBSCRIBE退訂匹配模式的頻道ssubscribe(K... shardChannels)SSUBSCRIBE訂閱 Shard 頻道6.4sunsubscribe(K... shardChannels)SUNSUBSCRIBE退訂 Shard 頻道6.4連接配置RedisURI 的創(chuàng)建與語法無論是 Standalone、Sentinel 還是 Cluster連接細(xì)節(jié)的統(tǒng)一載體都是RedisURI源碼見 RedisURI.java它可以在其中攜帶數(shù)據(jù)庫編號、客戶端名、密碼和超時等配置。RedisURI有三種創(chuàng)建方式// 1. 使用 URI 字符串 RedisURI.create(redis://localhost/); // 2. 使用 Builder RedisURI.Builder.redis(localhost, 6379).withPassword(password).withDatabase(1).build(); // 3. 直接構(gòu)造實例 RedisURI uri new RedisURI(localhost, 6379, Duration.ofSeconds(60)); // 或 RedisURI uri new RedisURI(); uri.setHost(localhost);URI 語法RedisURI支持 Standalone、SSL、Unix Domain Socket、Sentinel 等多種連接形態(tài)其 URI 語法由源碼注釋明確定義Redis Standaloneredis://[[username:]password]host[:port][/database] [?[timeouttimeout[d|h|m|s|ms|us|ns]][databasedatabase] [clientNameclientName][libraryNamelibraryName][libraryVersionlibraryVersion] [verifyPeerNONE|CA|FULL]]Redis StandaloneSSL使用rediss://前綴語法同上。Redis StandaloneUnix Domain Socketredis-socket://[[username:]password]path [?[timeout...][databasedatabase][clientNameclientName]...]Redis Sentinelredis-sentinel://[[username:]password]host1[:port1][,host2[:port2]][,hostN[:portN]][/database] [?[timeout...][sentinelMasterIdsentinelMasterId][databasedatabase]...]支持的 Scheme 一覽Scheme用途redisRedis StandaloneredissRedis Standalone SSLredis-socketRedis Standalone Unix Domain Socketredis-sentinelRedis Sentinelrediss-sentinelRedis Sentinel SSL源碼中同時保留了redisssl、redistls等別名 Scheme 常量。超時單位URI 中的timeout參數(shù)支持多種時間單位后綴d天、h小時、m分鐘、s秒、ms毫秒、us微秒、ns納秒。使用要點database 優(yōu)先級查詢參數(shù)?后中的database優(yōu)先級高于路徑中的/databaseSentinel 認(rèn)證URI 中的密碼只作用于數(shù)據(jù)節(jié)點Sentinel 節(jié)點的認(rèn)證需要對每個哨兵節(jié)點單獨配置用戶名Redis 6 起才支持用戶名庫名與庫版本在 Redis 7.2 上會自動設(shè)置libraryName/libraryVersion默認(rèn)取 LettuceVersion 中的版本信息。高級能力速覽Redis Cluster 與 Sentinel集群場景使用RedisClusterClient源碼同樣提供同步/異步/響應(yīng)式 API。集群客戶端按命令首個 key 計算槽位并路由到對應(yīng)節(jié)點維護(hù)集群分區(qū)視圖。倉庫官方示例 ConnectToRedisCluster.java 展示了基本連接方式。需要說明的是集群連接上不建議使用MULTI/EXEC/DISCARD等無 key 的事務(wù)命令——它們無法被分配到特定節(jié)點。Sentinel / 主從高可用場景參見 ha-sharding.md。流式 APIStreaming API對于結(jié)果集巨大的命令如SCAN、HGETALL的大批量數(shù)據(jù)Lettuce 提供StreamingChannel回調(diào)接口使數(shù)據(jù)以流的方式逐條輸出避免一次性在內(nèi)存中堆積。詳見 streaming-api.md。Codecs 編解碼器通過client.connect(RedisCodec)可傳入自定義編解碼器控制 key/value 在 UTF-8、二進(jìn)制、JSON 等表示形式之間的轉(zhuǎn)換。內(nèi)置StringCodec、ByteArrayCodec、CompressionCodec、CipherCodec等見 codec 包。Codecs 的接入方式詳見 integration-extension.md。動態(tài)命令接口Command Interfaces除 190 條內(nèi)置命令外Lettuce 還允許你通過聲明接口來自定義類型安全的命令調(diào)用減少樣板代碼。核心是Commands標(biāo)記接口例如public interface KeyCommands extends Commands { String get(String key); String set(String key, String value); String set(String key, byte[] value); }接口中方法名即命令名、參數(shù)即命令參數(shù)、返回類型即結(jié)果形態(tài)。完整的聲明式調(diào)用機(jī)制見 redis-command-interfaces.md。原生傳輸與 Redis 模塊Epoll / Kqueue 原生傳輸可在 Linux/macOS 上獲得更好的性能見 native-transports.md模塊支持RediSearchredis-search.md、RedisJSONredis-json.md、Vector Setsvector-sets.md等相應(yīng)命令構(gòu)建器位于 search、json、vector 包下。從源碼構(gòu)建與測試Lettuce 使用 Apache Maven 構(gòu)建。其測試需要多個運(yùn)行中的 Redis 實例實例的啟停通過倉庫根目錄的 Makefile 統(tǒng)一編排底層基于 Docker Compose測試環(huán)境定義見src/test/resources/docker-env/。當(dāng)前源碼默認(rèn)測試目標(biāo)是 Redis8.10同時支持8.12、8.8、8.6、8.4、8.2、8.0、7.4、7.2等版本見 Makefile。構(gòu)建流程如下git clone https://gitcode.com/gh_mirrors/le/lettuce-core cd lettuce-core make start # 啟動測試用 Redis 環(huán)境 make test # 運(yùn)行構(gòu)建與測試等價于 mvn -DskipITsfalse clean compile verify常用命令make test運(yùn)行完整構(gòu)建與測試make start手動啟動 Redis 測試環(huán)境make stop手動停止 Redis 測試環(huán)境make clean清理構(gòu)建產(chǎn)物。如果你已經(jīng)有本地 Redis也可以直接使用 Maven 運(yùn)行單元測試集成測試默認(rèn)通過skipITs跳過見 pom.xml。結(jié)語Lettuce 以一個線程安全連接承載三種執(zhí)行模型為核心設(shè)計覆蓋了從單機(jī)、主從、哨兵到集群的完整 Redis 部署形態(tài)并提供 Codec、流式 API、動態(tài)命令接口、模塊命令等豐富的擴(kuò)展機(jī)制。本文所述的入門路徑——引入依賴、創(chuàng)建連接、選擇sync()/async()/reactive()、按命令命名約定調(diào)用——即可支撐大部分日常開發(fā)場景。深入閱讀可繼續(xù)參考倉庫中的 connecting-redis.md、async-api.md、reactive-api.md 與 faq.md 等文檔。贊分享數(shù)據(jù)庫后端緩存【免費(fèi)下載鏈接】lettuce-coreRedis Java client項目地址https://gitcode.com/gh_mirrors/le/lettuce-core點擊查看免費(fèi)下載相關(guān)推薦Python異步Redis客戶端終極指南快速上手與實戰(zhàn)應(yīng)用Python異步Redis客戶端終極指南快速上手與實戰(zhàn)應(yīng)用 在現(xiàn)代Web開發(fā)中異步編程已經(jīng)成為提升應(yīng)用性能的關(guān)鍵技術(shù)。Python異步Redis客戶端通過結(jié)后端Lettuce-core 響應(yīng)式 API 終極指南構(gòu)建高性能異步 Redis 應(yīng)用 Lettuce core 響應(yīng)式 API 終極指南構(gòu)建高性能異步 Redis 應(yīng)用 Lettuce 是一個高級的 Java Redis 客戶端支持線程數(shù)據(jù)庫后端緩存python-binance 快速上手Binance REST API v3 同步 / 異步客戶端與 WebSocket 深度緩存實戰(zhàn)python binance 快速上手Binance REST API v3 同步 / 異步客戶端與 WebSocket 深度緩存實戰(zhàn) python bina金融科技上一篇Wand-Enhancer為WeMod用戶提供的高級本地化體驗增強(qiáng)實踐下一篇3分鐘解鎖WeMod專業(yè)版Wand-Enhancer終極免費(fèi)方案指南創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考