欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot整合redis+lettuce的方法詳解

 更新時間:2023年08月24日 09:22:20   作者:fking86  
這篇文章主要介紹了SpringBoot整合redis+lettuce的方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

前言

Spring Boot提供了與Redis的集成框架,可以使用Lettuce作為Redis客戶端來進行整合。

版本依賴

jdk 17

SpringBoot 3.1.0

環(huán)境準備

依賴

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>3.1.0</version>
    </parent>
    <groupId>com.example</groupId>
    <artifactId>RedisLettuceDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>RedisLettuceDemo</name>
    <description>RedisLettuceDemo</description>
    <properties>
        <java.version>17</java.version>
        <maven.compiler.source>17</maven.compiler.source>
        <maven.compiler.target>17</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>2.0.32</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>
    </dependencies>

配置

server:
  port: 8080  # 設(shè)置訪問端口
spring:
  redis:
    host: localhost
    port: 6379
    password: 123456
    database: 0
    ssl: false
    pool:
      maxIdle: 100
      minIdle: 0
      maxTotal: 100
      maxWaitMillis: 500
      testOnBorrow: false
      testOnReturn: true
      testWhileIdle: true

實例

LettuceClientConfig

//Redis服務(wù)器地址
    @Value("${spring.redis.host}")
    private String host;
    //Redis服務(wù)端口
    @Value("${spring.redis.port}")
    private Integer port;
    //Redis密碼
    @Value("${spring.redis.password}")
    private String password;
    //是否需要SSL
    @Value("${spring.redis.ssl}")
    private Boolean ssl;
    //Redis默認庫,一共0~15
    @Value("${spring.redis.database}")
    private Integer database;
    //Lettuce連接配置(Redis單機版實例)
    @Bean(name = "redisClient")
    public RedisClient redisClient() {
        RedisURI uri = RedisURI.Builder.redis(this.host, this.port)
                .withDatabase(this.database)
                .build();
        return RedisClient.create(uri);
    }

LettucePoolConfig

@Resource
    RedisClient redisClient;
    //設(shè)置可分配的最大Redis實例數(shù)量
    @Value("${spring.redis.pool.maxTotal}")
    private Integer maxTotal;
    //設(shè)置最多空閑的Redis實例數(shù)量
    @Value("${spring.redis.pool.maxIdle}")
    private Integer maxIdle;
    //歸還Redis實例時,檢查有消息,如果失敗,則銷毀實例
    @Value("${spring.redis.pool.testOnReturn}")
    private Boolean testOnReturn;
    //當Redis實例處于空閑壯體啊時檢查有效性,默認flase
    @Value("${spring.redis.pool.testWhileIdle}")
    private Boolean testWhileIdle;
    //Apache-Common-Pool是一個對象池,用于緩存Redis連接,
    //因為Letture本身基于Netty的異步驅(qū)動,但基于Servlet模型的同步訪問時,連接池是必要的
    //連接池可以很好的復用連接,減少重復的IO消耗與RedisURI創(chuàng)建實例的性能消耗
    @Getter
    GenericObjectPool<StatefulRedisConnection<String, String>> redisConnectionPool;
    //Servlet初始化時先初始化Lettuce連接池
    @PostConstruct
    private void init() {
        GenericObjectPoolConfig<StatefulRedisConnection<String, String>> redisPoolConfig
                = new GenericObjectPoolConfig<>();
        redisPoolConfig.setMaxIdle(this.maxIdle);
        redisPoolConfig.setMinIdle(0);
        redisPoolConfig.setMaxTotal(this.maxTotal);
        redisPoolConfig.setTestOnReturn(this.testOnReturn);
        redisPoolConfig.setTestWhileIdle(this.testWhileIdle);
        redisPoolConfig.setMaxWaitMillis(1000);
        this.redisConnectionPool =
                ConnectionPoolSupport.createGenericObjectPool(() -> redisClient.connect(), redisPoolConfig);
    }
    //Servlet銷毀時先銷毀Lettuce連接池
    @PreDestroy
    private void destroy() {
        redisConnectionPool.close();
        redisClient.shutdown();
    }

LettuceUtil

