redis实战spring-boot-starter-data-redis

2024-08-23 00:12

本文主要是介绍redis实战spring-boot-starter-data-redis,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

SpringBoot集成Redis环境搭建及配置详解_springboot redis 配置-CSDN博客

如何使用Spring Boot框架整合Redis:超详细案例教程_spring-boot-starter-data-redis-CSDN博客

https://blog.csdn.net/weixin_44411039/article/details/133578724

连接池选择及Jedis连接池参数配置建议_分布式缓存服务 DCS

官网 Drivers :: Spring Data Redis

1 总结

1:默认整合了两种连接池,lettuce 和 jedis ,默认使用 lettuce连接池(因为支持的功能多)

2:如果配置了自定义的RedisConnectionFactory ,Spring Boot就不会自动配置 RedisConnectionFactory

2:不配置序列化器,我们是无法看懂的

2 pom

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><!--    <version>2.5.1</version>--></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><!--  <version>2.9.0</version>--></dependency>

 配置jedis连接池时用

      <dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId></dependency>

3 简单使用(单机版)

配置文件

spring:application:name: redisredis:port: 6379database: 0# host: 192.168.135.10host: 127.0.0.1jedis:pool:max-active: 300max-idle: 300min-idle: 100max-wait: 5slettuce:pool:max-active: 300max-idle: 300min-idle: 100max-wait: 5sshutdown-timeout: 100ms

 直接使用,设置值

    @AutowiredRedisTemplate redisTemplate;@Testvoid contextLoads1() {//設置字符串 新值redisTemplate.opsForValue().set("ok","测试ok1");String ok = (String)redisTemplate.opsForValue().get("ok");System.out.println(ok);}

 因为未配置序列化器

默认加载哪个连接池

结论:不自定义连接池情况下,默认只会加载lettuce连接池

1:当我们配置文件配置了lettuce时,会加在配置单连接池中。

配置文件不会因为你配置 jedis 默认使用jedis连接池。

序列化器


import com.alibaba.fastjson.parser.ParserConfig;
import org.springframework.beans.factory.annotation.Autowired;
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.HashOperations;
import org.springframework.data.redis.core.ListOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
public class RedisTemplateConfig {/*** 可以注入方式设置连接*/
/*    @Autowiredprivate RedisConnectionFactory factory;*//*** RedisTemplate配置 改成json序列化模式用keys方法可取到值 否则取不到**/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);// 全局开启AutoType,不建议使用// ParserConfig.getGlobalInstance().setAutoTypeSupport(true);// 建议使用这种方式,小范围指定白名单ParserConfig.getGlobalInstance().addAccept("com.demo.");// 设置值(value)的序列化采用FastJsonRedisSerializer。template.setValueSerializer(fastJsonRedisSerializer);template.setHashValueSerializer(fastJsonRedisSerializer);template.setDefaultSerializer(fastJsonRedisSerializer);// 设置键(key)的序列化采用StringRedisSerializer。template.setKeySerializer(new StringRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer());template.afterPropertiesSet();return template;}/*** 可以删除*/@Beanpublic ValueOperations valueOperations(RedisTemplate redisTemplate){return redisTemplate.opsForValue();}/*** 可以删除*/@Beanpublic ListOperations listOperations(RedisTemplate redisTemplate){return redisTemplate.opsForList();}/*** 可以删除*/@Beanpublic HashOperations hashOperations(RedisTemplate redisTemplate){return redisTemplate.opsForHash();}
}

 方式二

测试成功

4 自定义LettuceConnectionFactory

1:场景:配置文件中用户,密码是加密的,需要解密后 设置到连接池中。

2: 可以发现自定义配置参数会 覆盖配置文件的配置参数

import com.alibaba.fastjson.parser.ParserConfig;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration  // 配置类
public class RedisConfig  {/***  配置 Redis 连接工厂*  意义: LettuceConnectionFactory 是连接 Redis 服务器的入口,它使用了 Lettuce 客户端,并且配置了连接池来提高性能和资源管理* @return*/@Beanpublic LettuceConnectionFactory redisConnectionFactory() {// 配置 Redis 服务器的连接信息 可以读取配置文件获取RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();redisStandaloneConfiguration.setHostName("localhost");redisStandaloneConfiguration.setPort(6379);// redisStandaloneConfiguration.setPassword("password"); // 取消注释以设置密码// 配置连接池GenericObjectPoolConfig<Object> poolConfig = new GenericObjectPoolConfig<>();poolConfig.setMaxTotal(10);       // 连接池中的最大连接数poolConfig.setMaxIdle(5);         // 连接池中的最大空闲连接数poolConfig.setMinIdle(1);         // 连接池中的最小空闲连接数poolConfig.setMaxWaitMillis(2000); // 连接池获取连接的最大等待时间// 创建一个带有连接池配置的 Lettuce 客户端配置LettucePoolingClientConfiguration lettucePoolingClientConfiguration =LettucePoolingClientConfiguration.builder().poolConfig(poolConfig).build();// 返回带有连接池配置的 Redis 连接工厂return new LettuceConnectionFactory(redisStandaloneConfiguration, lettucePoolingClientConfiguration);}@Beanpublic RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory factory) {/*    2.设置连接工厂: 使用前面定义的 LettuceConnectionFactory。3.设置序列化器: 设置键和值的序列化器,这里使用 StringRedisSerializer 来将键和值序列化为字符串。*/RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);// 全局开启AutoType,不建议使用// ParserConfig.getGlobalInstance().setAutoTypeSupport(true);// 建议使用这种方式,小范围指定白名单ParserConfig.getGlobalInstance().addAccept("com.demo.");// 设置值(value)的序列化采用FastJsonRedisSerializer。template.setValueSerializer(fastJsonRedisSerializer);template.setHashValueSerializer(fastJsonRedisSerializer);template.setDefaultSerializer(fastJsonRedisSerializer);// 设置键(key)的序列化采用StringRedisSerializer。template.setKeySerializer(new StringRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer());template.afterPropertiesSet();return template;}}

