基于springboot的redis集群配置

使用yml配置文件形式配置redis连接, 也可直接使用RedisTemplate默认配置，就可不用创建以下代码内容，只需编写yml文件即可。

至此就可以使用 RedisTemplate的自带API进行与redis的交互。

RedisClusterConf.java

package cn.com.xxx.config;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.core.env.MapPropertySource;

import org.springframework.data.redis.connection.RedisClusterConfiguration;

import org.springframework.data.redis.connection.RedisConnectionFactory;

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.serializer.StringRedisSerializer;

import redis.clients.jedis.JedisPoolConfig;

import java.util.HashMap;

import java.util.Map;

/**

* @description RedisConf 配置

* @author qijunyu

* @date 2017/11/15 10:59

@Configuration

public class RedisClusterConf {

private static final Logger logger = LoggerFactory.getLogger(RedisClusterConf.class);

@Value("${redis.cluster.nodes}")

private String clusterNodes;

// Redis服务器地址

@Value("${redis.host}")

private String host;

// Redis服务器连接端口

@Value("${redis.port}")

private int port;

// Redis服务器连接密码（默认为空）

@Value("${redis.password}")

private String password;

// 连接超时时间（毫秒）

@Value("${redis.timeout}")

private int timeout;

// Redis数据库索引（默认为0）

@Value("${redis.database}")

private int database;

// 连接池最大连接数（使用负值表示没有限制）

@Value("${redis.pool.max-active}")

private int maxTotal;

// 连接池最大阻塞等待时间（使用负值表示没有限制）

@Value("${redis.pool.max-wait}")

private int maxWaitMillis;

// 连接池中的最大空闲连接

@Value("${redis.pool.max-idle}")

private int maxIdle;

// 连接池中的最小空闲连接

@Value("${redis.pool.min-idle}")

private int minIdle;

@Bean(name = "jedisClusterConfig")

public RedisClusterConfiguration getClusterConfiguration()

{

Map<String, Object> source = new HashMap<String, Object>();

source.put("spring.redis.cluster.nodes", clusterNodes);

source.put("spring.redis.cluster.timeout", timeout);

source.put("spring.redis.cluster.max-redirects", 5);

return new RedisClusterConfiguration(new MapPropertySource("RedisClusterConfiguration", source));

}

/**

* 配置JedisPoolConfig

* @return JedisPoolConfig实体

@Bean(name = "jedisPoolConfig")

public JedisPoolConfig jedisPoolConfig() {

logger.info("=== XXX RedisConf jedisPoolConfig 初始化JedisPoolConfi ===");

JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();

// 连接池最大连接数（使用负值表示没有限制）

jedisPoolConfig.setMaxTotal(this.maxTotal);

// 连接池最大阻塞等待时间（使用负值表示没有限制）

jedisPoolConfig.setMaxWaitMillis(this.maxWaitMillis);

// 连接池中的最大空闲连接

jedisPoolConfig.setMaxIdle(this.maxIdle);

// 连接池中的最小空闲连接

jedisPoolConfig.setMinIdle(this.minIdle);

// jedisPoolConfig.setTestOnBorrow(true);

// jedisPoolConfig.setTestOnCreate(true);

// jedisPoolConfig.setTestWhileIdle(true);

return jedisPoolConfig;

}

/**

* 实例化 RedisConnectionFactory 对象

* @param poolConfig

* @return

@Bean(name = "jedisConnectionFactory")

public RedisConnectionFactory jedisConnectionFactory(@Qualifier(value = "jedisClusterConfig") RedisClusterConfiguration poolConfig) {

logger.info("=== XXX RedisConf jedisConnectionFactory 初始化JedisPoolConfi ===");

JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(poolConfig);

jedisConnectionFactory.setHostName(this.host);

jedisConnectionFactory.setPort(this.port);

jedisConnectionFactory.setDatabase(this.database);

jedisConnectionFactory.setTimeout(this.timeout);

return jedisConnectionFactory;

}

/**

* 实例化 RedisTemplate 对象

* @return

@Bean(name = "redisTemplate")

public RedisTemplate<String, String> functionDomainRedisTemplate(@Qualifier(value = "jedisConnectionFactory") RedisConnectionFactory factory) {

logger.info("=== XXX RedisConf functionDomainRedisTemplate 初始化JedisPoolConfi ===");

RedisTemplate<String, String> redisTemplate = new RedisTemplate<>();

redisTemplate.setConnectionFactory(factory);

redisTemplate.setKeySerializer(new StringRedisSerializer());

redisTemplate.setHashKeySerializer(new StringRedisSerializer());

redisTemplate.setHashValueSerializer(new EntityRedisSerializer());

redisTemplate.setValueSerializer(new EntityRedisSerializer());

redisTemplate.afterPropertiesSet();

redisTemplate.setEnableTransactionSupport(true);

return redisTemplate;

}

application.yml

redis:

# Redis 服务器地址

host: 127.0.0.1

# Redis 服务器连接端口

port: 7000

# Redis 服务器连接密码（默认为空）

password:

# 连接超时时间（毫秒）

timeout: 0

# Redis 数据库索引（默认为 0 ）

database: 0

pool:

# 连接池最大连接数（使用负值表示没有限制）

max-active: 8

# 连接池最大阻塞等待时间（使用负值表示没有限制）

max-wait: -1

# 连接池中的最大空闲连接

max-idle: 8

# 连接池中的最小空闲连接

min-idle: 0

cluster:

nodes: 127.0.0.1:7000,127.0.0.1:7001,127.0.0.1:7002

基于springboot的redis集群配置相关推荐

springBoot整合redis集群配置
最近发现这篇博客阅读量比较大,今天特意抽空创建了一个可运行的开源项目. 项目的代码和之前的博客内容相比,做了些优化,请大家参考项目源码. 开源项目源码: springboot-redis-cluste ...
SpringBoot多redis集群配置
在一个SpringBoot应用中配置多个redis集群文章目录 1) 禁用自动配置 2)配置application.properties 3)增加java配置类 4)使用 1) 禁用自动配置禁用 ...
springboot集成redis集群实现集群拓扑动态刷新
一个redis-cluster的三主三从集群,在其中一个master节点挂了之后,springboot集成redis集群配置信息没有及时刷新,出现读取操作报错.下面聊聊如何实现springboot集成 ...
springBoot整合redis单节点、redis哨兵、redis集群配置及redisClient区别
springBoot整合redis单节点.redis哨兵.redis集群配置,redisClient jedis lettuce 区别? 1.springboot 整合redis单机模式: sprin ...
springboot整合redis集群master宕机后连接超时
前提: # 本文是在确保redis集群配置正确的情况下,连接超时的解决方案. 项目登录认证使用的是sa-token(这个不重要,主要说的是springboot和redis集群),最近应甲 ...
基于Docker搭建Redis集群（主从集群）
最近陆陆续续有不少园友加我好友咨询 redis 集群搭建的问题,我觉得之前写的这篇 <基于Docker的Redis集群搭建> 文章一定是有问题了,所以我花了几分钟浏览之前的文章总结了下面几 ...
基于Docker的Redis集群简单搭建
环境:Docker + ( Redis:5.0.5 * 3 ) 1.拉取镜像 docker pull redis:5.0.5 2.创建Redis容器创建三个 redis 容器: redis-node ...
基于Twemproxy的Redis集群方案
基于Twemproxy的Redis集群方案原文地址:http://www.cnblogs.com/haoxinyue/p/redis.html 为了保持方便,愿原博主谅解概述由于单台redis ...
java集群解析文件_java相关：springboot整合redis集群过程解析
java相关:springboot整合redis集群过程解析发布于 2020-4-13| 复制链接摘记: 简介在springboot使用搭建好的redis集群添加redis和连接池依赖 ```x ...

基于springboot的redis集群配置

基于springboot的redis集群配置相关推荐

最新文章

热门文章