@Autowired
    LettucePoolConfig lettucePoolConfig;
    //編寫executeSync方法,在方法中,獲取Redis連接,利用Callback操作Redis,最后釋放連接,并返回結(jié)果
    //這里使用的同步的方式執(zhí)行cmd指令
    public <T> T executeSync(SyncCommandCallback<T> callback) {
        //這里利用try的語法糖,執(zhí)行完,自動給釋放連接
        try (StatefulRedisConnection<String, String> connection = lettucePoolConfig.getRedisConnectionPool().borrowObject()) {
            //開啟自動提交,如果false,命令會被緩沖,調(diào)用flushCommand()方法發(fā)出
            connection.setAutoFlushCommands(true);
            //設(shè)置為同步模式
            RedisCommands<String, String> commands = connection.sync();
            //執(zhí)行傳入的實現(xiàn)類
            return callback.doInConnection(commands);
        } catch (Exception e) {
            log.error(e.getMessage());
            throw new RuntimeException(e);
        }
    }
    //分裝一個set方法
    public String set(final String key, final String val) {
        return executeSync(commands -> commands.set(key, val));
    }
    //分裝一個get方法
    public String get(final String key) {
        return executeSync(commands -> commands.get(key));
    }

SyncCommandCallback

    //抽象方法,為了簡化代碼,便于傳入回調(diào)函數(shù)
    T doInConnection(RedisCommands<String, String> commands);

LettuceController

@Autowired
    LettuceUtil lettuceUtil;
    /**
     * 使用Lettuce工具類,調(diào)用Redis的Set指令
     * http://127.0.0.1:8080/lettuce/set?key=name&val=ipipman
     *
     * @param key
     * @param val
     * @return
     */
    @GetMapping("/set")
    public Object setItem(@RequestParam(name = "key", required = true) String key,
                          @RequestParam(name = "val", required = true) String val) {
        return lettuceUtil.set(key, val);
    }
    /**
     * 使用Lettuce工具類,調(diào)用Redis的Get指令
     * http://127.0.0.1:8080/lettuce/get?key=name
     *
     * @param key
     * @return
     */
    @GetMapping("/get")
    public Object getItem(@RequestParam(name = "key", required = true) String key) {
        return lettuceUtil.get(key);
    }

到此這篇關(guān)于SpringBoot整合redis+lettuce的方法詳解的文章就介紹到這了,更多相關(guān)SpringBoot整合redis+lettuce內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • swagger配置正式環(huán)境中不可訪問的問題

    swagger配置正式環(huán)境中不可訪問的問題

    這篇文章主要介紹了swagger配置正式環(huán)境中不可訪問的問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-06-06
  • 使用mtrace追蹤JVM堆外內(nèi)存泄露的方法

    使用mtrace追蹤JVM堆外內(nèi)存泄露的方法

    這篇文章主要給大家介紹了如何使用mtrace追蹤JVM堆外內(nèi)存泄露,文章通過代碼示例介紹的非常詳細,對大家的學習或工作有一定的幫助,需要的朋友可以參考下
    2023-09-09
  • java的finalize方法解讀

    java的finalize方法解讀

    這篇文章主要介紹了java的finalize方法,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-09-09
  • Java8中StringJoiner類的使用詳解

    Java8中StringJoiner類的使用詳解

    Java在java.util包中添加了一個新的最終類StringJoiner??梢杂糜跇?gòu)造由定界符分隔的字符序列。本文將通過示例和大家分享一下StringJoiner類的使用,需要的可以參考一下
    2022-10-10
  • spring cloud 之 客戶端負載均衡Ribbon深入理解

    spring cloud 之 客戶端負載均衡Ribbon深入理解

    下面小編就為大家?guī)硪黄猻pring cloud 之 客戶端負載均衡Ribbon深入理解。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-06-06
  • Java中解壓縮文件的方法詳解(通用)

    Java中解壓縮文件的方法詳解(通用)

    在軟件開發(fā)和數(shù)據(jù)處理領(lǐng)域,文件的解壓縮和壓縮是常見的任務(wù),下面這篇文章主要給大家介紹了關(guān)于Java中解壓縮文件的相關(guān)資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
    2024-06-06
  • Java通過JavaMail發(fā)送郵件功能

    Java通過JavaMail發(fā)送郵件功能

    這篇文章主要為大家詳細介紹了Java通過JavaMail發(fā)送郵件功能,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2022-08-08
  • idea添加數(shù)據(jù)庫圖文教程

    idea添加數(shù)據(jù)庫圖文教程

    這篇文章主要介紹了idea添加數(shù)據(jù)庫圖文教程,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-09-09
  • struts2標簽總結(jié)_動力節(jié)點Java學院整理

    struts2標簽總結(jié)_動力節(jié)點Java學院整理

    這篇文章主要為大家詳細總結(jié)了struts2標簽的使用方法,和學習資料,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-09-09
  • Java收集的雪花算法代碼詳解

    Java收集的雪花算法代碼詳解

    這篇文章主要介紹了Java實現(xiàn)雪花算法的詳細代碼,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2021-10-10

最新評論