springboot整合redis lettuce

偏执的太偏执、 2023-03-01 09:49 123阅读 0赞

需要配置的jar

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
                <exclusions>
                    <exclusion>
                        <groupId>org.junit.vintage</groupId>
                        <artifactId>junit-vintage-engine</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <scope>test</scope>
            </dependency>

配置

server.port=9901
    
    ##redis配置
    spring.redis.database=0
    spring.redis.host=192.168.99.92
    spring.redis.port=6379
    spring.redis.password=8HD5agiwfJrx0ptc@MRD
    spring.redis.timeout=10000
    ##redis线程池配置
    spring.redis.lettuce.pool.max-active=8
    spring.redis.lettuce.pool.max-wait=-1
    spring.redis.lettuce.pool.max-idle=8
    spring.redis.jedis.pool.min-idle=0

如果存储对象可以写一下

package com.jackray.redis.configure;
    
    import java.io.Serializable;
    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
    public class LettuceRedisConfig {
        @Bean
        public RedisTemplate<String, Serializable> redisTemplate(LettuceConnectionFactory lettuceConnectionFactory) {
            RedisTemplate<String, Serializable> redisTemplate = new RedisTemplate<>();
            redisTemplate.setKeySerializer(new StringRedisSerializer());
            redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
            redisTemplate.setConnectionFactory(lettuceConnectionFactory);
            return redisTemplate;
        }
    
    }

测试用例 整体要不要太简单

package com.jackray.redis.redis;
    
    import com.jackray.redis.bean.User;
    import java.io.Serializable;
    import java.util.concurrent.TimeUnit;
    import org.junit.Assert;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.omg.CORBA.PRIVATE_MEMBER;
    import org.omg.CORBA.ServerRequest;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.test.context.junit4.SpringRunner;
    
    /**
     * redisTemplate.opsForValue();//操作字符串
     * redisTemplate.opsForHash();//操作hash
     * redisTemplate.opsForList();//操作list
     * redisTemplate.opsForSet();//操作set
     * redisTemplate.opsForZSet();//操作有序set
     */
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class RedisTest {
    
        @Autowired
        private RedisTemplate<String, String> strRedisTemplate;
        @Autowired
        private RedisTemplate<String, Serializable> serializableRedisTemplate;
    
        @Test
        public void testString(){
            strRedisTemplate.opsForValue().set("sad", "sad");
            System.out.println(strRedisTemplate.opsForValue().get("sad"));
        }
    
        @Test
        public void testSerializables(){
            String ss = "sad";
            User user = new User();
            user.setId(1);
            user.setAddress("sad");
    
            serializableRedisTemplate.opsForValue().set(ss, user, 2, TimeUnit.HOURS);
            User sad = (User) serializableRedisTemplate.opsForValue().get(ss);
            System.out.println(sad.toString());
        }
    }