脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot Redis多数据源

SpringBoot Redis配置多数据源的项目实践

 更新时间：2023年07月25日 15:16:55   作者：算.子  
springboot中默认的redis配置是只能对单个redis库进行操作的， 那么我们需要多个库操作的时候这个时候就可以采用redis多数据源 ，本文就介绍了SpringBoot Redis配置多数据源，感兴趣的可以了解一下

1.教程

0. 添加依赖

在项目中使用 RedisTemplate 支持多个 Redis 数据库之前，需要先添加 Spring Data Redis 的依赖。在 Maven 项目中，可以通过在 pom.xml 文件中添加以下依赖来引入 Spring Data Redis：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

1. 配置多个 Redis 连接信息

在 Spring Boot 中，可以通过在 application.properties 或 application.yml 文件中指定不同的 Redis 连接信息来配置多个 RedisConnectionFactory 实例，并通过 @Bean 注解将它们注入到 RedisTemplate 中，例如：

Redis的常用配置大概是这些

# Redis 服务器的主机名或 IP 地址
spring.redis.host=127.0.0.1
# Redis 服务器的端口号
spring.redis.port=6379
# Redis 服务器的密码，如果没有设置密码，则为空字符串
spring.redis.password=
# Redis 数据库的编号，默认为 0
spring.redis.database=0
# Redis 服务器连接超时时间（毫秒），默认为 5000 毫秒
spring.redis.timeout=5000
# 连接池最大连接数，即最多允许多少个客户端同时连接到 Redis 服务器
spring.redis.pool.max-active=8
# 连接池中最大空闲连接数，即在连接池中最多允许多少个连接处于空闲状态
spring.redis.pool.max-idle=8
# 连接池中最小空闲连接数，即在连接池中最少保持多少个连接处于空闲状态
spring.redis.pool.min-idle=0
# 连接池最大等待时间（毫秒），即当连接池中的连接全部被占用时，新的连接请求最多等待多长时间
# 如果设置为-1，则表示无限等待
spring.redis.pool.max-wait=-1
# 是否启用 SSL 加密连接，默认为 false
spring.redis.ssl=false

我们将上面的配置改造一下，支持Redis多数据源

# 配置 Redis 数据库 0
spring.redis.database0.host=127.0.0.1
spring.redis.database0.port=6379
spring.redis.database0.password=
spring.redis.database0.database=0
spring.redis.database0.timeout=5000
spring.redis.database0.pool.max-active=8
spring.redis.database0.pool.max-idle=8
spring.redis.database0.pool.min-idle=0
spring.redis.database0.pool.max-wait=-1
spring.redis.database0.ssl=false
# 配置 Redis 数据库 1
spring.redis.database1.host=127.0.0.1
spring.redis.database1.port=6380
spring.redis.database1.password=
spring.redis.database1.database=1
spring.redis.database1.timeout=5000
spring.redis.database1.pool.max-active=8
spring.redis.database1.pool.max-idle=8
spring.redis.database1.pool.min-idle=0
spring.redis.database1.pool.max-wait=-1
spring.redis.database1.ssl=false

2. 配置

@ConfigurationProperties(prefix = "spring.redis.database0") 和 @ConfigurationProperties(prefix = "spring.redis.database1") 注解来将不同的 Redis 配置注入到 Java 类中，例如：

@Configuration
public class RedisConfig {
   @Bean(name = "redisTemplate0")
   public RedisTemplate<String, Object> redisTemplate0(RedisConnectionFactory redisConnectionFactory0) {
       RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
       redisTemplate.setConnectionFactory(redisConnectionFactory0);
       redisTemplate.afterPropertiesSet();
       return redisTemplate;
   }
   @Bean(name = "redisTemplate1")
   public RedisTemplate<String, Object> redisTemplate1(RedisConnectionFactory redisConnectionFactory1) {
       RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
       redisTemplate.setConnectionFactory(redisConnectionFactory1);
       redisTemplate.afterPropertiesSet();
       return redisTemplate;
   }
   @Bean(name = "redisConnectionFactory0")
   @ConfigurationProperties(prefix = "spring.redis.database0")
   public RedisConnectionFactory redisConnectionFactory0() {
       return new JedisConnectionFactory();
   }
   @Bean(name = "redisConnectionFactory1")
   @ConfigurationProperties(prefix = "spring.redis.database1")
   public RedisConnectionFactory redisConnectionFactory1() {
       return new JedisConnectionFactory();
   }
}

