Jedis那么低性能,還在用?趕緊換上 lettuce 吧!
在與 知識星球 的球友交流中,最近有很多小伙伴在面大廠, 經(jīng)常遇到下面的問題:3大redis客戶端:Jedis、Redisson、Lettuce ,如何選型?
今天就來深入聊聊這個問題。
Redis 的3大 Java 客戶端組件
Redis 官方推薦的 Java 客戶端有Jedis、lettuce 和 Redisson。
客戶端組件1:Jedis
Jedis 是老牌的 Redis 的 Java 實現(xiàn)客戶端,提供了比較全面的 Redis 命令的支持、
Jedis 在線網(wǎng)址:http://tool.oschina.net/uploads/apidocs/redis/clients/jedis/Jedis.html
優(yōu)點:
- 支持全面的 Redis 操作特性(可以理解為API比較全面)。
缺點:
- 使用阻塞的 I/O,且其方法調(diào)用都是同步的,程序流需要等到 sockets 處理完 I/O 才能執(zhí)行,不支持異步;
- Jedis 客戶端實例不是線程安全的,所以需要通過連接池來使用 Jedis。
客戶端組件2:Redisson
Redisson 是一個在 Redis 的基礎(chǔ)上實現(xiàn)的 Java 駐內(nèi)存數(shù)據(jù)網(wǎng)格(In-Memory Data Grid)。
Redisson 提供了使用Redis 的最簡單和最便捷的方法。
它不僅提供了一系列的分布式的 Java 常用對象,還提供了許多分布式服務(wù)。
其中包括:
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 的宗旨是促進(jìn)使用者對Redis的關(guān)注分離(Separation of Concern),從而讓使用者能夠?qū)⒕Ω械胤旁谔幚順I(yè)務(wù)邏輯上。
redisson 官網(wǎng)地址:https://redisson.org/
redisson git項目地址:https://github.com/redisson/redisson
優(yōu)點:
- 使用者對 Redis 的關(guān)注分離,可以類比 Spring 框架,這些框架搭建了應(yīng)用程序的基礎(chǔ)框架和功能,提升開發(fā)效率,讓開發(fā)者有更多的時間來關(guān)注業(yè)務(wù)邏輯;
- 提供很多分布式相關(guān)操作服務(wù),例如,分布式鎖,分布式集合,可通過Redis支持延遲隊列等。
- Redisson基于Netty框架的事件驅(qū)動的通信層,其方法調(diào)用是異步的。
- Redisson的API是線程安全的,所以可以操作單個Redisson連接來完成各種操作
缺點:
- Redisson 對字符串的操作支持比較差。
客戶端組件3:lettuce
lettuce ([?let?s]),是一種可擴(kuò)展的線程安全的 Redis 客戶端,支持異步模式。
如果避免阻塞和事務(wù)操作,如BLPOP和MULTI/EXEC,多個線程就可以共享一個連接。
lettuce 底層基于 Netty,支持高級的 Redis 特性,比如哨兵,集群,管道,自動重新連接和Redis數(shù)據(jù)模型。
lettuce能夠支持redis4,需要java8及以上。
lettuce是基于netty實現(xiàn)的與redis進(jìn)行同步和異步的通信。
lettuce 官網(wǎng)地址:https://lettuce.io/
lettuce git項目地址:https://github.com/lettuce-io/lettuce-core
優(yōu)點:
- 支持同步異步通信模式;
- Lettuce 的 API 是線程安全的,如果不是執(zhí)行阻塞和事務(wù)操作,如BLPOP和MULTI/EXEC,多個線程就可以共享一個連接。
lettuce、jedis、Redisson 三者比較
jedis使直接連接redis server,如果在多線程環(huán)境下是非線程安全的,這個時候只有使用連接池,為每個jedis實例增加物理連接;
lettuce的連接是基于Netty的,連接實例(StatefulRedisConnection)可以在多個線程間并發(fā)訪問,StatefulRedisConnection是線程安全的,所以一個連接實例可以滿足多線程環(huán)境下的并發(fā)訪問,當(dāng)然這也是可伸縮的設(shè)計,一個連接實例不夠的情況也可以按需增加連接實例。
Jedis 和 lettuce 是比較純粹的 Redis 客戶端,幾乎沒提供什么高級功能。
Jedis 的性能比較差,所以如果你不需要使用 Redis 的高級功能的話,優(yōu)先推薦使用 lettuce。
Redisson實現(xiàn)了分布式和可擴(kuò)展的Java數(shù)據(jù)結(jié)構(gòu),和Jedis相比,功能較為簡單,不支持字符串操作,不支持排序、事務(wù)、管道、分區(qū)等Redis特性。
Redisson的宗旨是促進(jìn)使用者對Redis的關(guān)注分離,從而讓使用者能夠?qū)⒕Ω械胤旁谔幚順I(yè)務(wù)邏輯上。
如果需要分布式鎖,分布式集合等分布式的高級特性,添加Redisson結(jié)合使用,因為Redisson本身對字符串的操作支持很差。
Redisson 的優(yōu)勢是提供了很多開箱即用的 Redis 高級功能,如果你的應(yīng)用中需要使用到 Redis 的高級功能,建議使用 Redisson。
具體 Redisson 的高級功能可以參考:https://redisson.org/
使用建議
建議:lettuce + Redisson
在spring boot2之后,redis連接默認(rèn)就采用了lettuce。
就想 spring 的本地緩存,默認(rèn)使用Caffeine一樣,
這就一定程度說明了,lettuce 比 Jedis在性能的更加優(yōu)秀。
生產(chǎn)問題
問題1 鏈接斷裂怎么辦?
小伙伴問題1 鏈接斷裂怎么辦?
具體問題:Jedis有心跳 能保持長連接,lettuce好像沒有心跳。阿里ecs 搭的redis tcp長時間沒有傳輸 就會斷開 ,但是lettuce感知不到, 再執(zhí)行redis請求就會提示鏈接不可用
具體來說,可以通過用netty的空閑檢測機(jī)制來維持連接。
注意:是空閑檢測 不是心跳機(jī)制。
什么是心跳機(jī)制
心跳是在TCP長連接中,客戶端和服務(wù)端定時向?qū)Ψ桨l(fā)送數(shù)據(jù)包通知對方自己還在線,保證連接的有效性的一種機(jī)制。在服務(wù)器和客戶端之間一定時間內(nèi)沒有數(shù)據(jù)交互時, 即處于 idle 狀態(tài)時, 客戶端或服務(wù)器會發(fā)送一個特殊的數(shù)據(jù)包給對方, 當(dāng)接收方收到這個數(shù)據(jù)報文后, 也立即發(fā)送一個特殊的數(shù)據(jù)報文, 回應(yīng)發(fā)送方, 此即一個 PING-PONG 交互.
自然地, 當(dāng)某一端收到心跳消息后, 就知道了對方仍然在線, 這就確保 TCP 連接的有效性.
空閑檢測 是心跳的基礎(chǔ)機(jī)制。
什么是空閑檢測
就是檢測通道中的讀寫數(shù)據(jù)包,如果一段時間內(nèi),沒有收到讀寫數(shù)據(jù)包,就會出發(fā) IdleStateEvent 空閑狀態(tài)事件。
所以,可以借助這個機(jī)制,主動關(guān)閉 空閑的、被異常斷開的連接。
這就需要大家,熟悉Netty的開發(fā)和源碼,關(guān)于Netty源碼和開發(fā)的內(nèi)容,請參見《java高并發(fā)核心編程卷1加強(qiáng)版》 ,很多小伙伴,就是通過此書掌握的。
最后,奉上問題解決的參考代碼:
import io.lettuce.core.resource.ClientResources;
import io.lettuce.core.resource.NettyCustomizer;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelDuplexHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.timeout.IdleStateEvent;
import io.netty.handler.timeout.IdleStateHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ClientConfig {
@Bean
public ClientResources clientResources(){
NettyCustomizer nettyCustomizer = new NettyCustomizer() {
@Override
public void afterChannelInitialized(Channel channel) {
channel.pipeline().addLast(
//此處事件必須小于超時時間
new IdleStateHandler(40, 0, 0));
channel.pipeline().addLast(new ChannelDuplexHandler() {
@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
if (evt instanceof IdleStateEvent) {
ctx.disconnect();
}
}
});
}
@Override
public void afterBootstrapInitialized(Bootstrap bootstrap) {
}
};
//替換掉 NettyCustomizer 通道初始化處理器
return ClientResources.builder().nettyCustomizer(nettyCustomizer ).build();
}
}
寫在最后
這個組件,是一個新的組件,性能比 jedis 高太多,很多小伙伴一樣用起來了。