依星源码资源网,依星资源网

 找回密码
 立即注册

QQ登录

只需一步,快速开始

【好消息,好消息,好消息】VIP会员可以发表文章赚积分啦 !
查看: 22|回复: 0

同一个 Redis 实例里要用多个 DB,比如应用平时用 database:0,但要删除的数据在 database:1

[复制链接] 主动推送

2万

主题

2万

帖子

2万

积分

管理员

Rank: 9Rank: 9Rank: 9

积分
23353
发表于 昨天 09:39 | 显示全部楼层 |阅读模式
同一个 Redis 实例里要用多个 DB,比如应用平时用 `database:0`,但要删除的数据在 `database:1`,需要在 Spring Boot 里同时访问 0 和 1 两个库。

- 创建 **多个 `RedisConnectionFactory` / `RedisTemplate`**,每个绑定一个不同的 `database`。
- 平时业务用默认的(db0),清理数据时用专门指向 db1 的模板。

下面给出一个常见实现方式(基于 Lettuce,Spring Boot 2.x 默认)。

---

**1. application.yml 中仍然只配置一个 Redis 节点**

Redis 本身就是一个节点,DB 只是编号,不需要写多份 IP/端口:

```yaml
spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: 123456
    database: 0   # 默认 DB,仍然是 0
    lettuce:
      pool:
        max-active: 32
        max-idle: 16
        min-idle: 0
        max-wait: 3s
```

> 说明:我们在 Java 配置里额外创建一个专门指向 `database:1` 的工厂/模板。

---

**2. Java 配置:为不同 DB 建不同的 `StringRedisTemplate`**

新建一个配置类,比如 `RedisConfig.java`:

```java
package com.example.sms.config;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.data.redis.LettuceClientConfigurationBuilderCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisPassword;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.StringRedisTemplate;

@Configuration
public class RedisConfig {

    @Value("${spring.redis.host}")
    private String host;

    @Value("${spring.redis.port}")
    private int port;

    @Value("${spring.redis.password}")
    private String password;

    // 默认的 StringRedisTemplate(使用 spring.redis.database,通常是 0)
    // Spring Boot 已经自动配置了一个,你可以继续用现成的。

    // DB1 的连接工厂
    @Bean
    public LettuceConnectionFactory redisConnectionFactoryDb1() {
        RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
        config.setHostName(host);
        config.setPort(port);
        if (password != null && !password.isEmpty()) {
            config.setPassword(RedisPassword.of(password));
        }
        config.setDatabase(1);   // 关键:指定使用 DB 1

        return new LettuceConnectionFactory(config);
    }

    // 指向 DB1 的 StringRedisTemplate
    @Bean
    public StringRedisTemplate stringRedisTemplateDb1() {
        StringRedisTemplate template = new StringRedisTemplate();
        template.setConnectionFactory(redisConnectionFactoryDb1());
        return template;
    }
}
```

要点:

- 默认的 `spring.redis.database` 仍是 0,Spring Boot 会帮你创建一个默认的 `StringRedisTemplate`(你现在 `SmsServiceImpl` 里注入的就是它)。
- 我们自己再创建一个 `redisConnectionFactoryDb1`,只改 `setDatabase(1)`。
- 再基于它创建一个 `StringRedisTemplate` Bean(例如叫 `stringRedisTemplateDb1`)。

---

**3. 在代码中使用不同 DB 的模板**

- 业务代码继续用默认 DB0 的 `StringRedisTemplate`:

  ```java
  @Autowired
  private StringRedisTemplate redisTemplate; // 指向 database:0
  ```

- 要操作 DB1 的时候,注入我们刚才配置的那个:

  ```java
  @Autowired
  private StringRedisTemplate stringRedisTemplateDb1; // 指向 database:1
  ```

示例:删除 `database:1` 中前缀为 `sms:` 的数据:

```java
@Service
public class RedisDb1CleanupService {

    @Autowired
    private StringRedisTemplate stringRedisTemplateDb1;

    public void deleteSmsKeysInDb1() {
        // 简单版(key 不多时)
        Set<String> keys = stringRedisTemplateDb1.keys("sms:*");
        if (keys != null && !keys.isEmpty()) {
            stringRedisTemplateDb1.delete(keys);
        }
    }
}
```

如果数据量大,就结合前面说的 SCAN 分批删除,只是把 `redisTemplate` 换成 `stringRedisTemplateDb1` 即可。

---

**4. 总结用法**

- `database:0`:继续用原来的 `StringRedisTemplate`。
- `database:1`:在配置类里手工创建一个指向 DB1 的 `LettuceConnectionFactory` 和 `StringRedisTemplate`,需要访问 DB1 时注入并使用它。



相关帖子

扫码关注微信公众号,及时获取最新资源信息!下载附件优惠VIP会员6折;永久VIP4折
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

免责声明:
1、本站提供的所有资源仅供参考学习使用,版权归原著所有,禁止下载本站资源参与商业和非法行为,请在24小时之内自行删除!
2、本站所有内容均由互联网收集整理、网友上传,并且以计算机技术研究交流为目的,仅供大家参考、学习,请勿任何商业目的与商业用途。
3、若您需要商业运营或用于其他商业活动,请您购买正版授权并合法使用。
4、论坛的所有内容都不保证其准确性,完整性,有效性,由于源码具有复制性,一经售出,概不退换。阅读本站内容因误导等因素而造成的损失本站不承担连带责任。
5、用户使用本网站必须遵守适用的法律法规,对于用户违法使用本站非法运营而引起的一切责任,由用户自行承担
6、本站所有资源来自互联网转载,版权归原著所有,用户访问和使用本站的条件是必须接受本站“免责声明”,如果不遵守,请勿访问或使用本网站
7、本站使用者因为违反本声明的规定而触犯中华人民共和国法律的,一切后果自己负责,本站不承担任何责任。
8、凡以任何方式登陆本网站或直接、间接使用本网站资料者,视为自愿接受本网站声明的约束。
9、本站以《2013 中华人民共和国计算机软件保护条例》第二章 “软件著作权” 第十七条为原则:为了学习和研究软件内含的设计思想和原理,通过安装、显示、传输或者存储软件等方式使用软件的,可以不经软件著作权人许可,不向其支付报酬。若有学员需要商用本站资源,请务必联系版权方购买正版授权!
10、本网站如无意中侵犯了某个企业或个人的知识产权,请来信【站长信箱312337667@qq.com】告之,本站将立即删除。
郑重声明:
本站所有资源仅供用户本地电脑学习源代码的内含设计思想和原理,禁止任何其他用途!
本站所有资源、教程来自互联网转载,仅供学习交流,不得商业运营资源,不确保资源完整性,图片和资源仅供参考,不提供任何技术服务。
本站资源仅供本地编辑研究学习参考,禁止未经资源商正版授权参与任何商业行为,违法行为!如需商业请购买各资源商正版授权
本站仅收集资源,提供用户自学研究使用,本站不存在私自接受协助用户架设游戏或资源,非法运营资源行为。
 
在线客服
点击这里给我发消息 点击这里给我发消息 点击这里给我发消息
售前咨询热线
312337667

微信扫一扫,私享最新原创实用干货

QQ|免责声明|小黑屋|依星资源网 ( 鲁ICP备2021043233号-3 )|网站地图

GMT+8, 2025-11-22 04:36

Powered by Net188.com X3.4

邮箱:312337667@qq.com 客服QQ:312337667(工作时间:9:00~21:00)

快速回复 返回顶部 返回列表