 最终加载的是代码中自定义配置的连接池参数,而不是配置文件中配置。

5 自定义JedisConnectionFactory

1:配置了Jedis连接池后,用的就是Jedis了。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import redis.clients.jedis.JedisPoolConfig;@Configuration
public class JedisConnectionConfig {@Autowiredprivate Environment env;@Beanpublic JedisConnectionFactory redisConnectionFactory() {Integer port = Integer.valueOf(env.getProperty("spring.redis.port"));String host = env.getProperty("spring.redis.host");String password = env.getProperty("spring.redis.password");Integer database = Integer.valueOf(env.getProperty("spring.redis.database"));Integer maxActive = Integer.valueOf(env.getProperty("spring.redis.jedis.pool.max-active"));Integer maxIdle = Integer.valueOf(env.getProperty("spring.redis.jedis.pool.max-idle"));Integer minIdle = Integer.valueOf(env.getProperty("spring.redis.jedis.pool.min-idle"));JedisPoolConfig poolConfig = new JedisPoolConfig();//最大空闲数poolConfig.setMaxIdle(maxIdle);//最大连接数poolConfig.setMaxTotal(maxActive);//最大等待毫秒数poolConfig.setMaxWaitMillis(20000);poolConfig.setMinIdle(minIdle);poolConfig.setTestOnBorrow(true);RedisStandaloneConfiguration config = new RedisStandaloneConfiguration("server", 6379);config.setPort(port);config.setDatabase(database);config.setHostName(host);if (null != password) {config.setPassword(password);}JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(config);jedisConnectionFactory.setPoolConfig(poolConfig);return jedisConnectionFactory;}
}

这篇关于redis实战spring-boot-starter-data-redis的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1097803

相关文章

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1:定义时间段类步骤2:添加时间段步骤3:检查时间段是否有重合步骤4:输出结果示例代码结语作

Java中String字符串使用避坑指南

《Java中String字符串使用避坑指南》Java中的String字符串是我们日常编程中用得最多的类之一,看似简单的String使用,却隐藏着不少“坑”,如果不注意,可能会导致性能问题、意外的错误容... 目录8个避坑点如下:1. 字符串的不可变性:每次修改都创建新对象2. 使用 == 比较字符串,陷阱满

Java判断多个时间段是否重合的方法小结

《Java判断多个时间段是否重合的方法小结》这篇文章主要为大家详细介绍了Java中判断多个时间段是否重合的方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录判断多个时间段是否有间隔判断时间段集合是否与某时间段重合判断多个时间段是否有间隔实体类内容public class D

IDEA编译报错“java: 常量字符串过长”的原因及解决方法

《IDEA编译报错“java:常量字符串过长”的原因及解决方法》今天在开发过程中,由于尝试将一个文件的Base64字符串设置为常量,结果导致IDEA编译的时候出现了如下报错java:常量字符串过长,... 目录一、问题描述二、问题原因2.1 理论角度2.2 源码角度三、解决方案解决方案①:StringBui

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下:需要在

Java中ArrayList和LinkedList有什么区别举例详解

《Java中ArrayList和LinkedList有什么区别举例详解》:本文主要介绍Java中ArrayList和LinkedList区别的相关资料,包括数据结构特性、核心操作性能、内存与GC影... 目录一、底层数据结构二、核心操作性能对比三、内存与 GC 影响四、扩容机制五、线程安全与并发方案六、工程

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》:本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》:本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.

Spring AI集成DeepSeek的详细步骤

《SpringAI集成DeepSeek的详细步骤》DeepSeek作为一款卓越的国产AI模型,越来越多的公司考虑在自己的应用中集成,对于Java应用来说,我们可以借助SpringAI集成DeepSe... 目录DeepSeek 介绍Spring AI 是什么?1、环境准备2、构建项目2.1、pom依赖2.2