redis集群yml配置lettuce

左手的ㄟ右手 2023-07-15 04:54 1阅读 0赞

在springboot中使用redis很方便，只要在yml配置好reids的相关配置项就可以直接使用。

无论是单实例还是集群，都能配置：

spring:
      application:
        name: gate
      redis:
        timeout: 6000ms
        database: 10 
    #    host: localhost #单实例redis用这个配置
    #    password:
    #    port: 6379
        password: Redis@123
        cluster: #集群用这个配置
          nodes:
            - 127.0.0.1:7011
            - 127.0.0.1:7012
            - 127.0.0.1:7013
            - 127.0.0.1:7014
            - 127.0.0.1:7015
            - 127.0.0.1:7016
          max-redirects: 2 #获取失败 最大重定向次数
        lettuce:
          pool: 
            max-active: 1000 #连接池最大连接数（使用负值表示没有限制）
            max-idle: 10 #连接池中的最大空闲连接
            min-idle: 3 #连接池中的最小空闲连接
            max-wait: -1 #连接池最大阻塞等待时间（使用负值表示没有限制）

springboot会帮我们初始化2个RedisTemplate。

一个是 redisTemplate，stringRedisTemplate

注意：

redisTemplate的类型是RedisTemplate<Object, Object>

stringRedisTemplate的类型是：RedisTemplate<String, String>

他们是有区别的，redisTemplate的序列化器是JdkSerializationRedisSerializer

stringRedisTemplate的序列化器是StringRedisSerializer。

在我们需要使用时，直接注入就可以：

@Autowired     
    	private RedisTemplate redisTemplate;
    	
    	
    	@Autowired     
    	private StringRedisTemplate  stringRedisTemplate;

我们在使用时，一般会修改序列化器，所以不会直接@Autowired这个对象就是用，而是重新定义下：

package com.example.gate.config;
    
    import org.springframework.boot.autoconfigure.AutoConfigureAfter;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
    import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
    import org.springframework.data.redis.serializer.StringRedisSerializer;
    
    @Configuration
    @AutoConfigureAfter(RedisAutoConfiguration.class)
    public class RedisConfig {
    	
    	//redisConnectionFactory配置信息由yml控制
    	
    	@Bean
    	@ConditionalOnMissingBean
    	public RedisTemplate<String, Object> redisTemplateMy (LettuceConnectionFactory redisConnectionFactory) {
    		RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
    		//配置序列化器
    		template.setKeySerializer(new StringRedisSerializer());
    		template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    		template.setHashKeySerializer(new StringRedisSerializer());
    		template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
    		template.setConnectionFactory(redisConnectionFactory);
    		
    //		template.afterPropertiesSet();//断言，判断redisConnectionFactory是否不为空,实现InitializingBean接口会自动执行，所以这里不用写这行代码。
    		return template;
    	}
    	
    }

redis连接池的配置pom依赖：

<dependency>
    		   <groupId>org.apache.commons</groupId>
    		   <artifactId>commons-pool2</artifactId>
    		</dependency>

这样在使用的时候就ok了，我们可以比较下我定义的redisTemplateMy和默认的是否是同一个对象，

package com.example.gate.controller;
    
    import java.time.LocalDateTime;
    import java.time.format.DateTimeFormatter;
    
    import javax.annotation.Resource;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.ResponseBody;
    import org.springframework.web.bind.annotation.RestController;
    
    /**
     * RedisAutoConfiguration 
     * 
     * @author lsy
     *
     */
    @RestController
    public class RedisTestController {
    
    	@Resource(name="redisTemplateMy")
    	private RedisTemplate redisTemplateMy;
    	
    	@Autowired     
    	private RedisTemplate redisTemplate;
    	
    	
    	@Autowired     
    	private StringRedisTemplate  stringRedisTemplate;
    	
    	
    	@RequestMapping(value = "/helloRedis",method = RequestMethod.GET)
        @ResponseBody
        public String helloRedis(@RequestParam(required=false) String param){
    		System.out.println("helloRedis接收请求体为===\r\n"+param); 
    		DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
            String dateStr=LocalDateTime.now().format(df);
            
            String value=param+"-------"+dateStr;
            String key="testkey";
            this.redisTemplate.opsForValue().set(key, value);
            String res=(String) this.redisTemplate.opsForValue().get(key);
            String print="查询redis结果===key=="+key+",值=="+res;
    		System.out.println(print);
    		
    		判断springboot帮我创建的对象和我自己声明的对象是否是同一个
    		System.out.println("判断是否相等===="+(redisTemplateMy.equals(redisTemplate)));
    		
    		
    		
    		String key22="testkey22";
            this.stringRedisTemplate.opsForValue().set(key22, value+"22222");
            String res222=(String) this.stringRedisTemplate.opsForValue().get(key22);
            String print22="查询redis结果===key22=="+key22+",值=="+res222;
    		System.out.println(print22);
    		
    		
    		
    		
            return print;
            
        }
    	
    }

结果是2个对象不相等。

所以我们保留一个就行

package com.example.gate.config;
    
    import org.springframework.boot.autoconfigure.AutoConfigureAfter;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
    import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
    import org.springframework.data.redis.serializer.StringRedisSerializer;
    
    @Configuration
    @AutoConfigureAfter(RedisAutoConfiguration.class)
    public class RedisConfig {
    	
    	//redisConnectionFactory配置信息由yml控制
    	
    	@Bean
    	@ConditionalOnMissingBean
    	public RedisTemplate<String, Object> redisTemplate (LettuceConnectionFactory redisConnectionFactory) {
    		RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
    		//配置序列化器
    		template.setKeySerializer(new StringRedisSerializer());
    		template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    		template.setHashKeySerializer(new StringRedisSerializer());
    		template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
    		template.setConnectionFactory(redisConnectionFactory);
    		
    //		template.afterPropertiesSet();//断言，判断redisConnectionFactory是否不为空,实现InitializingBean接口会自动执行，所以这里不用写这行代码。
    		return template;
    	}
    	
    }