如何动态连接不同Redis地址？-java教程-PHP中文网

如何动态连接不同Redis地址？

碧海醫心

发布： 2025-02-22 19:36:09

原创

465人浏览过

如何动态连接不同redis地址？

灵活连接Redis：自定义函数实现动态Redis连接

为了根据运行时参数连接不同的Redis实例，我们可以创建一个自定义函数，动态生成并返回 RedisTemplate 实例。

自定义函数代码

<code class="java">public static RedisTemplate<Object, Object> getRedisTemplate(RedisConnectInfo info) {
    // 创建RedisStandaloneConfiguration
    RedisStandaloneConfiguration redisStandaloneConfiguration = buildRedisStandaloneConfiguration(info);

    RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
    // 配置JSON序列化
    Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
    ObjectMapper objectMapper = new ObjectMapper();
    objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
    jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
    redisTemplate.setHashKeySerializer(new StringRedisSerializer());
    redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);

    // 使用LettuceConnectionFactory
    redisTemplate.setConnectionFactory(new LettuceConnectionFactory(
            redisStandaloneConfiguration,
            LettuceClientConfiguration.builder().build()
    ));

    // 初始化配置
    redisTemplate.afterPropertiesSet();
    return redisTemplate;
}</code>

登录后复制

测试代码

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

<code class="java">@Test
public void testDynamicRedisConnection() {
    RedisTemplate<Object, Object> redisTemplate = CacheUtils.getRedisTemplate(new RedisConfigInfo("127.0.0.1", "password", 6379));
    redisTemplate.opsForValue().set("foo", "bar");
}</code>

登录后复制

重要提示：

使用 LettuceConnectionFactory 创建 RedisTemplate 时，务必调用 afterPropertiesSet() 方法完成初始化。这确保了 RedisTemplate 正确配置并能正常工作。

以上就是如何动态连接不同Redis地址？的详细内容，更多请关注php中文网其它相关文章！