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