文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Redis怎么配置多个数据库

2023-06-29 15:33

关注

这篇文章主要介绍“Redis怎么配置多个数据库”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“Redis怎么配置多个数据库”文章能帮助大家解决问题。

前言

redis 默认有 0-16 号数据库,一般我们操作redis时,用的是 0号数据库,但是有时我们的项目想同时操作多个数据库,又不想每次访问其它库数据时 select 切换数据库,这样太繁琐。

因此我们需要配置多个Jedis Client,但是jedis是容易阻塞,效率不太好,所以我这边采用了 Lettuce Client,它是 Reactive 的连接方式,效率比较高。但是怎么使用到 Lettuce Client,其实一般我们添加  spring-boot-starter-data-redis  依赖,通过RedisTemplate 去使用Redis的功能时,当版本很高的时候默认RedisTemplate底层用的就是通过Lettuce Client 去建立连接和操作数据。

一、添加pom 依赖

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

二、多数据源的配置和添加到spring容器中

下面我的截图使用了四个数据源,分别是1,2,3,4号库。

1)新建一个configuration 配置类

2)new RedisStandaloneConfiguration(host, port); 初始化一个Redis配置,并接下来选择好库号。

3)初始化一个 LettuceConnectionFactory 。

4)实例化一个 RedisTemplate ,并设置键值序列化的方式,这里key和value都是字符串的,所以序列化器选择  StringRedisSerializer。

5)给 RedisTemplate 设置第三步创建的 LettuceConnectionFactory,并以@Bean注解注入到spring容器中,使用时直接通过方法名字在spring容器中查找,装配到引用它的实例中。

import io.lettuce.core.resource.ClientResources;import io.lettuce.core.resource.DefaultClientResources;import org.apache.commons.pool2.impl.GenericObjectPoolConfig;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.connection.RedisPassword;import org.springframework.data.redis.connection.RedisStandaloneConfiguration;import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;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;import org.springframework.util.ObjectUtils; import java.time.Duration;  @Configurationpublic class RedisDatasourceConfiguration {     @Value("${redis.isCleanRedisCache:false}")    private String cleanRedisCache;    @Value("${redis.host:127.0.0.1}")    public String host;    @Value("${redis.port:6379}")    public Integer port;    private String password;     @Value("${redis.timeout:2000}")    public Integer timeout;    public Integer maxIdle = 16;    public Integer minIdle = 5;    public Integer maxTotal = 30;      @Bean    public RedisTemplate<String, String> stringRedisTemplate1() {        RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration(host, port);        configuration.setDatabase(1);        if (!ObjectUtils.isEmpty(password)) {            RedisPassword redisPassword = RedisPassword.of(password);            configuration.setPassword(redisPassword);        }        return createRedisTemplate(creatFactory(configuration));    }     @Bean    public RedisTemplate<String, String> stringRedisTemplate2() {        RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration(host, port);        configuration.setDatabase(2);        if (!ObjectUtils.isEmpty(password)) {            RedisPassword redisPassword = RedisPassword.of(password);            configuration.setPassword(redisPassword);        }        return createRedisTemplate(creatFactory(configuration));    }    @Bean    public RedisTemplate<String, String> stringRedisTemplate3() {        RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration(host, port);        configuration.setDatabase(3);        if (!ObjectUtils.isEmpty(password)) {            RedisPassword redisPassword = RedisPassword.of(password);            configuration.setPassword(redisPassword);        }        return createRedisTemplate(creatFactory(configuration));    }    @Bean    public RedisTemplate<String, String> stringRedisTemplate4() {        RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration(host, port);        configuration.setDatabase(4);        if (!ObjectUtils.isEmpty(password)) {            RedisPassword redisPassword = RedisPassword.of(password);            configuration.setPassword(redisPassword);        }        return createRedisTemplate(creatFactory(configuration));    }     @Bean    public RedisTemplate<String, String> stringRedisTemplate5() {        RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration(host, port);        configuration.setDatabase(5);        if (!ObjectUtils.isEmpty(password)) {            RedisPassword redisPassword = RedisPassword.of(password);            configuration.setPassword(redisPassword);        }        return createRedisTemplate(creatFactory(configuration));    }     private RedisTemplate<String, String> getSerializerRedisTemplate(){        RedisTemplate<String, String> redisTemplate = new RedisTemplate<>();        redisTemplate.setKeySerializer(new StringRedisSerializer());        redisTemplate.setHashKeySerializer(new StringRedisSerializer());        redisTemplate.setHashValueSerializer(new StringRedisSerializer());        return redisTemplate;    }     private RedisTemplate createRedisTemplate(RedisConnectionFactory redisConnectionFactory) {        RedisTemplate<String, String> redisTemplate = getSerializerRedisTemplate();        redisTemplate.setConnectionFactory(redisConnectionFactory);        redisTemplate.afterPropertiesSet();        return redisTemplate;    }    private GenericObjectPoolConfig getGenericObjectPoolConfig(){        GenericObjectPoolConfig genericObjectPoolConfig = new GenericObjectPoolConfig();        genericObjectPoolConfig.setMaxTotal(maxTotal);        genericObjectPoolConfig.setMinIdle(minIdle);        genericObjectPoolConfig.setMaxIdle(maxIdle);        genericObjectPoolConfig.setMaxWaitMillis(timeout);        return genericObjectPoolConfig;    }     private LettuceConnectionFactory creatFactory(RedisStandaloneConfiguration configuration){        LettucePoolingClientConfiguration.LettucePoolingClientConfigurationBuilder builder = LettucePoolingClientConfiguration.builder();        builder.poolConfig(getGenericObjectPoolConfig()); //        LettuceClientConfiguration.LettuceClientConfigurationBuilder builder = LettuceClientConfiguration.builder();//        builder.clientResources(clientResources());//        builder.commandTimeout(Duration.ofSeconds(3000));        LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory(configuration, builder.build());        connectionFactory.afterPropertiesSet();        return connectionFactory;    }}

三、使用方式

Redis怎么配置多个数据库

这里引用是2号库,即上面通过@Bean 加载到spring容器中的。

关于“Redis怎么配置多个数据库”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注编程网行业资讯频道,小编每天都会为大家更新不同的知识点。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