2. 程式人生 > 其它 >Redis學習 --redis的Java客戶端(SpringDataRedis)

Redis學習 --redis的Java客戶端(SpringDataRedis)

阿新 • • 發佈：2022-04-04

概述：SpringData是Spring中資料操作的模組，包含對各種資料庫的整合，其中對Redis的整合模組就叫做SpringDataRedis，官網地址：https://spring.io/projects/spring-data-redis

特點：

  1. 提供了對不同Redis客戶端的整合（Lettuce和Jedis）
  2. 提供了RedisTemplate統一API來操作Redis
  3. 支援Redis的釋出訂閱模型
  4. 支援Redis哨兵和Redis叢集
  5. 支援基於Lettuce的響應式程式設計
  6. 支援基於JDK、JSON、字串、Spring物件的資料序列化及反序列化
  7. 支援基於Redis的JDKCollection實現

 

SpringDataRedis中提供了RedisTemplate工具類，其中封裝了各種對Redis的操作。並且將不同資料型別的操作API封裝到了不同的型別中，常用的API如下：

API 返回值型別 說明
redisTemplate.opsForValue() ValueOperations 操作String型別資料
redisTemplate.opsForHash() HashOperations 操作Hash型別資料
redisTemplate.opsForList() ListOperations 操作List型別資料
redisTemplate.opsForSet() SetOperations 操作Set型別資料
redisTemplate.opsForZSet() ZSetOperations 操作SortedSet型別資料
redisTemplate   通用的命令

 

一：RedisTemplate使用的入門案例：

1、建立一個SpringBoot工程

 

2、引入依賴

<!--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>
<!--testng依賴-->
<dependency>
    <groupId>org.testng</groupId>
    <artifactId>testng</artifactId>
    <version>7.1.0</version>
</dependency>

3、編寫連線配置檔案application.yml

spring:
  redis:
    host: 192.168.80.132
    port: 6379
    password: root
    lettuce:
      pool:
        max-active: 8 #最大連線數
        max-idle: 8 #最大空閒連線
        max-wait: 100 #連線等待時間
        min-idle: 0 #最小空閒連線

4、在測試類中進行測試。

package com.lrc;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

@SpringBootTest
class RedisSpringdataApplicationTests {

    //注入RedisTemplate
    @Autowired
    private RedisTemplate redisTemplate;

    @Test
    void testString(){
        //插入一條string型別的資料
        redisTemplate.opsForValue().set("name","李四");
        //讀取一條string型別資料
        Object name = redisTemplate.opsForValue().get("name");
        System.out.println("name="+name);

    }


}

5、執行得到結果：

 

二、RedisTemplate的序列化機制

引入：在上述入門案例中，我們向redis插入了一條{"name":"李四"}的資料，但是我們在redis視覺化介面看到插入的資料顯示為如下圖：

可以看到，在redis中儲存我們上述案例插入的資料並不是按照我們預期的結果展示，這是因為：RedisTemplate可以接收任意Object作為值寫入Redis，只不過寫入前會把Object序列化為位元組形式，預設是採用JDK序列化。所以我們可以採用自定義序列化方式改成我們想要的樣式。

自定義序列化步驟：

1、引入JackSon依賴，處理序列化操作

<!--Jackson依賴-->
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
</dependency>

2、在redis.config包下新建一個RedisConfig配置類

package com.lrc.redis.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;

/**
 * @param
 * @author lrc
 * @create 2022/4/4
 * @return
 * @description
 **/

@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String ,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){
        //建立一個redisTemplate物件
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        //設定連線工廠
        template.setConnectionFactory(redisConnectionFactory);
        //設定序列化工具
        GenericJackson2JsonRedisSerializer jonRedisSerializer = new GenericJackson2JsonRedisSerializer();
        //key和hashkey採用String序列化
        template.setKeySerializer(RedisSerializer.string());
        template.setHashKeySerializer(RedisSerializer.string());
        //value和hashValue採用JSON序列化
        template.setValueSerializer(RedisSerializer.json());
        template.setHashValueSerializer(RedisSerializer.json());
        return template;
    }
}

3、測試自定義序列化機制後的結果

package com.lrc;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

@SpringBootTest
class RedisSpringdataApplicationTests {

    //注入RedisTemplate
    @Autowired
    private RedisTemplate<String ,Object> redisTemplate;

    @Test
    void testString(){
        //插入一條string型別的資料
        redisTemplate.opsForValue().set("name","李四");
        //讀取一條string型別資料
        Object name = redisTemplate.opsForValue().get("name");
        System.out.println("name="+name);

    }


}

 

 

 

下面我們驗證下向Redis寫入物件的結果：

1、在redis.pojo包下新建一個實體類User：

