SpringBoot2.X整合Redis

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0modelVersion>    <parent>        <groupId>org.springframework.bootgroupId>        <artifactId>spring-boot-starter-parentartifactId>        <version>2.3.3.RELEASEversion>        <relativePath/>     parent>    <groupId>net.auiogroupId>    <artifactId>spring-boot-redisartifactId>    <version>0.0.1-SNAPSHOTversion>    <name>spring-boot-redisname>    <description>Demo project for Spring Bootdescription>
    <properties>        <java.version>1.8java.version>        <springboot.version>2.2.3.RELEASEspringboot.version>        <fastjson.version>1.2.54fastjson.version>    properties>
    <dependencies>        <dependency>            <groupId>org.springframework.bootgroupId>            <artifactId>spring-boot-starter-webartifactId>            <version>${springboot.version}version>        dependency>        <dependency>            <groupId>org.springframework.bootgroupId>            <artifactId>spring-boot-starter-data-redisartifactId>        dependency>        <dependency>            <groupId>org.apache.commonsgroupId>            <artifactId>commons-pool2artifactId>        dependency>
        <dependency>            <groupId>com.alibabagroupId>            <artifactId>fastjsonartifactId>            <version>${fastjson.version}version>        dependency>

        <dependency>            <groupId>org.springframework.bootgroupId>            <artifactId>spring-boot-devtoolsartifactId>            <scope>runtimescope>            <optional>trueoptional>        dependency>        <dependency>            <groupId>org.springframework.bootgroupId>            <artifactId>spring-boot-starter-testartifactId>            <scope>testscope>            <exclusions>                <exclusion>                    <groupId>org.junit.vintagegroupId>                    <artifactId>junit-vintage-engineartifactId>                exclusion>            exclusions>        dependency>    dependencies>
    <build>        <plugins>            <plugin>                <groupId>org.springframework.bootgroupId>                <artifactId>spring-boot-maven-pluginartifactId>                <configuration>                    <fork>truefork>                configuration>            plugin>        plugins>    build>
project>

spring.redis.host=localhostspring.redis.port=6379spring.redis.jedis.pool.max-active=8spring.redis.jedis.pool.max-idle=500spring.redis.jedis.pool.max-wait=-1spring.redis.jedis.pool.min-idle=0spring.redis.lettuce.shutdown-timeout=0

package net.auio.springboot.config;
import net.auio.springboot.Initializr.MyRedisSerInitializr;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 java.net.UnknownHostException;
@Configurationpublic class RedisConfig {
    @Bean    public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {        RedisTemplate template = new RedisTemplate<>();        template.setConnectionFactory(redisConnectionFactory);        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();        MyRedisSerInitializr myRedisSerInitializr = new MyRedisSerInitializr();        template.setKeySerializer(stringRedisSerializer);        template.setValueSerializer(myRedisSerInitializr);        template.setHashKeySerializer(stringRedisSerializer);        template.setHashValueSerializer(myRedisSerInitializr);        return template;
    }
}

package net.auio.springboot.controller;
import net.auio.springboot.exception.BusinessException;import net.auio.springboot.service.RedisService;import org.springframework.util.StringUtils;import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;@RestController@RequestMapping(value = "/redis")public class RedisController {
    @Resource    RedisService redisService;
    @GetMapping(value = "/getvalue/{key}")    public String getvalue(@PathVariable("key") String key){        if (!StringUtils.isEmpty(key)){            if(!redisService.hasKey(key)){              return "key不存在";            }            Object o = redisService.get(key);            return o.toString();        }else{            return "key不允許為空";        }    }
    @PostMapping(value = "/add")    public String addStringRedis(String key,String value){        try {            redisService.set(key,value);            return key+"添加成功";        } catch (Exception e) {            e.printStackTrace();            throw new BusinessException(1001,e.getMessage());        }    }}

package net.auio.springboot.exception;
public class BusinessException extends RuntimeException {    private final int messageCode;    private final String detailMessage;
    public BusinessException(int messageCode,String message){        super(message);        this.messageCode=messageCode;        this.detailMessage =message;    }
    public int getMessageCode() {        return messageCode;    }
    public String getDetailMessage() {        return detailMessage;    }}

package net.auio.springboot.Initializr;
import com.alibaba.fastjson.JSON;import org.springframework.data.redis.serializer.RedisSerializer;import org.springframework.data.redis.serializer.SerializationException;
import java.nio.charset.Charset;import java.nio.charset.StandardCharsets;
public class MyRedisSerInitializr implements RedisSerializer<Object> {
    private final Charset charset;
    public MyRedisSerInitializr() {        this(StandardCharsets.UTF_8);    }
    public MyRedisSerInitializr(Charset charset) {        this.charset = charset;    }
    @Override    public byte[] serialize(Object o) throws SerializationException {        if(o==null){            return new byte[0];        }        if (o instanceof String){            return o.toString().getBytes(charset);        }else {            String string=JSON.toJSONString(o);            return string.getBytes(charset);        }    }
    @Override    public Object deserialize(byte[] bytes) throws SerializationException {        return (bytes==null ? null : new String(bytes,charset));    }}

