redis最佳实践

总结：

String类型的value（string/list/set/hash）使用StringRedisTemplate

其他类型的value（string/list/set/hash/object）使用RedisTemplate（GenericFastJsonRedisSerializer，value都会序列化为json）

value为string时，

如果使用RedisTemplate（使用GenericFastJsonRedisSerializer序列化）时，value值带双引号。即："遥远2"。

如果使用StringRedisTemplate，value值不带双引号。即：遥远2

1、pom

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.3.RELEASE</version>
</parent>

<dependencies>

        <dependency>

            <groupId>org.projectlombok</groupId>

            <artifactId>lombok</artifactId>

            <!-- <scope>provided</scope> -->

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-data-redis</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-test</artifactId>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.alibaba</groupId>

            <artifactId>fastjson</artifactId>

            <version>1.2.41</version>

        </dependency>

    </dependencies>

2、application-dev.yml

spring:

  redis:

    host: 10.134.253.30

    port: 6379

    password: 123456

    # 连接超时时间：ms

    timeout: 5000

    pool:

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

      max-active: 8

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

      max-wait: -1

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

      max-idle: 8

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

      min-idle: 0

3、RedisConfig.java

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

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

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

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

import com.alibaba.fastjson.support.spring.GenericFastJsonRedisSerializer;

@Configuration

public class RedisConfig {

    @Bean("jsonRedisTemplate")

    public RedisTemplate<Object,Object> jsonRedisTemplate(RedisConnectionFactory redisConectionFactory) {

        RedisTemplate<Object,Object> template = new RedisTemplate<Object,Object>();

        template.setConnectionFactory(redisConectionFactory);

        template.setKeySerializer(new StringRedisSerializer());

        template.setValueSerializer(new GenericFastJsonRedisSerializer());

        //hash

        template.setHashKeySerializer(new StringRedisSerializer());

        template.setHashValueSerializer(new GenericFastJsonRedisSerializer());

        template.afterPropertiesSet();

        return template;

    }

}

4、测试类

4.1、StringRedisTemplateTest

import java.util.List;

import lombok.extern.slf4j.Slf4j;

import org.junit.Test;

import org.junit.runner.RunWith;

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

import org.springframework.boot.test.context.SpringBootTest;

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

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

import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)

@SpringBootTest(classes = Application.class)

@Slf4j

public class StringRedisTemplateTest {

    @Autowired

    private StringRedisTemplate stringRedisTemplate;

    @Test

    public void testValue() throws Exception {

        stringRedisTemplate.opsForValue().set("zuo:1", "遥远2");

        String val = stringRedisTemplate.opsForValue().get("zuo:1");

        log.info("值={}",val);

    }

    @Test

    public void testList() throws Exception {

        stringRedisTemplate.opsForList().leftPush("list:zuo", "左");

        stringRedisTemplate.opsForList().leftPush("list:zuo", "杨");

        stringRedisTemplate.opsForList().leftPush("list:zuo", "王");

        long len = stringRedisTemplate.opsForList().size("list:zuo");

        for (int i = 0; i < len; i++) {

            String val = stringRedisTemplate.opsForList().leftPop("list:zuo");//先进后出

            /*

             * 0:王

             * 1:杨

             * 2:左

             */

            log.info("{}:{}",i,val);

        }

    }

    @Test

    public void testHash() throws Exception {

        stringRedisTemplate.opsForHash().put("hash:zuo", "name", "遥远2");;

        stringRedisTemplate.opsForHash().put("hash:zuo", "age", "18");

        String age = (String)stringRedisTemplate.opsForHash().get("hash:zuo", "age");

        log.info("{}",age);

    }

    @Test

    public void testSet() throws Exception {

        stringRedisTemplate.opsForSet().add("set:zuo", "1");

        stringRedisTemplate.opsForSet().add("set:zuo", "2");

        stringRedisTemplate.opsForSet().add("set:zuo", "3");

        long len = stringRedisTemplate.opsForSet().size("set:zuo");

        for (int i = 0; i < len; i++) {

            String s = stringRedisTemplate.opsForSet().pop("set:zuo");

            log.info("{}",s);

        }

    }

