歡迎光臨
每天分享高質量文章

一起來學 SpringBoot 2.x | 第九篇:整合 Lettuce Redis

點擊上方“芋道原始碼”,選擇“置頂公眾號”

技術文章第一時間送達!

原始碼精品專欄

 


摘要: 原創出處 http://blog.battcn.com/2018/05/11/springboot/v2-nosql-redis/ 「唐亞峰」歡迎轉載,保留摘要,謝謝!

  • Redis介紹

  • Lettuce

  • 匯入依賴

  • 屬性配置

  • 具體編碼

  • 總結

  • 說點什麼


SpringBoot 是為了簡化 Spring 應用的創建、運行、除錯、部署等一系列問題而誕生的產物,自動裝配的特性讓我們可以更好的關註業務本身而不是外部的XML配置,我們只需遵循規範,引入相關的依賴就可以輕易的搭建出一個 WEB 工程

Spring Boot 除了支持常見的ORM框架外,更是對常用的中間件提供了非常好封裝,隨著Spring Boot2.x的到來,支持的組件越來越豐富,也越來越成熟,其中對Redis的支持不僅僅是豐富了它的API,更是替換掉底層Jedis的依賴,取而代之換成了Lettuce(生菜)

Redis介紹

Redis是一個開源的使用ANSI C語言編寫、支持網絡、可基於記憶體亦可持久化的日誌型、Key-Value資料庫,並提供多種語言的API。相比Memcached它支持儲存的型別相對更多(字符、哈希、集合、有序集合、串列、GEO)同時Redis是執行緒安全的。2010年3月15日起,Redis的開發工作由VMware主持,2013年5月開始,Redis的開發由Pivotal贊助。

Lettuce

Lettuce  Jedis 的都是連接Redis Server的客戶端程式。Jedis實現上是直連redis server,多執行緒環境下非執行緒安全,除非使用連接池,為每個Jedis實體增加物理連接Lettuce基於Netty的連接實體(StatefulRedisConnection),可以在多個執行緒間併發訪問,且執行緒安全,滿足多執行緒環境下的併發訪問,同時它是可伸縮的設計,一個連接實體不夠的情況也可以按需增加連接實體

匯入依賴

 pom.xml spring-boot-starter-data-redis的依賴,Spring Boot2.x 後底層不在是Jedis如果做版本升級的朋友需要註意下

<dependency>
    <groupId>org.springframework.bootgroupId>


    <artifactId>spring-boot-starter-data-redisartifactId>
dependency>
<dependency>
    <groupId>org.springframework.bootgroupId>
    <artifactId>spring-boot-starter-webartifactId>
dependency>
<dependency>
    <groupId>org.apache.commonsgroupId>
    <artifactId>commons-pool2artifactId>
dependency>
<dependency>
    <groupId>org.springframework.bootgroupId>
    <artifactId>spring-boot-starter-testartifactId>
    <scope>testscope>
dependency>

屬性配置

 application.properties 檔案中配置如下內容,由於Spring Boot2.x 的改動,連接池相關配置需要通過spring.redis.lettuce.pool或者 spring.redis.jedis.pool 進行配置了

spring.redis.host=localhost
spring.redis.password=battcn
# 連接超時時間(毫秒)
spring.redis.timeout=10000
# Redis預設情況下有16個分片,這裡配置具體使用的分片,預設是0
spring.redis.database=0
# 連接池最大連接數(使用負值表示沒有限制) 預設 8
spring.redis.lettuce.pool.max-active=8
# 連接池最大阻塞等待時間(使用負值表示沒有限制) 預設 -1
spring.redis.lettuce.pool.max-wait=-1
# 連接池中的最大空閑連接 預設 8
spring.redis.lettuce.pool.max-idle=8
# 連接池中的最小空閑連接 預設 0
spring.redis.lettuce.pool.min-idle=0

具體編碼

Spring BootRedis的支持已經非常完善了,良好的序列化以及豐富的API足夠應對日常開發

物體類

創建一個User

package com.battcn.entity;

import java.io.Serializable;

/**
 * @author Levin
 * @since 2018/5/10 0007
 */

public class User implements Serializable {

    private static final long serialVersionUID = 8655851615465363473L;
    private Long id;
    private String username;
    private String password;
    // TODO  省略get set
}

自定義Template

預設情況下的模板只能支持RedisTemplate,也就是只能存入字串,這在開發中是不友好的,所以自定義模板是很有必要的,當自定義了模板又想使用String儲存這時候就可以使用StringRedisTemplate的方式,它們並不衝突…

package com.battcn.config;

import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.io.Serializable;

/**
 * TODO 修改database
 *
 * @author Levin
 * @since 2018/5/10 0022
 */

@Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class)
public class RedisCacheAutoConfiguration {

    @Bean
    public RedisTemplate redisCacheTemplate(LettuceConnectionFactory redisConnectionFactory) {
        RedisTemplate template = new RedisTemplate<>();
        template.setKeySerializer(new StringRedisSerializer());
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }
}

測試

完成準備事項後,編寫一個junit測試類來檢驗代碼的正確性,有很多人質疑過Redis執行緒安全性,故下麵也提供了響應的測試案例,如有疑問歡迎指正

package com.battcn;

import com.battcn.entity.User;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.test.context.junit4.SpringRunner;

import java.io.Serializable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.stream.IntStream;

/**
 * @author Levin
 * @since 2018/5/10 0010
 */

@RunWith(SpringRunner.class)
@SpringBootTest
public class Chapter8ApplicationTest {

    private static final Logger log = LoggerFactory.getLogger(Chapter8ApplicationTest.class);

    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Autowired
    private RedisTemplate redisCacheTemplate;


    @Test
    public void get() {
        // TODO 測試執行緒安全
        ExecutorService executorService = Executors.newFixedThreadPool(1000);
        IntStream.range(01000).forEach(i ->
                executorService.execute(() -> stringRedisTemplate.opsForValue().increment("kk"1))
        );
        stringRedisTemplate.opsForValue().set("k1""v1");
        final String k1 = stringRedisTemplate.opsForValue().get("k1");
        log.info("[字符快取結果] - [{}]", k1);
        // TODO 以下只演示整合,具體Redis命令可以參考官方文件,Spring Data Redis 只是改了個名字而已,Redis支持的命令它都支持
        String key = "battcn:user:1";
        redisCacheTemplate.opsForValue().set(key, new User(1L"u1""pa"));
        // TODO 對應 String(字串)
        final User user = (User) redisCacheTemplate.opsForValue().get(key);
        log.info("[物件快取結果] - [{}]", user);
    }
}

其它型別

下列的就是Redis其它型別所對應的操作方式

  • opsForValue: 對應 String(字串)

  • opsForZSet: 對應 ZSet(有序集合)

  • opsForHash: 對應 Hash(哈希)

  • opsForList: 對應 List(串列)

  • opsForSet: 對應 Set(集合)

  • opsForGeo: 對應 GEO(地理位置)

總結

spring-data-redis文件: https://docs.spring.io/spring-data/redis/docs/2.0.1.RELEASE/reference/html/#new-in-2.0.0
Redis 文件: https://redis.io/documentation
Redis 中文文件: http://www.redis.cn/commands.html

目前很多大佬都寫過關於 SpringBoot 的教程了,如有雷同,請多多包涵,本教程基於最新的 spring-boot-starter-parent:2.0.1.RELEASE編寫,包括新版本的特性都會一起介紹…

說點什麼

全文代碼:https://github.com/battcn/spring-boot2-learning/tree/master/chapter8




如果你對 Dubbo / Netty 等等原始碼與原理感興趣,歡迎加入我的知識星球一起交流。長按下方二維碼噢

目前在知識星球更新了《Dubbo 原始碼解析》目錄如下:

01. 除錯環境搭建
02. 專案結構一覽
03. 配置 Configuration
04. 核心流程一覽

05. 拓展機制 SPI

06. 執行緒池

07. 服務暴露 Export

08. 服務取用 Refer

09. 註冊中心 Registry

10. 動態編譯 Compile

11. 動態代理 Proxy

12. 服務呼叫 Invoke

13. 呼叫特性 

14. 過濾器 Filter

15. NIO 服務器

16. P2P 服務器

17. HTTP 服務器

18. 序列化 Serialization

19. 集群容錯 Cluster

20. 優雅停機

21. 日誌適配

22. 狀態檢查

23. 監控中心 Monitor

24. 管理中心 Admin

25. 運維命令 QOS

26. 鏈路追蹤 Tracing

… 一共 69+ 篇

目前在知識星球更新了《Netty 原始碼解析》目錄如下:

01. 除錯環境搭建
02. NIO 基礎
03. Netty 簡介
04. 啟動 Bootstrap

05. 事件輪詢 EventLoop

06. 通道管道 ChannelPipeline

07. 通道 Channel

08. 位元組緩衝區 ByteBuf

09. 通道處理器 ChannelHandler

10. 編解碼 Codec

11. 工具類 Util

… 一共 61+ 篇

目前在知識星球更新了《資料庫物體設計》目錄如下:


01. 商品模塊
02. 交易模塊
03. 營銷模塊
04. 公用模塊

… 一共 17+ 篇

赞(0)

分享創造快樂