package com.lrc.redis.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * @param
 * @author lrc
 * @create 2022/4/4
 * @return
 * @description
 **/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {
    private String name;
    private Integer age;
}

2、測試下向redis插入一個物件資料的結果：

@Test
void testAddUser(){
    //寫入資料
    redisTemplate.opsForValue().set("user:100",new User("王五",21));
    //讀取資料
    User user = (User) redisTemplate.opsForValue().get("user:100");
    System.out.println("user="+user);
}

3、執行測試

出現這種結果的原因是因為：RedisTemplate存在一個自動反序列機制，那麼它就需要存起反序列化的物件才能知道對哪個物件進行反序列化，顯然這種結果往往我們也不想要，因為會有很大的記憶體開銷，下面我們再進行一個優化方案。

 

Spring預設還提供了一個StringRedisTemplate類，它的key和value的序列化方式預設就是String方式。省去了我們自定義RedisTemplate的過程。

使用步驟：

1、測試類中注入StringRedisTemplate

@Autowired
private StringRedisTemplate stringRedisTemplate;

2、new一個序列化工具：

// JSON工具
private static final ObjectMapper mapper = new ObjectMapper();

3、手動編寫序列化操作：

@Test
void testAddUserMyself() throws JsonProcessingException {
    //建立物件
    User user=new User("Tom",29);
    //手動序列化
    String json = mapper.writeValueAsString(user);
    //寫入資料
    stringRedisTemplate.opsForValue().set("user:300",json);
    //讀取資料
    String s = stringRedisTemplate.opsForValue().get("user:300");
    //進行反序列化
    User user1 = mapper.readValue(s, User.class);
    System.out.println("user1="+user1);
}

4、執行測試

在使用看來，還是使用StringRedisTemplate比較符合我們的實際應用場景。

 

 

三：使用StringRedisTemplate操作其他資料型別練習

1、操作Hash型別

（1）使用put方法逐條村資料

@Test
void testHash(){
    //存資料
    stringRedisTemplate.opsForHash().put("user:400","name","hashName");
    stringRedisTemplate.opsForHash().put("user:400","age","hashAge");
    stringRedisTemplate.opsForHash().put("user:400","handsome","hashYes");
    //取資料
    Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400");
    System.out.println("entries="+entries);
}

（2）使用putAll方法批量存資料

@Test
void testHash02(){
    //準備一個HashMap資料
    HashMap<Object,Object> map=new HashMap<>();
    map.put("name","lrc");
    map.put("age","18");
    map.put("description","很晒氣的小夥子");

    //存入上述hashMap資料
    stringRedisTemplate.opsForHash().putAll("user:500",map);
    //取資料
    Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:500");
    System.out.println("entries="+entries);
}

 

2、操作List型別資料

（1）逐條插入資料leftPush或者rightPush

@Test
void testList(){
    //存資料
    stringRedisTemplate.opsForList().leftPush("aKey","aValue");
    stringRedisTemplate.opsForList().leftPush("bKey","bValue");
    //取資料
    String aKey = stringRedisTemplate.opsForList().leftPop("aKey");
    String bKey = stringRedisTemplate.opsForList().leftPop("bKey");
    System.out.println("akey="+aKey+"\n"+"bKey="+bKey);
}

（2）、一次插入一個ArrayList集合資料

@Test
void testList02(){
    //建立一個ArrayList
    ArrayList list=new ArrayList();
    list.add("張三");
    list.add("李四");
    list.add("王五");
    list.add("趙六");
    //存資料
    stringRedisTemplate.opsForList().leftPushAll("student",list);
    //讀資料
    for (int i=0;i<list.size();i++){
        String student = stringRedisTemplate.opsForList().leftPop("student");
        System.out.println("student="+student);
    }
}

 

3、操作Set型別

@Test
void testSet(){
    stringRedisTemplate.opsForSet().add("setData","data1","data2","data3","data4");
    Set<String> setData = stringRedisTemplate.opsForSet().members("setData");
    System.out.println("setData="+setData);
}

 

 

4、操作SortedSet型別

@Test
void testSortSet(){
    //存資料
    stringRedisTemplate.opsForZSet().add("key","value1",80);
    stringRedisTemplate.opsForZSet().add("key","value2",90);
    stringRedisTemplate.opsForZSet().add("key","value3",95);
    stringRedisTemplate.opsForZSet().add("key","value4",98);
    //取資料
    Set<String> key = stringRedisTemplate.opsForZSet().range("key", 0, 2);
    System.out.println("key="+key);
}

相關推薦

Redis學習 --redis的Java客戶端(SpringDataRedis)

概述：SpringData是Spring中資料操作的模組，包含對各種資料庫的整合，其中對Redis的整合模組就叫做SpringDataRedis，官網地址：https://spring.io/projects/spring-data-redis

Redis的Java客戶端Jedis

