springboot redis多数据源怎样管理

在Spring Boot中管理多个Redis数据源可以通过以下步骤实现：

1. 配置多个数据源：首先，你需要在application.yml或application.properties文件中配置多个Redis数据源。每个数据源需要有自己的配置信息，包括主机名、端口、密码等。

2. 创建数据源配置类：为每个Redis数据源创建一个配置类，使用@ConfigurationProperties注解来绑定配置文件中的属性。

3. 创建RedisTemplate：为每个数据源创建一个RedisTemplate实例，用于操作Redis数据。

4. 创建RedisConnectionFactory：为每个数据源创建一个RedisConnectionFactory实例，用于建立与Redis服务器的连接。

5. 创建RedisService：创建一个服务类，用于封装对不同数据源的访问逻辑。

下面是一个示例代码，展示了如何实现上述步骤：

1. 配置多个数据源

# application.yml
redis:
  datasource1:
    host: localhost
    port: 6379
    password: password1
  datasource2:
    host: localhost
    port: 6380
    password: password2

2. 创建数据源配置类

import org.springframework.boot.context.properties.ConfigurationProperties;
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.LettuceClientConfiguration;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;

@Configuration
public class RedisDataSourceConfig {

    @Bean
    @ConfigurationProperties(prefix = "redis.datasource1")
    public RedisStandaloneConfiguration redisStandaloneConfiguration1() {
        return new RedisStandaloneConfiguration();
    }

    @Bean
    @ConfigurationProperties(prefix = "redis.datasource2")
    public RedisStandaloneConfiguration redisStandaloneConfiguration2() {
        return new RedisStandaloneConfiguration();
    }

    @Bean
    public LettuceConnectionFactory redisConnectionFactory1() {
        return new LettuceConnectionFactory(redisStandaloneConfiguration1());
    }

    @Bean
    public LettuceConnectionFactory redisConnectionFactory2() {
        return new LettuceConnectionFactory(redisStandaloneConfiguration2());
    }

    @Bean
    public RedisTemplate<String, String> redisTemplate1() {
        StringRedisTemplate template = new StringRedisTemplate();
        template.setConnectionFactory(redisConnectionFactory1());
        return template;
    }

    @Bean
    public RedisTemplate<String, String> redisTemplate2() {
        StringRedisTemplate template = new StringRedisTemplate();
        template.setConnectionFactory(redisConnectionFactory2());
        return template;
    }
}

3. 创建RedisService

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class RedisService {

    @Autowired
    private RedisTemplate<String, String> redisTemplate1;

    @Autowired
    private RedisTemplate<String, String> redisTemplate2;

    public String getValueFromDataSource1(String key) {
        return redisTemplate1.opsForValue().get(key);
    }

    public void setValueToDataSource1(String key, String value) {
        redisTemplate1.opsForValue().set(key, value);
    }

    public String getValueFromDataSource2(String key) {
        return redisTemplate2.opsForValue().get(key);
    }

    public void setValueToDataSource2(String key, String value) {
        redisTemplate2.opsForValue().set(key, value);
    }
}

4. 使用RedisService

在你的业务逻辑中使用RedisService来操作不同的数据源：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MyService {

    @Autowired
    private RedisService redisService;

    public void useDataSource1() {
        redisService.setValueToDataSource1("key", "value");
        String value = redisService.getValueFromDataSource1("key");
        System.out.println("Value from DataSource 1: " + value);
    }

    public void useDataSource2() {
        redisService.setValueToDataSource2("key", "value");
        String value = redisService.getValueFromDataSource2("key");
        System.out.println("Value from DataSource 2: " + value);
    }
}

通过上述步骤，你可以在Spring Boot中管理多个Redis数据源，并根据需要访问不同的数据源。