個人中心
退出
redis java客戶端那么多，該選擇哪一個
我們在使用springboot搭建微服務(wù)的時候，在很多時候還是需要redis的高速緩存來緩存一些數(shù)據(jù)，存儲一些高頻率訪問的數(shù)據(jù)，如果直接使用redis的話又比較麻煩，在這里，我們使用jedis來實現(xiàn)redis緩存來達到高效緩存的目的。
但是首先，我們需要了解一下什么是jedis，jedis是redis的客戶端。以下介紹幾種常用的redis客戶端及其對比。
Jedis api 在線網(wǎng)址：
http://tool.oschina.net/uploads/apidocs/redis/clients/jedis/Jedis.html
redisson 官網(wǎng)地址：
https://redisson.org/
redisson git項目地址：
https://github.com/redisson/redisson
lettuce 官網(wǎng)地址：
https://lettuce.io/
lettuce git項目地址：
https://github.com/lettuce-io/lettuce-core
首先，在spring boot2之后，對redis連接的支持，默認就采用了lettuce。這就一定程度說明了lettuce 和Jedis的優(yōu)劣。
概念：
Jedis：是老牌的Redis的Java實現(xiàn)客戶端，提供了比較全面的Redis命令的支持，
Redisson：實現(xiàn)了分布式和可擴展的Java數(shù)據(jù)結(jié)構(gòu)。
Lettuce：高級Redis客戶端，用于線程安全同步，異步和響應(yīng)使用，支持集群，Sentinel，管道和編碼器。
優(yōu)點：
Jedis：是老牌的Redis的Java實現(xiàn)客戶端，提供了比較全面的Redis命令的支持，
Redisson：實現(xiàn)了分布式和可擴展的Java數(shù)據(jù)結(jié)構(gòu)。
Lettuce：高級Redis客戶端，用于線程安全同步，異步和響應(yīng)使用，支持集群，Sentinel，管道和編碼器。
可伸縮：
Jedis：使用阻塞的I/O，且其方法調(diào)用都是同步的，程序流需要等到sockets處理完I/O才能執(zhí)行，不支持異步。Jedis客戶端實例不是線程安全的，所以需要通過連接池來使用Jedis。
Redisson：基于Netty框架的事件驅(qū)動的通信層，其方法調(diào)用是異步的。Redisson的API是線程安全的，所以可以操作單個Redisson連接來完成各種操作
Lettuce：基于Netty框架的事件驅(qū)動的通信層，其方法調(diào)用是異步的。Lettuce的API是線程安全的，所以可以操作單個Lettuce連接來完成各種操作
lettuce能夠支持redis4，需要java8及以上。
lettuce是基于netty實現(xiàn)的與redis進行同步和異步的通信。
lettuce和jedis比較
jedis使直接連接redis server,如果在多線程環(huán)境下是非線程安全的，這個時候只有使用連接池，為每個jedis實例增加物理連接 ；
lettuce的連接是基于Netty的，連接實例（StatefulRedisConnection）可以在多個線程間并發(fā)訪問，StatefulRedisConnection是線程安全的，所以一個連接實例可以滿足多線程環(huán)境下的并發(fā)訪問，當然這也是可伸縮的設(shè)計，一個連接實例不夠的情況也可以按需增加連接實例。
Redisson實現(xiàn)了分布式和可擴展的Java數(shù)據(jù)結(jié)構(gòu)，和Jedis相比，功能較為簡單，不支持字符串操作，不支持排序、事務(wù)、管道、分區(qū)等Redis特性。Redisson的宗旨是促進使用者對Redis的關(guān)注分離，從而讓使用者能夠?qū)⒕Ω械胤旁谔幚順I(yè)務(wù)邏輯上。
總結(jié)：
優(yōu)先使用Lettuce，如果需要分布式鎖，分布式集合等分布式的高級特性，添加Redisson結(jié)合使用，因為Redisson本身對字符串的操作支持很差。
在一些高并發(fā)的場景中，比如秒殺，搶票，搶購這些場景，都存在對核心資源，商品庫存的爭奪，控制不好，庫存數(shù)量可能被減少到負數(shù)，出現(xiàn)超賣的情況，或者 產(chǎn)生唯一的一個遞增ID，由于web應(yīng)用部署在多個機器上，簡單的同步加鎖是無法實現(xiàn)的，給數(shù)據(jù)庫加鎖的話，對于高并發(fā)，1000/s的并發(fā)，數(shù)據(jù)庫可能由行鎖變成表鎖，性能下降會厲害。那相對而言，redis的分布式鎖，相對而言，是個很好的選擇，redis官方推薦使用的Redisson就提供了分布式鎖和相關(guān)服務(wù)。
SpringBoot整合Jedis
引入Jedis依賴
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>
因為 SpringBoot 內(nèi)默認引用了jedis版本,所以我們直接引入jedis 依賴無需在配置 jedis的版本號了。
application.yml
spring:
redis:
port: 6379 #端口號
password: 123456 #輸入redis數(shù)據(jù)庫密碼
host: #輸入ip地址
jedis:
pool:
max-idle: 6 #最大空閑數(shù)
max-active: 10 #最大連接數(shù)
min-idle: 2 #最小空閑數(shù)
timeout: 2000 #連接超時
編寫Config
創(chuàng)建類：com.wpc.config.jedis.JedisConfig
package com.wpc.config.jedis;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* @ClassName JedisConfig
* @Description TODO
* @Author admin
* @Version 1.0
*/
@Configuration
public class JedisConfig {
private Logger logger = LoggerFactory.getLogger(JedisConfig.class);
@Value("${spring.redis.host}")
private String host;
@Value("${spring.redis.port}")
private int port;
@Value("${spring.redis.password}")
private String password;
@Value("${spring.redis.timeout}")
private int timeout;
@Value("${spring.redis.jedis.pool.max-active}")
private int maxActive;
@Value("${spring.redis.jedis.pool.max-idle}")
private int maxIdle;
@Value("${spring.redis.jedis.pool.min-idle}")
private int minIdle;
@Bean
public JedisPool jedisPool(){
JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
jedisPoolConfig.setMaxIdle(maxIdle);
jedisPoolConfig.setMinIdle(minIdle);
jedisPoolConfig.setMaxTotal(maxActive);
JedisPool jedisPool=new JedisPool(jedisPoolConfig,host,port,timeout,password);
logger.info("JedisPool連接成功:"+host+"\t"+port);
return jedisPool;
}
}
測試配置
@SpringBootTest
public class JedisApplicationTests {
@Autowired
private JedisPool jedisPool;
@Test
public void contextLoads() {
System.out.println(jedisPool);
//在連接池中得到Jedis連接
Jedis jedis=jedisPool.getResource();
jedis.set("haha","你好");
jedis.set("name","wangpengcheng");
//關(guān)閉當前連接
jedis.close();
}
封裝工具類
JedisUtil
package com.wpc.config.jedis;
import org.springframework.beans.factory.annotation.Autowired;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
/**
* @ClassName JedisUtils
* @Description TODO
* @Author admin
* @Version 1.0
*/
@Component
public class JedisUtils {
@Autowired
private JedisPool jedisPool;
/**
* 獲取Jedis資源
*/
public Jedis getJedis(){
return jedisPool.getResource();
}
/**
* 釋放Jedis連接
*/
public void close(Jedis jedis){
if(jedis!=null){
jedis.close();
}
}
.......................
}
測試
Jedis操作String類型
業(yè)務(wù)JedisServiceImpl類
/**
* @ClassName JedisServiceImpl
* @Description TODO
* @Author wpc
* @Version 1.0
*/
@Service
@Log //日志的處理
public class JedisServiceImpl {
@Autowired
private JedisUtils jedisUtils;
/**
* 測試String
* 根據(jù)key 查詢value值
*/
public String getString(String key){
Jedis jedis=jedisUtils.getJedis();
String val=null;
if(!jedis.exists(key)){
val="南京";
log.info(key+"在MYSQL數(shù)據(jù)庫中進行查詢的結(jié)果是："+val);
jedis.set(key,val);
log.info(key+"存入Redis中。值是："+val);
}else{
val=jedis.get(key);
log.info(key+"是在Redis中查詢的數(shù)據(jù)。值是："+val);
}
jedisUtils.close(jedis); //釋放資源
return val;
}
}
單元測試
@SpringBootTest
public class JedisTests {
@Autowired
private JedisServiceImpl jedisService;
@Test
void t1(){
String val= jedisService.getString("name");
System.out.println(val);
}
}
Jedis操作Hash類型
業(yè)務(wù)JedisServiceImpl類
@Service
@Log
public class JedisServiceImpl {
@Autowired
private JedisUtils jedisUtils;
/**
* 測試 jedis 操作hash類型
* 根據(jù)用戶ID查詢用戶信息
* 先判斷Redis中是否存在，
* 如果不存在，數(shù)據(jù)庫中查詢。并存到Redis中
* 如果存在，直接查詢Redis 并返回
*/
public User selectBy(String id){
String key="user:id"; //根據(jù)規(guī)則生成相同規(guī)范的key
User user=new User();;
Jedis jedis=jedisUtils.getJedis();
if(!jedis.exists(key)){
//數(shù)據(jù)庫中查詢，并進行存
user.setId(id);
user.setName("JAVA");
user.setAge(20);
log.info("數(shù)據(jù)庫中查詢的用戶信息是："+user);
Map<String,String> map=new HashMap();
map.put("id",user.getId());
map.put("name",user.getName());
jedis.hset(key,map);
log.info(key+"成功存入Redis:"+user);
}
else{
Map<String,String> map= jedis.hgetAll(key);
user.setId(map.get("id"));
user.setName(map.get("name"));
log.info(key+"Redis中查詢出來的是:"+map);
}
jedisUtils.close(jedis);
return user;
}
}
單元測試
@SpringBootTest
public class JedisTests {
@Autowired
private JedisServiceImpl jedisService;
@Test
void hash(){
User user= jedisService.selectBy("101");
System.out.println(user);
}
}
作者：java知路
歡迎關(guān)注微信公眾號 ：java知路
分類導(dǎo)航