redis多数据源如何配置

在Redis中配置多个数据源通常涉及到设置多个主服务器地址，以便客户端可以连接到不同的Redis实例。以下是一个基本的步骤指南，假设你使用的是Spring Boot和Jedis作为客户端库。

1. 添加依赖

首先，确保你的pom.xml文件中包含了必要的依赖项：

<dependencies>
    <!-- Spring Boot Starter Data Redis -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>

    <!-- Jedis Client -->
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
    </dependency>
</dependencies>

2. 配置多个数据源

在application.yml或application.properties文件中配置多个Redis数据源。以下是一个示例配置：

application.yml

spring:
  redis:
    master1:
      host: localhost
      port: 6379
      password: your_password_for_master1
    master2:
      host: localhost
      port: 6380
      password: your_password_for_master2

application.properties

spring.redis.master1.host=localhost
spring.redis.master1.port=6379
spring.redis.master1.password=your_password_for_master1

spring.redis.master2.host=localhost
spring.redis.master2.port=6380
spring.redis.master2.password=your_password_for_master2

3. 创建JedisTemplate Bean

为每个数据源创建一个JedisTemplate Bean。以下是一个示例配置：

import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.data.redis.JedisProperties;
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.core.JedisTemplate;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;

@Configuration
public class RedisConfig {

    @Bean
    @Qualifier("master1JedisTemplate")
    public JedisTemplate jedisTemplate(@Qualifier("master1JedisConnectionFactory") RedisStandaloneConfiguration redisStandaloneConfiguration) {
        return new JedisTemplate(redisStandaloneConfiguration);
    }

    @Bean
    @Qualifier("master2JedisTemplate")
    public JedisTemplate jedisTemplate(@Qualifier("master2JedisConnectionFactory") RedisStandaloneConfiguration redisStandaloneConfiguration) {
        return new JedisTemplate(redisStandaloneConfiguration);
    }

    @Bean
    @Qualifier("master1StringRedisTemplate")
    public StringRedisTemplate stringRedisTemplate(@Qualifier("master1JedisConnectionFactory") RedisStandaloneConfiguration redisStandaloneConfiguration) {
        return new StringRedisTemplate(redisStandaloneConfiguration);
    }

    @Bean
    @Qualifier("master2StringRedisTemplate")
    public StringRedisTemplate stringRedisTemplate(@Qualifier("master2JedisConnectionFactory") RedisStandaloneConfiguration redisStandaloneConfiguration) {
        return new StringRedisTemplate(redisStandaloneConfiguration);
    }

    @Bean
    @Qualifier("master1JedisConnectionFactory")
    public RedisStandaloneConfiguration redisStandaloneConfiguration(@Value("${spring.redis.master1.host}") String host,
                                                                 @Value("${spring.redis.master1.port}") int port,
                                                                 @Value("${spring.redis.master1.password}") String password) {
        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(host, port);
        redisStandaloneConfiguration.setPassword(password);
        return redisStandaloneConfiguration;
    }

    @Bean
    @Qualifier("master2JedisConnectionFactory")
    public RedisStandaloneConfiguration redisStandaloneConfiguration(@Value("${spring.redis.master2.host}") String host,
                                                                 @Value("${spring.redis.master2.port}") int port,
                                                                 @Value("${spring.redis.master2.password}") String password) {
        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(host, port);
        redisStandaloneConfiguration.setPassword(password);
        return redisStandaloneConfiguration;
    }
}

4. 使用JedisTemplate

在你的服务类中，你可以注入并使用这些JedisTemplate Bean来操作不同的Redis实例：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.data.redis.core.JedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class RedisService {

    @Autowired
    @Qualifier("master1JedisTemplate")
    private JedisTemplate master1JedisTemplate;

    @Autowired
    @Qualifier("master2JedisTemplate")
    private JedisTemplate master2JedisTemplate;

    public void useMaster1() {
        master1JedisTemplate.opsForValue().set("key", "value");
    }

    public void useMaster2() {
        master2JedisTemplate.opsForValue().set("key", "value");
    }
}

通过这种方式，你可以配置和使用多个Redis数据源。根据你的具体需求，你可能还需要调整配置和代码以适应不同的场景。