Redis的Java客戶端-Jedis
在Redis官網(wǎng)中提供了各種語(yǔ)言的客戶端，地址：https://redis.io/docs/clients/
其中Java客戶端也包含很多：
標(biāo)記為?的就是推薦使用的java客戶端，包括：
- Jedis和Lettuce：這兩個(gè)主要是提供了Redis命令對(duì)應(yīng)的API，方便我們操作Redis，而SpringDataRedis是對(duì)這兩種做了抽象和封裝。
- Redisson：是在Redis基礎(chǔ)上實(shí)現(xiàn)了分布式的可伸縮的java數(shù)據(jù)結(jié)構(gòu)，例如Map.Queue等，而且支持跨進(jìn)程的同步機(jī)制：Lock.Semaphore等待，比較適合用來(lái)實(shí)現(xiàn)特殊的功能需求。
Jedis快速入門
入門案例詳細(xì)步驟
案例分析：
0）創(chuàng)建工程：
1）引入依賴：
<!--jedis-->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.7.0</version>
</dependency>
<!--單元測(cè)試-->
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<version>5.7.0</version>
<scope>test</scope>
</dependency>
2）建立連接
新建一個(gè)單元測(cè)試類，內(nèi)容如下：
private Jedis jedis;
@BeforeEach
void setUp() {
// 1.建立連接
// jedis = new Jedis("192.168.150.101", 6379);
jedis = JedisConnectionFactory.getJedis();
// 2.設(shè)置密碼
jedis.auth("123321");
// 3.選擇庫(kù)
jedis.select(0);
}
3）測(cè)試：
@Test
void testString() {
// 存入數(shù)據(jù)
String result = jedis.set("name", "虎哥");
System.out.println("result = " + result);
// 獲取數(shù)據(jù)
String name = jedis.get("name");
System.out.println("name = " + name);
}
@Test
void testHash() {
// 插入hash數(shù)據(jù)
jedis.hset("user:1", "name", "Jack");
jedis.hset("user:1", "age", "21");
// 獲取
Map<String, String> map = jedis.hgetAll("user:1");
System.out.println(map);
}
4）釋放資源
@AfterEach
void tearDown() {
if (jedis != null) {
jedis.close();
}
}
Jedis連接池
Jedis本身是線程不安全的，并且頻繁的創(chuàng)建和銷毀連接會(huì)有性能損耗，因此推薦大家使用Jedis連接池代替Jedis的直連方式
有關(guān)池化思想，并不僅僅是這里會(huì)使用，很多地方都有，比如說(shuō)我們的數(shù)據(jù)庫(kù)連接池，比如我們tomcat中的線程池，這些都是池化思想的體現(xiàn)。
創(chuàng)建Jedis的連接池
public class JedisConnectionFacotry {
private static final JedisPool jedisPool;
static {
//配置連接池
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxTotal(8);
poolConfig.setMaxIdle(8);
poolConfig.setMinIdle(0);
poolConfig.setMaxWaitMillis(1000);
//創(chuàng)建連接池對(duì)象
jedisPool = new JedisPool(poolConfig,
"192.168.150.101",6379,1000,"123321");
}
public static Jedis getJedis(){
return jedisPool.getResource();
}
}
代碼說(shuō)明：
-
1） JedisConnectionFacotry：工廠設(shè)計(jì)模式是實(shí)際開發(fā)中非常常用的一種設(shè)計(jì)模式，我們可以使用工廠，去降低代的耦合，比如Spring中的Bean的創(chuàng)建，就用到了工廠設(shè)計(jì)模式
-
2）靜態(tài)代碼塊：隨著類的加載而加載，確保只能執(zhí)行一次，在加載當(dāng)前工廠類的時(shí)候，就可以執(zhí)行static的操作完成對(duì) 連接池的初始化
-
3）最后提供返回連接池中連接的方法.
改造原始代碼
代碼說(shuō)明:
1.在完成了使用工廠設(shè)計(jì)模式來(lái)完成代碼的編寫之后，獲得連接時(shí)，就可以通過(guò)工廠來(lái)獲得。
而不用直接去new對(duì)象，降低耦合，并且使用的還是連接池對(duì)象。
2.當(dāng)我們使用了連接池后，當(dāng)我們關(guān)閉連接其實(shí)并不是關(guān)閉，而是將Jedis還回連接池的。
@BeforeEach
void setUp(){
//建立連接
/*jedis = new Jedis("127.0.0.1",6379);*/
jedis = JedisConnectionFacotry.getJedis();
//選擇庫(kù)
jedis.select(0);
}
@AfterEach
void tearDown() {
if (jedis != null) {
jedis.close();
}
}
Redis的Java客戶端-SpringDataRedis
SpringData是Spring中數(shù)據(jù)操作的模塊，包含對(duì)各種數(shù)據(jù)庫(kù)的集成，其中對(duì)Redis的集成模塊就叫做SpringDataRedis，
官網(wǎng)地址：https://spring.io/projects/spring-data-redis
- 提供了對(duì)不同Redis客戶端的整合（Lettuce和Jedis）
- 提供了RedisTemplate統(tǒng)一API來(lái)操作Redis
- 支持Redis的發(fā)布訂閱模型
- 支持Redis哨兵和Redis集群
- 支持基于Lettuce的響應(yīng)式編程
- 支持基于JDK.JSON.字符串.Spring對(duì)象的數(shù)據(jù)序列化及反序列化
- 支持基于Redis的JDKCollection實(shí)現(xiàn)
SpringDataRedis中提供了RedisTemplate工具類，其中封裝了各種對(duì)Redis的操作。并且將不同數(shù)據(jù)類型的操作API封裝到了不同的類型中：
快速入門
SpringBoot已經(jīng)提供了對(duì)SpringDataRedis的支持，使用非常簡(jiǎn)單：
- 導(dǎo)入pom坐標(biāo)
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.5.7</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.zhangsan</groupId>
<artifactId>redis-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>redis-demo</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<!--redis依賴-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!--common-pool-->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
<!--Jackson依賴-->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
配置文件
spring:
redis:
host: 192.168.150.101
port: 6379
password: 123321
lettuce:
pool:
max-active: 8 #最大連接
max-idle: 8 #最大空閑連接
min-idle: 0 #最小空閑連接
max-wait: 100ms #連接等待時(shí)間
測(cè)試代碼
@SpringBootTest
class RedisDemoApplicationTests {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@Test
void testString() {
// 寫入一條String數(shù)據(jù)
redisTemplate.opsForValue().set("name", "虎哥");
// 獲取string數(shù)據(jù)
Object name = redisTemplate.opsForValue().get("name");
System.out.println("name = " + name);
}
}
貼心小提示：SpringDataJpa使用起來(lái)非常簡(jiǎn)單，記住如下幾個(gè)步驟即可
SpringDataRedis的使用步驟：
- 引入spring-boot-starter-data-redis依賴
- 在application.yml配置Redis信息
- 注入RedisTemplate
數(shù)據(jù)序列化器
RedisTemplate可以接收任意Object作為值寫入Redis：
只不過(guò)寫入前會(huì)把Object序列化為字節(jié)形式，默認(rèn)是采用JDK序列化，得到的結(jié)果是這樣的：
缺點(diǎn)：
- 可讀性差
- 內(nèi)存占用較大
可以自定義RedisTemplate的序列化方式，代碼如下：
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory){
// 創(chuàng)建RedisTemplate對(duì)象
RedisTemplate<String, Object> template = new RedisTemplate<>();
// 設(shè)置連接工廠
template.setConnectionFactory(connectionFactory);
// 創(chuàng)建JSON序列化工具
GenericJackson2JsonRedisSerializer jsonRedisSerializer =
new GenericJackson2JsonRedisSerializer();
// 設(shè)置Key的序列化
template.setKeySerializer(RedisSerializer.string());
template.setHashKeySerializer(RedisSerializer.string());
// 設(shè)置Value的序列化
template.setValueSerializer(jsonRedisSerializer);
template.setHashValueSerializer(jsonRedisSerializer);
// 返回
return template;
}
}
這里采用了JSON序列化來(lái)代替默認(rèn)的JDK序列化方式。最終結(jié)果如圖：
整體可讀性有了很大提升，并且能將Java對(duì)象自動(dòng)的序列化為JSON字符串，并且查詢時(shí)能自動(dòng)把JSON反序列化為Java對(duì)象。不過(guò)，其中記錄了序列化時(shí)對(duì)應(yīng)的class名稱，目的是為了查詢時(shí)實(shí)現(xiàn)自動(dòng)反序列化。這會(huì)帶來(lái)額外的內(nèi)存開銷。
StringRedisTemplate
盡管JSON的序列化方式可以滿足需求，但依然存在一些問(wèn)題，如圖：
為了在反序列化時(shí)知道對(duì)象的類型，JSON序列化器會(huì)將類的class類型寫入json結(jié)果中，存入Redis，會(huì)帶來(lái)額外的內(nèi)存開銷。
為了減少內(nèi)存的消耗，可以采用手動(dòng)序列化的方式，換句話說(shuō)，就是不借助默認(rèn)的序列化器，而是控制序列化的動(dòng)作，同時(shí)，只采用
String的序列化器，這樣，在存儲(chǔ)value時(shí)，就不需要在內(nèi)存中就不用多存儲(chǔ)數(shù)據(jù)，從而節(jié)約內(nèi)存空間
這種用法比較普遍，因此SpringDataRedis就提供了RedisTemplate的子類：StringRedisTemplate，它的key和value的序列化方式默認(rèn)就是String方式。
省去了自定義RedisTemplate的序列化方式的步驟，而是直接使用：
@SpringBootTest
class RedisStringTests {
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Test
void testString() {
// 寫入一條String數(shù)據(jù)
stringRedisTemplate.opsForValue().set("verify:phone:13600527634", "124143");
// 獲取string數(shù)據(jù)
Object name = stringRedisTemplate.opsForValue().get("name");
System.out.println("name = " + name);
}
private static final ObjectMapper mapper = new ObjectMapper();
@Test
void testSaveUser() throws JsonProcessingException {
// 創(chuàng)建對(duì)象
User user = new User("虎哥", 21);
// 手動(dòng)序列化
String json = mapper.writeValueAsString(user);
// 寫入數(shù)據(jù)
stringRedisTemplate.opsForValue().set("user:200", json);
// 獲取數(shù)據(jù)
String jsonUser = stringRedisTemplate.opsForValue().get("user:200");
// 手動(dòng)反序列化
User user1 = mapper.readValue(jsonUser, User.class);
System.out.println("user1 = " + user1);
}
}
此時(shí)再來(lái)看一看存儲(chǔ)的數(shù)據(jù)，會(huì)發(fā)現(xiàn)那個(gè)class數(shù)據(jù)已經(jīng)不在了，節(jié)約了空間
最后小總結(jié)：
RedisTemplate的兩種序列化實(shí)踐方案：
-
方案一：文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-825184.html
- 自定義RedisTemplate
- 修改RedisTemplate的序列化器為GenericJackson2JsonRedisSerializer
-
方案二：文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-825184.html
- 使用StringRedisTemplate
- 寫入Redis時(shí)，手動(dòng)把對(duì)象序列化為JSON
- 讀取Redis時(shí)，手動(dòng)把讀取到的JSON反序列化為對(duì)象
Hash結(jié)構(gòu)操作
@SpringBootTest
class RedisStringTests {
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Test
void testHash() {
stringRedisTemplate.opsForHash().put("user:400", "name", "虎哥");
stringRedisTemplate.opsForHash().put("user:400", "age", "21");
Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400");
System.out.println("entries = " + entries);
}
}
到了這里，關(guān)于Redis的Java客戶端-Jedis的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
