Java整合Redis_Spring-Data-Redis环境搭建-【官方】百战程序员_IT在线教育培训机构

序列化器	说明
JdkSerializationRedisSerializer	POJO对象的存取场景，使用JDK本身序列化机制，将pojo类通过ObjectInputstream/ObjectOutputstream进行序列化操作，最终redis-server中将存储字节序列。是目前最常用的序列化策略。
StringRedisSerializer	Key或者value为字符串的场景，根据指定的charset对数据的字节序列编码成string,是"new String(bytes,charset)"和“string.getBytes(charset)"的直接封装。是最轻量级和高效的策略。
GenericJackson2JsonRedisSerializer	jackson-json工具提供了javabean与json之间的转换能力，可以将pojo实例序列化成json格式存储在redis中，也可以将json格式的数据转换成pojo实例。

添加依赖


xxxxxxxxxx
 <dependencies>
        <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>
        </dependency>
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

RedisTemplate的配置

自定义序列化方式。


xxxxxxxxxx

@Configuration
public class RedisConfig {
 
    /**
     * 创建RedisTemplate:用于执行Redis操作的方法
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory)    {
        RedisTemplate<String, Object> redisTemplate= new RedisTemplate<String, Object>();
        redisTemplate.setConnectionFactory(factory);
 
        //设置通用序列化器
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
        
        return redisTemplate;
    }
}

在application.properties中配置


xxxxxxxxxx
#Redis服务器连接地址
spring.data.redis.host=192.168.47.100
#Redis服务器连接端口
spring.data.redis.port=6379

操作RedisTemplate方法


xxxxxxxxxx
redisTemplate.opsForValue();//操作字符串
redisTemplate.opsForHash();//操作hash
redisTemplate.opsForList();//操作list
redisTemplate.opsForSet();//操作set
redisTemplate.opsForZSet();//操作有序set

使用StringRedisTemplate进行各类型的CURD操作

String数据类型操作

添加元素


xxxxxxxxxx
public boolean set(String key,Object value){
    try{
     redisTemplate.opsForValue().set(key,value);
            return true;
        }catch (Exception e){
            log.error("redis set value exception:{}",e);
            return false;
        }
    }

获取元素


xxxxxxxxxx
 public Object get(String key){
        return  key == null ? null : redisTemplate.opsForValue().get(key);
    }

添加元素并设置过期时间


xxxxxxxxxx
public boolean setex(String key,Object value,long expire){
        try{
            //TimeUnit.SECONDS指定类型为秒
            redisTemplate.opsForValue().set(key,value,expire,              TimeUnit.SECONDS);
            return true;
        }catch (Exception e){
            log.error("redis set value and expire exception:{}",e);
            return false;
        }
    }

Hash类型的操作

添加元素


xxxxxxxxxx
public boolean hset(String key, String field, Object value,long seconds) {
        try {
            redisTemplate.opsForHash().put(key, field, value);
            expire(key,seconds);//调用通用方法设置过期时间
            return true;
        }catch (Exception e){
            log.error("redis hset and expire eror,key:{},field:{},value:{},exception:{}",key,field,value,e);
            return false;
        }
    }

获取数据


xxxxxxxxxx
public Object hget(String key,String field){
        return redisTemplate.opsForHash().get(key,field);
    }

set类型的操作

添加元素


xxxxxxxxxx
   public long sset(String key ,Object...values){
        try {
            return redisTemplate.opsForSet().add(key,values);
        }catch (Exception e){
            log.error("redis sset error,key:{},value:{},values:{},exception:{}",key,values,e);
            return 0;
        }
    }

获取set的长度


xxxxxxxxxx
public long sgetSize(String key){
        try {
            return redisTemplate.opsForSet().size(key);
        }catch (Exception e){
            log.error("redis sgetSize error,key:{},exception:{}",key,e);
            return 0;
        }
    }

获取元素


xxxxxxxxxx
 public Set<Object> sgetAll(String key){
        try {
            return redisTemplate.opsForSet().members(key);
        }catch (Exception e){
            log.error("redis sgetAll error,key:{},exception:{}",key,e);
            return null;
        }
    }

zset类型的操作

添加元素


xxxxxxxxxx
  public  boolean zadd(String key,Object member,double score){
        try {
            return  redisTemplate.opsForZSet().add(key,member,score);
        } catch (Exception e) {
            log.error("redis zadd error,key:{},value:{},score:{},exception:{}",key,member,score,e);
            return false;
        }
    }

获取元素


xxxxxxxxxx
   public  Set<String> zrange(String key,int start,int end){
        try {
            Set<Object> range = redisTemplate.opsForZSet().
                    range(key, start, end);
            if(range==null||range.size()==0) return null;
            return   range.stream().
                    map(o->(String)o).collect(Collectors.toSet());
        } catch (Exception e) {
            log.error("redis zrange error,key:{},start:{},end:{},exception:{}",
                    key,start,end,e);
            return null;
        }
    }

list类型的操作

添加元素


xxxxxxxxxx
  public boolean lrpush(String key, Object value) {
        try {
 redisTemplate.opsForList().rightPush(key, value);
            return true;
        } catch (Exception e) {
            log.error("redis lrpush error,key:{},value:{}exception:{}",key,value,e);
            return false;
        }
    }

获取元素


xxxxxxxxxx
    public List<Object> getList(String key,int start,int end) {
        try {
            List<Object> o = redisTemplate.opsForList().range(key,start,end);
            return o;
        } catch (Exception e) {
            return null;
        }
    }

JAVA最全学习路线图和就业分析

北京市昌平区回龙观镇南店村综合商业楼2楼226室