package net.auio.springboot.service;
import net.auio.springboot.exception.BusinessException;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Service;
import javax.annotation.Resource;import java.util.*;import java.util.concurrent.TimeUnit;@Servicepublic class RedisService {    @Resource    private RedisTemplate redisTemplate;    /** -------------------key相關(guān)操作--------------------- */    /**     * 是否存在key     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key     * @return       java.lang.Boolean     * @throws     */    public Boolean hasKey(String key) {        if (null==key){            return false;        }        return redisTemplate.hasKey(key);    }    /**     * 刪除key     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key     * @return       Boolean 成功返回true 失敗返回false     * @throws     */    public Boolean delete(String key) {        if (null==key){            return false;        }        return redisTemplate.delete(key);    }    /**     * 批量刪除key     * @Author:     妖妖玖     * @CreateDate: 2019/8/27 20:27     * @UpdateUser:     * @UpdateDate: 2019/8/27 20:27     * @Version:     0.0.1     * @param keys     * @return       Long 返回成功刪除key的數(shù)量     * @throws     */    public Long delete(Collection keys) {        return redisTemplate.delete(keys);    }    /**     * 設(shè)置過期時(shí)間     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key    ? * @param timeout    ? * @param unit     * @return       java.lang.Boolean     * @throws     */    public Boolean expire(String key, long timeout, TimeUnit unit) {        if (null==key||null==unit){            return false;        }        return redisTemplate.expire(key, timeout, unit);    }    /**     * 查找匹配的key     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param pattern     * @return       java.util.Set     * @throws     */    public Set keys(String pattern) {        if (null==pattern){            return null;        }        return redisTemplate.keys(pattern);    }    /**     * 移除 key 的過期時(shí)間，key 將持久保持     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key     * @return       java.lang.Boolean     * @throws     */    public Boolean persist(String key) {        if (null==key){            return false;        }        return redisTemplate.persist(key);    }    /**     * 返回 key 的剩余的過期時(shí)間     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key    ? * @param unit     * @return       java.lang.Long 當(dāng) key 不存在時(shí)，返回 -2 。當(dāng) key 存在但沒有設(shè)置剩余生存時(shí)間時(shí)，返回 -1 。否    則，以秒為單位，返回 key的剩余生存時(shí)間     * @throws     */    public Long getExpire(String key, TimeUnit unit) {        if(null==key||null==unit){            throw new BusinessException(4001004,"key or TomeUnit 不能為空");        }        return redisTemplate.getExpire(key, unit);    }    //*************String相關(guān)數(shù)據(jù)類型***************************    /**     * 設(shè)置指定 key 的值     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key    ? * @param value     * @return       void     * @throws     */    public void set(String key, Object value) {        if(null==key||null==value){            return;        }        redisTemplate.opsForValue().set(key, value);    }    /**     * 設(shè)置key 的值 并設(shè)置過期時(shí)間     * @Author:     妖妖玖    迎學(xué)教育     * @UpdateUser:     * @Version:     0.0.1     * @param key    ? * @param value    ? * @param time    ? * @param unit     * @return       void     * @throws     */    public void set(String key,Object value,long time,TimeUnit unit){        if(null==key||null==value||null==unit){            return;        }        redisTemplate.opsForValue().set(key,value,time,unit);    }    /**     * 設(shè)置key 的值 并設(shè)置過期時(shí)間     * key存在 不做操作返回false     * key不存在設(shè)置值返回true     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key    ? * @param value    ? * @param time    ? * @param unit     * @return       java.lang.Boolean     * @throws     */    public Boolean setifAbsen(String key,Object value,long time,TimeUnit unit){        if(null==key||null==value||null==unit){            throw new BusinessException(4001004,"kkey、value、unit都不能為空");        }        return redisTemplate.opsForValue().setIfAbsent(key,value,time,unit);    }    /**     * 獲取指定Key的Value。如果與該Key關(guān)聯(lián)的Value不是string類型，Redis將拋出異常，     * 因?yàn)镚ET命令只能用于獲取string Value，如果該Key不存在，返回null     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key     * @return       java.lang.Object     * @throws     */    public Object get(String key){        if(null==key){            return null;        }        return  redisTemplate.opsForValue().get(key);    }    /**     * 很明顯先get再set就說先獲取key值對應(yīng)的value然后再set 新的value 值。     * @Author:     妖妖玖     * @UpdateUser:     * @Version:     0.0.1     * @param key    ? * @param value     * @return       java.lang.Object     * @throws     */    public Object getSet(String key,Object value){        if(null==key){            return null;        }        return redisTemplate.opsForValue().getAndSet(key,value);    }    /**     * 通過批量的key獲取批量的value     * @Author:     妖妖玖    迎學(xué)教育     * @UpdateUser:     * @Version:     0.0.1     * @param keys     * @return       java.util.List     * @throws     */    public List