使用 @ConfigurationProperties(prefix = "spring.redis.database0") 和 @ConfigurationProperties(prefix = "spring.redis.database1") 注解将不同的Redis 配置注入到 RedisConnectionFactory 实例中，并通过 @Bean 注解将不同的 RedisTemplate 实例注入到 Spring 容器中。这样，在代码中就可以通过 @Qualifier 注解来注入不同的 RedisTemplate 实例，从而访问不同的 Redis 数据库。

3. 创建 RedisTemplate 实例

在 Spring Boot 中，可以通过 @Qualifier 和 @Autowired 注解将不同的 RedisTemplate 实例注入到 Java 类中，例如：

@Autowired
@Qualifier("redisTemplate0")
private RedisTemplate<String, Object> redisTemplate0;
@Autowired
@Qualifier("redisTemplate1")
private RedisTemplate<String, Object> redisTemplate1;

4. 使用 RedisTemplate 操作 Redis

在 RedisTemplate 中，提供了一系列方法来操作 Redis，例如：

// 存储数据到 Redis 数据库 0
redisTemplate0.opsForValue().set("key0", "value0");
// 获取数据从 Redis 数据库 0
Object value0 = redisTemplate0.opsForValue().get("key0");
// 删除数据从 Redis 数据库 0
redisTemplate0.delete("key0");
// 存储数据到 Redis 数据库 1
redisTemplate1.opsForValue().set("key1", "value1");
// 获取数据从 Redis 数据库 1
Object value1 = redisTemplate1.opsForValue().get("key1");
// 删除数据从 Redis 数据库 1
redisTemplate1.delete("key1");

2. 常见问题

在使用 Spring Boot 中的 Redis 进行多数据源配置时，可能会遇到以下几个常见问题：

2.1. RedisTemplate 实例重名问题

在配置多个 Redis 数据库时，需要为每个 Redis 数据库创建一个 RedisTemplate 实例。如果不同的 RedisTemplate 实例的名称相同，可能会导致实例重名的问题，进而导致应用程序无法启动。为每个 RedisTemplate 实例指定不同的名称。例如，可以在配置类中通过 @Bean 注解为每个 RedisTemplate 实例指定名称

@Bean(name = "redisTemplate0")
public RedisTemplate<String, Object> redisTemplate0(RedisConnectionFactory redisConnectionFactory0) {
    RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(redisConnectionFactory0);
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class));
    redisTemplate.afterPropertiesSet();
    return redisTemplate;
}
@Bean(name = "redisTemplate1")
public RedisTemplate<String, Object> redisTemplate1(RedisConnectionFactory redisConnectionFactory1) {
    RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(redisConnectionFactory1);
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class));
    redisTemplate.afterPropertiesSet();
    return redisTemplate;
}

在上面的代码中，我们分别为两个 RedisTemplate 实例指定了不同的名称，分别为 “redisTemplate0” 和 “redisTemplate1”。

2.2. RedisConnectionFactory 实例重用问题

在配置多个 Redis 数据库时，需要为每个 Redis 数据库创建一个 RedisConnectionFactory 实例。如果多个 RedisConnectionFactory 实例使用了同一个 Redis 连接池，可能会导致实例重用的问题，进而导致应用程序无法启动。可以为每个 RedisConnectionFactory 实例配置不同的 Redis 连接池。例如，可以在配置类中创建不同的 RedisConnectionFactory 实例，并分别为它们配置不同的 Redis 连接池

@Bean(name = "redisConnectionFactory0")
public RedisConnectionFactory redisConnectionFactory0() {
    RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
    config.setHostName("localhost");
    config.setPort(6379);
    config.setPassword(RedisPassword.of("password"));
    LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory(config);
    connectionFactory.setDatabase(0);
    connectionFactory.afterPropertiesSet();
    return connectionFactory;
}
@Bean(name = "redisConnectionFactory1")
public RedisConnectionFactory redisConnectionFactory1() {
    RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
    config.setHostName("localhost");
    config.setPort(6379);
    config.setPassword(RedisPassword.of("password"));
    LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory(config);
    connectionFactory.setDatabase(1);
    connectionFactory.afterPropertiesSet();
    return connectionFactory;
}

2.3. 数据库编号配置问题

在配置多个 Redis 数据库时，需要为每个 Redis 数据库指定不同的数据库编号。如果多个 Redis 数据库使用了同一个数据库编号，可能会导致数据被覆盖或丢失。为了解决这个问题，可以为每个 RedisConnectionFactory 实例配置不同的数据库编号。例如，可以在 RedisStandaloneConfiguration 中指定不同的数据库编号

