标签：java redis Redis springframework 哨兵 org import data properties
@
目录前言
一、添加依赖
因我的构建cloud项目，这里直接把可能会用的依赖都放到一起
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-configuration-processor</artifactId>
<optional>true</optional>
</dependency>
二、改好RedisConfig
前提是已经建好Redis的springboot项目，按网上的操作就行。我的是在这基础上操作
package com.ams.common.redis.config;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
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.RedisNode;
import org.springframework.data.redis.connection.RedisSentinelConfiguration;
import org.springframework.data.redis.connection.RedisServer;
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.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.time.Duration;
import java.util.List;
@Configuration
@EnableConfigurationProperties(RedisProperties.class)
public class RedisConfig {
private final RedisProperties properties;
public RedisConfig(RedisProperties properties){
this.properties = properties;
}
@Bean
public RedisTemplate<String, Object> redisTemplate() {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(getConnectionFactory());
// 用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(stringRedisSerializer); // key
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper objectMapper = new ObjectMapper();
// 指定要序列化的域(field,get,set)，访问修饰符(public,private,protected)
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer); //value
redisTemplate.setHashKeySerializer(stringRedisSerializer);
redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
@Bean
public RedisConnectionFactory getConnectionFactory() {
//哨兵模式
RedisSentinelConfiguration configuration = new RedisSentinelConfiguration();
configuration.setMaster(properties.getSentinel().getMaster());
configuration.setPassword(properties.getPassword());
configuration.setDatabase(properties.getDatabase());
List<String> nodes = properties.getSentinel().getNodes();
nodes.forEach(node -> {
String[] str = node.split(":");
RedisNode redisServer = new RedisServer(str[0], Integer.parseInt(str[1]));
configuration.sentinel(redisServer);
});
LettuceConnectionFactory factory = new LettuceConnectionFactory(configuration, getPool());
//使用前先校验连接,这个最好是要配置：不然会带来connection reset by peer
factory.setValidateConnection(true);
return factory;
}
@Bean
public LettuceClientConfiguration getPool() {
GenericObjectPoolConfig genericObjectPoolConfig = new GenericObjectPoolConfig();
//redis客户端配置:超时时间默认
LettucePoolingClientConfiguration.LettucePoolingClientConfigurationBuilder
builder = LettucePoolingClientConfiguration.builder().
commandTimeout(Duration.ofMillis(60000));
//连接池配置
RedisProperties.Pool pool = properties.getLettuce().getPool();
genericObjectPoolConfig.setMaxIdle(pool.getMaxIdle());
genericObjectPoolConfig.setMinIdle(pool.getMinIdle());
genericObjectPoolConfig.setMaxTotal(pool.getMaxActive());
genericObjectPoolConfig.setMaxWaitMillis(pool.getMaxWait().toMillis());
builder.shutdownTimeout(Duration.ofMillis(4000));
builder.poolConfig(genericObjectPoolConfig);
return builder.build();
}
三、修改nacos中Redis的配置
redis:
sentinel:
master: master
nodes: 192.168.2.237:6776,192.168.2.37:6777,192.168.2.37:6778
password: 123456
timeout: 1000
database: 3
lettuce:
pool:
max-active: 8
max-wait: 1000
max-idle: 8
min-idle: 0
四、其他
1.踩到的坑如下：
java一直无法连接sentinel，关闭防火墙也不行
解决方法：因为之前redis配置的防火墙打开，开放端口，所以这里也不能关闭防火墙，而是要开放sentinel的几个端口。
随心所往，看见未来。Follow your heart，see night！
欢迎点赞、关注、留言，一起学习、交流！
标签：java,redis,Redis,springframework,哨兵,org,import,data,properties 来源： https://www.cnblogs.com/folyh/p/16501061.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。