Spring Boot: 集成Redis 基本操作、事务、流水线、订阅、发布、序列化

        
            org.springframework.boot
            spring-boot-starter-data-redis
        

#Redis 数据库索引（默认为0）
spring.redis.database=0
#Redis 服务器地址
spring.redis.host=localhost
#Redis 服务器连接端口
spring.redis.port=6379
#Redis 服务器连接密码（默认为空）
spring.redis.password=
#连接池最大连接数（使用负值表示没有限制）默认8
spring.redis.lettuce.pool.max-active=8
#连接池最大阻塞等待时间（使用负值表示灭有限制）默认-1
spring.redis.lettuce.pool.max-wait=-1
#连接池中的最大空闲连接 默认 8
spring.redis.lettuce.pool.max-idle=8
#连接池中最小空闲连接 默认 0
spring.redis.lettuce.pool.min-idle=0

package com.yq.demo.controller;

import com.yq.demo.config.RedisConfig;
import com.yq.demo.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.RedisZSetCommands;
import org.springframework.data.redis.core.*;

import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.*;
import java.util.concurrent.TimeUnit;

@RestController
@RequestMapping("/redis")
public class TestRedisController {

    @Autowired
    private RedisTemplate redisTemplate;

    /**
     * redis存储key,value
     * */
    @GetMapping("/setValue")
    public String setValue(String key,String strValue){
        redisTemplate.opsForValue().set(key,strValue);
        return "success";
    }

    /**
     * 根据key读取redis的value值
     * */
    @GetMapping("/getValue")
    public String getValue(String key){
        return (String)redisTemplate.opsForValue().get(key);
    }

    /**
     * 将对象存储到redis
     * */
    @GetMapping("/setUser")
    public String setValue(String key,String userName,int age,String tel){

        int userId=1;
        User user=new User();
        user.setUserId(userId);
        user.setAge(age);
        user.setUserName(userName);
        user.setTel(tel);
       // ValueOperations operations=redisTemplate.opsForValue();
       // operations.set(key,user);
//        redisTemplate.opsForValue().set(key,user);
        //参数100是过期时间，超过这个时间就会自动删除数据
        redisTemplate.opsForValue().set(key,user,100, TimeUnit.MILLISECONDS);
        return "success";
    }

    /**
     * 根据key获取存储的对象数据
     * */
    @GetMapping("/getUser")
    public String setValue(String key){

        if(redisTemplate.hasKey(key)){
            User user=(User)redisTemplate.opsForValue().get(key);
            return user.toString();
        }
        return "null";
    }

    /**
     * 删除数据
     * */
    @GetMapping("/delete")
    public void delKey(String key){
        if(redisTemplate.hasKey(key)){
            redisTemplate.delete(key);
        }
    }

    @GetMapping("/value")
    public void value(){
        String key="v1";
        String key2="v2";
        redisTemplate.delete(key);
        //使用increment,append需要加上序列化
        redisTemplate.setValueSerializer(new StringRedisSerializer());
        ValueOperations v1=redisTemplate.opsForValue();
        v1.set(key,"13");
        long l1=v1.increment(key);//value+1
        long l2=v1.increment(key,100);//value+100
        long l3=v1.decrement(key);//value-1

        v1.set(key2,"a");
        v1.append(key2,"bcdef");//value末尾追加字符串
        System.out.println(v1.get(key2));

        String str=v1.get(key2,1,2);//截取value从索引1到索引2，包含1，2
        System.out.println(str);
        v1.set(key2,"12",1);//从索引1开始字符串被替换,bc被12替换
        System.out.println(v1.get(key2));


    }

    @GetMapping("/hash")
    public void hash(){
        //Charset.forName("ISO_8859_1")
        redisTemplate.delete("user");
        //下面有使用increment需要序列化
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(new StringRedisSerializer());
        HashOperations hash=redisTemplate.opsForHash();
        hash.put("user","id","1");
        hash.put("user","userName","Jack");

        Set