@Bean(name = "redisConnectionFactory0")
public RedisConnectionFactory redisConnectionFactory0() {
    RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
    config.setHostName("localhost");
    config.setPort(6379);
    config.setPassword(RedisPassword.of("password"));
    config.setDatabase(0);
    LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory(config);
    connectionFactory.afterPropertiesSet();
    return connectionFactory;
}
@Bean(name = "redisConnectionFactory1")
public RedisConnectionFactory redisConnectionFactory1() {
    RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
    config.setHostName("localhost");
    config.setPort(6379);
    config.setPassword(RedisPassword.of("password"));
    config.setDatabase(1);
    LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory(config);
    connectionFactory.afterPropertiesSet();
    return connectionFactory;
}

2.4. RedisTemplate 序列化问题

在使用 RedisTemplate 时，需要对数据进行序列化和反序列化。如果不同的 Redis 数据库使用了不同的序列化方式，可能会导致数据无法正常读写。每个 RedisTemplate 实例指定不同的序列化器。例如，可以为每个 RedisTemplate 实例分别设置不同的 keySerializer 和 valueSerializer 。但是通常情况下我们的的项目中的序列化方式都是一致的，除非是在连别的项目的Redis时候人家已经按自己的序列化方式将值已经写入，我们只能按照对接方的方式配置序列化。

@Bean(name = "redisTemplate0")
public RedisTemplate<String, Object> redisTemplate0(RedisConnectionFactory redisConnectionFactory0) {
    RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(redisConnectionFactory0);
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class));
    redisTemplate.afterPropertiesSet();
    return redisTemplate;
}
@Bean(name = "redisTemplate1")
public RedisTemplate<String, Object> redisTemplate1(RedisConnectionFactory redisConnectionFactory1) {
    RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(redisConnectionFactory1);
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    redisTemplate.afterPropertiesSet();
    return redisTemplate;
}

到此这篇关于SpringBoot Redis配置多数据源的项目实践的文章就介绍到这了,更多相关SpringBoot Redis多数据源内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • SpringBoot 使用Mybatis分页插件实现详解

    SpringBoot 使用Mybatis分页插件实现详解

    这篇文章主要介绍了SpringBoot 使用Mybatis分页插件实现详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-10-10
  • 关于JSCH使用自定义连接池的说明

    关于JSCH使用自定义连接池的说明

    这篇文章主要介绍了关于JSCH使用自定义连接池的说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-09-09
  • Java实现多线程断点下载实例代码（下载过程中可以暂停）

    Java实现多线程断点下载实例代码（下载过程中可以暂停）

    线程可以理解为下载的通道，一个线程就是一个文件的下载通道，多线程也就是同时开启好几个下载通道,Java实现多线程断点下载实例代码（下载过程中可以暂停），有兴趣的可以了解一下。
    2016-12-12
  • JAVA正则表达式的基本使用教程

    JAVA正则表达式的基本使用教程

    这篇文章主要给大家介绍了关于JAVA正则表达式的基本使用教程，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2021-03-03
  • Mybatis各种查询接口使用详解

    Mybatis各种查询接口使用详解

    这篇文章主要介绍了Mybatis各种查询接口使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习吧
    2022-11-11
  • Java中的HashMap集合源码详细解读

    Java中的HashMap集合源码详细解读

    这篇文章主要介绍了Java中的HashMap集合源码详细解读,hash表是一种数据结构,它拥有惊人的效率,它的时间复杂度低到接近O(1)这样的常数级,需要的朋友可以参考下
    2023-11-11
  • 使用ThreadPoolExecutor之高效处理并发任务

    使用ThreadPoolExecutor之高效处理并发任务

    这篇文章主要介绍了使用ThreadPoolExecutor之高效处理并发任务,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-07-07
  • HTTP基本认证(Basic Authentication)的JAVA实例代码

    HTTP基本认证(Basic Authentication)的JAVA实例代码

    下面小编就为大家带来一篇HTTP基本认证(Basic Authentication)的JAVA实例代码。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2016-11-11
  • java实现XML与JSON转换的便捷实用方法

    java实现XML与JSON转换的便捷实用方法

    这篇文章主要为大家介绍了java实现XML与JSON转换的便捷实用方法,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12
  • 详解Spring中的@PropertySource注解使用

    详解Spring中的@PropertySource注解使用

    这篇文章主要介绍了Spring的@PropertySource注解使用,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2021-08-08

最新评论