先決條件 jdk idea/eclipse Jedis所需要的jar包 Commons-pool-1.6.jar Jedis-2.1.0.jar Jedis常用操作

Winsock庫學習3-客戶端程式設計

技術標籤：C++網路winsocktcpip 為客戶端建立套接字 宣告一個包含sockaddr結構的addrinfo物件，並初始化這些值。對於此應用程式，未指定Internet地址系列，因此可以返回IPv6或IPv4地址。應用程式請求套接字型別

redis 簡單整理——客戶端通訊協議[十五]

前言 簡單介紹一下客戶端的通訊協議。 正文 第 一，客戶端與服務端之間的通訊協議是在TCP協議之上構建的。

redis 簡單整理——客戶端常見異常[十七]

前言 這個還是比較常見的，也就是比較對開發有用的部分。 正文 1.無法從連線池獲取到連線

redis 簡單整理——客戶端案例分析[十八]

前言 簡單整理一下客戶端案例分析。 正文 現象一: 服務端現象：Redis主節點記憶體陡增，幾乎用滿maxmemory，而從節點 記憶體並沒有變化。

讀寫 Redis RESP3 協議以及Redis 6.0客戶端快取

　　在四月份的一篇翻譯的文章中，我介紹了讀寫Redis RESP version 2的協議的Go 語言的實現，你可以使用它採用底層的方式讀寫5.0以及以下版本的Redis。Redis 6.0還在開發之中年底或者明年初就要釋出了。Redis 6.0支

Redis的Java客戶端

Redis 的 Java 客戶端 Jedis 優點：以 Redis 命令作為方法名稱，學習成本低廉，簡單且實用

Redis 學習——客戶端

文章目錄 第三章 客戶端 1.開啟遠端連線 Redis 預設是不支援遠端連線的,需要手動開啟,需要配置 redis.conf 檔案：警告說，如果打算直接暴露到網上，誰都可以連線，是危險的，建議強制直接配置的 IPV4

Redis學習之Jedis原始碼原理分析探究(BIO手寫Jedis客戶端)

　　在Redis的使用過程中，大多數人都是使用現成的客戶端，如Jedis,Redisson,Lettuce。因此本文研究用BIO的方式手寫Redis客戶端嘗試，對遇到的問題進行探究及總結。

一文徹底理解Redis序列化協議，你也可以編寫Redis客戶端

前提 最近學習Netty的時候想做一個基於Redis服務協議的編碼解碼模組，過程中順便閱讀了Redis服務序列化協議RESP，結合自己的理解對檔案進行了翻譯並且簡單實現了RESP基於Java語言的解析。編寫本文的使用使用的JDK版本

redis客戶端實現續命

注入到容器中 呼叫redis客戶端 實現續命 Redsson分散式鎖實現原理

Redis高階客戶端Lettuce詳解

前提 Lettuce是一個Redis的Java驅動包，初識她的時候是使用RedisTemplate的時候遇到點問題Debug到底層的一些原始碼，發現spring-data-redis的驅動包在某個版本之後替換為Lettuce。Lettuce翻譯為生菜，沒錯，就是

Spring Boot Redis客戶端遠端操作實現過程解析

在Spring Boot 1.x中預設是Jedis作為客戶端，但是在Spring Boot2.x後，預設就是Lettuce

C#佇列學習筆記：RabbitMQ實現客戶端相互通訊

原文:C#佇列學習筆記：RabbitMQ實現客戶端相互通訊 一、引言 fanout型別的Exchange，路由規則非常簡單：它會把所有傳送到該Exchange的訊息，路由到所有與它繫結的Queue中。假設有一個聊天室，各個客戶端都訂閱在同

Docker安裝Redis並介紹視覺化客戶端進行操作

1 簡介 Redis是使用ANSI C語言開發的基於Key-Value的高效能NoSQL資料庫，在解決高併發、高可用等一系列問題中，它扮演著重要的角色。它的優勢主要有：

golang學習筆記 --- HTTP 客戶端

Get 函式語法： Get(url string) (resp *Response, err error) 引數：字串型別的 url 地址，需要注意的是這裡要是完整地址，要加上 http:// 或 https:// 的地址

Python基礎學習（29）基於TCP協議的檔案傳輸 驗證客戶端合法性 socketserver模組處理併發客戶端請求

Python基礎學習（29）基於TCP協議的檔案傳輸 驗證客戶端合法性 socketserver 模組處理併發客戶端請求

通過jedis對redis客戶端的一些基本操作

通過jedis對redis客戶端的一些基本操作 引言： redis的儲存方式是基於鍵值對的儲存的。

【客戶端學習】Kotlin Android 學習筆記

Android 應用的基本元件 1. Activity 和 View Activity 是 Android 應用中負責與使用者互動的元件