    @Test

    public void testBound() throws Exception {

        BoundListOperations operations = stringRedisTemplate.boundListOps("list:zuo");

        operations.leftPush("左");

        operations.leftPush("杨");

        operations.leftPush("王");

        List<String> list = operations.range(0, operations.size());

        list.stream().forEach(s -> System.out.println(s));

    }

}

4.2、RedisTemplateTest

import lombok.extern.slf4j.Slf4j;

import org.junit.Test;

import org.junit.runner.RunWith;

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;

import com.ebc.entity.User;

@RunWith(SpringRunner.class)

@SpringBootTest(classes = Application.class)

@Slf4j

public class RedisTemplateTest {

    @Autowired

    private RedisTemplate<Object,Object> jsonRedisTemplate;//不能为RedisTemplate<K,V>

    @Test

    public void testHash() throws Exception {

        String key = "redistemplate:hash";

        jsonRedisTemplate.opsForHash().put(key, "name", "遥远2");

        jsonRedisTemplate.opsForHash().put(key, "age", 18);

        int age = (Integer)jsonRedisTemplate.opsForHash().get(key, "age");

        log.info("{}", age);

    }

    @Test

    public void testObj() throws Exception {

        String key = "redistemplate:user";

        jsonRedisTemplate.delete(key);

        jsonRedisTemplate.opsForValue().set(key, User.getSampleUser());

        User user = (User)jsonRedisTemplate.opsForValue().get(key);

        log.info("{}", user);

    }

}

4.3、RedisTemplateTest2

import java.util.List;

import lombok.extern.slf4j.Slf4j;

import org.junit.Test;

import org.junit.runner.RunWith;

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

import org.springframework.boot.test.context.SpringBootTest;

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

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

import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)

@SpringBootTest(classes = Application.class)

@Slf4j

public class RedisTemplateTest2 {

    @Autowired()

    private RedisTemplate<Object,Object> jsonRedisTemplate;

    @Test

    public void testValue() throws Exception {

        jsonRedisTemplate.opsForValue().set("redistemplate:value:int", 1);

        jsonRedisTemplate.opsForValue().set("redistemplate:value:long", 1L);

        jsonRedisTemplate.opsForValue().set("redistemplate:value:double", 1d);

        int i = (int)jsonRedisTemplate.opsForValue().get("redistemplate:value:int");

        long l = (long)jsonRedisTemplate.opsForValue().get("redistemplate:value:long");

        double d = (double)jsonRedisTemplate.opsForValue().get("redistemplate:value:double");

        log.info("{},{},{}",i,l,d);

    }

    @Test

    public void testList() throws Exception {

        String key = "redistemplate:list";

        jsonRedisTemplate.opsForList().leftPush(key, 1);

        jsonRedisTemplate.opsForList().leftPush(key, 2);

        jsonRedisTemplate.opsForList().leftPush(key, 3);

        long len = jsonRedisTemplate.opsForList().size(key);

        for (int i = 0; i < len; i++) {

            int val = (int)jsonRedisTemplate.opsForList().leftPop(key);//先进后出

            /*

             * 0:3

             * 1:2

             * 2:1

             */

            log.info("{}:{}",i,val);

        }

    }

    @Test

    public void testSet() throws Exception {

        String key = "redistemplate:set";

        jsonRedisTemplate.opsForSet().add(key, 1);

        jsonRedisTemplate.opsForSet().add(key, 2);

        jsonRedisTemplate.opsForSet().add(key, 3);

        long len = jsonRedisTemplate.opsForSet().size(key);

        for (int i = 0; i < len; i++) {

            int s = (int)jsonRedisTemplate.opsForSet().pop(key);

            log.info("{}",s);

        }

    }

    @Test

    public void testBound() throws Exception {

        BoundListOperations operations = jsonRedisTemplate.boundListOps("redistemplate:list");

        operations.leftPush(1);

        operations.leftPush(2);

        operations.leftPush(3);

        List<Integer> list = operations.range(0, operations.size());

        list.stream().forEach(s -> System.out.println(s));

    }

}

巴特西

redis最佳实践

最新文章

热门文章