Spring Boot整合Redis && Jackson Null值处理

还是使用上次的工程
pom.xml中引入依赖

<!-- redis组件 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

application.yml新增配置

spring:
  redis:
      open: false  # 是否开启redis缓存  true开启   false关闭
      database: 0 #redis默认有16个库
      host: 127.0.0.1
      port: 6379
      password:
      timeout: 6000
      pool:
        max-active: 20   # 连接池最大连接数（使用负值表示没有限制）
        max-wait: -1     # 连接池最大阻塞等待时间（使用负值表示没有限制）
        max-idle: 10     # 连接池中的最大空闲连接
        min-idle: 5      # 连接池中的最小空闲连接

启动redis服务 默认端口6379


创建RedisConfig配置类

package com.xiaohan.bootdemo.config;

import org.springframework.beans.factory.annotation.Autowired;
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.core.ValueOperations;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisConfig {
    @Autowired
    private RedisConnectionFactory factory;

    @Bean
    public RedisTemplate<String, Object> redisTemplate() {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        // serializer策略
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashValueSerializer(new StringRedisSerializer());
        redisTemplate.setConnectionFactory(factory);
        return redisTemplate;
    }

    // 简单K-V操作
    @Bean
    public ValueOperations<String,String> valueOperations(RedisTemplate<String, String> redisTemplate){
        return redisTemplate.opsForValue();
    }
}

因为存储的为key-value形式 需要对实体进行json转换操作
所以这里先创建一个Jackson工具类
将null值替换为空字符串 和 时间可以转换为yyyy-MM-dd HH:mm:ss格式

package com.xiaohan.bootdemo.util;


import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.JsonSerializer;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializerProvider;

import java.io.IOException;
import java.text.SimpleDateFormat;

public class JacksonUtils {

    /* 默认时间转换格式 */
    private static String pattern = "yyyy-MM-dd HH:mm:ss";

    /* null不序列化 时间转换 yyyy-MM-dd HH:mm:ss 格式 */
    public static ObjectMapper createObjectMapperNullNotEcho() {
        ObjectMapper objectMapper = createObjectMapper(false, pattern);
        objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
        return objectMapper;
    }

    /* null不序列化  时间转换指定格式 */
    public static ObjectMapper createObjectMapperNullNotEcho(String pattern) {
        ObjectMapper objectMapper = createObjectMapper(false, pattern);
        objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
        return objectMapper;
    }

    /* 可指定是否替换null为空字符串"" 时间转换 yyyy-MM-dd HH:mm:ss 格式*/
    public static ObjectMapper createObjectMapper(boolean nullToString) {
        return createObjectMapper(nullToString,pattern);
    }

    /* 可指定是否替换null为空字符串"" 时间转换指定格式 */
    public static ObjectMapper createObjectMapper(boolean nullToString, String pattern) {
        ObjectMapper objectMapper = nullToString ? new ObjectMappingNullToString() : new ObjectMapper();
        if (pattern != null){
            SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
            objectMapper.setDateFormat(simpleDateFormat);
        }
        return objectMapper;
    }

    public static class ObjectMappingNullToString extends ObjectMapper {
        public ObjectMappingNullToString() {
            super();
            // 空值处理为空串
            this.getSerializerProvider().setNullValueSerializer(new JsonSerializer<Object>() {
                @Override
                public void serialize(Object value, JsonGenerator jg, SerializerProvider sp) throws IOException {
                    jg.writeString("");
                }
            });
        }
    }
}

接下来创建RedisUtils

package com.xiaohan.bootdemo.util;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.util.concurrent.TimeUnit;

@Component
public class RedisUtils {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;
    @Autowired
    private ValueOperations<String, String> valueOperations;

    /* 默认过期时长，单位：秒 */
    public final static long DEFAULT_EXPIRE = 60 * 60 * 24;
    /* 不设置过期时长 */
    public final static long NOT_EXPIRE = -1;


    public void set(String key, Object object) throws JsonProcessingException {
        set(key, object, DEFAULT_EXPIRE);
    }

    public void set(String key, Object object, long expire) throws JsonProcessingException {
        if (expire == NOT_EXPIRE) {
            valueOperations.set(key, toJson(object));
        } else {
            valueOperations.set(key, toJson(object), expire, TimeUnit.SECONDS);
        }
    }

    /* 获取指定类型的值  刷新生存时长 */
    public <T> T get(String key, Class<T> clazz, long expire) throws IOException {
        String value = valueOperations.get(key);
        if (expire != NOT_EXPIRE) {
            redisTemplate.expire(key, expire, TimeUnit.SECONDS);
        }
        return value == null ? null : fromJson(value, clazz);
    }

    /* 获取指定类型的值  不刷新生存时长 */
    public <T> T get(String key, Class<T> clazz) throws IOException {
        return get(key, clazz, NOT_EXPIRE);
    }

    /* 获取String类型的值  刷新生存时长 */
    public String get(String key, long expire) {
        String value = valueOperations.get(key);
        if(expire != NOT_EXPIRE){
            redisTemplate.expire(key, expire, TimeUnit.SECONDS);
        }
        return value;
    }

    /* 获取String类型的值  不刷新生存时长 */
    public String get(String key) {
        return get(key,NOT_EXPIRE);
    }

    /* 删除 */
    public void delete(String key) {
        redisTemplate.delete(key);
    }

    /**
     * Object转成JSON数据
     */
    private String toJson(Object object) throws JsonProcessingException {
        if (object instanceof Integer || object instanceof Long || object instanceof Float || object instanceof Double || object instanceof Boolean || object instanceof String) {
            return String.valueOf(object);
        }
        ObjectMapper objectMapper = JacksonUtils.createObjectMapper(true, null);
        // ObjectMapper objectMapper = JacksonUtils.createObjectMapperNullNotEcho(null);
        return objectMapper.writeValueAsString(object);
    }

    /**
     * JSON数据，转成Object
     */
    private <T> T fromJson(String json, Class<T> clazz) throws IOException {
        ObjectMapper objectMapper = JacksonUtils.createObjectMapper(true, null);
        return objectMapper.readValue(json, clazz);
    }
}

然后创建测试类进行测试

package com.xiaohan.bootdemo;

import com.xiaohan.bootdemo.entity.UserEntity;
import com.xiaohan.bootdemo.util.RedisUtils;
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.test.context.junit4.SpringRunner;

import java.io.IOException;
import java.util.Date;

@RunWith(SpringRunner.class)
@SpringBootTest
public class RedisTests {

    @Autowired
    private RedisUtils redisUtils;

    @Test
    public void testSet() throws IOException {
        UserEntity userEntity =new UserEntity();
        userEntity.setId(1);
        userEntity.setName("张三");
        userEntity.setCreateTime(new Date());
        redisUtils.set(userEntity.getId()+"",userEntity);

        String s = redisUtils.get(userEntity.getId() + "");
        System.err.println(s);

        UserEntity user = redisUtils.get(userEntity.getId() + "",UserEntity.class);
        System.err.println(user);


        redisUtils.delete(userEntity.getId()+"");
        s = redisUtils.get(userEntity.getId() + "");
        System.err.println(s);
    }
}

输出结果

{"id":1,"name":"张三","createTime":1502470327435}
UserEntity{id=1, name='张三', createTime=Sat Aug 12 00:52:07 CST 2017}
null

接下来我们来做个切面类
pom.xml加入aop组件

<!-- aop组件 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
</dependency>

新建一个切面类

package com.xiaohan.bootdemo.aspect;


import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

/**
 * Redis切面处理类
 */
@Aspect
@Configuration
public class RedisAspect {
    private Logger logger = LoggerFactory.getLogger(getClass());
    //是否开启redis缓存  true开启  false关闭
    @Value("${spring.redis.open: #{false}}")
    private boolean open;

    @Around("execution(* com.xiaohan.bootdemo.util.RedisUtils.*(..))")
    public Object around(ProceedingJoinPoint point) throws Throwable {
        Object result = null;
        if(open){
            try{
                result = point.proceed();
            }catch (Exception e){
                logger.error("redis error", e);
                throw new RuntimeException("Redis服务异常");
            }
        }
        return result;
    }
}

将 application.yml中的redis open设为true


image.png

在运行测试类就好了

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 213,014评论 6赞 492
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,796评论 3赞 386
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 158,484评论 0赞 348
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,830评论 1赞 285
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 65,946评论 6赞 386
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,114评论 1赞 292
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,182评论 3赞 412
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,927评论 0赞 268
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,369评论 1赞 303
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,678评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,832评论 1赞 341
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,533评论 4赞 335
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,166评论 3赞 317
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,885评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,128评论 1赞 267
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,659评论 2赞 362
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,738评论 2赞 351

推荐阅读更多精彩内容

  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,639评论 18赞 139
  • Spring boot参考指南
    Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,781评论 6赞 342
  • Spring Boot 参考指南3（1.5.2.RELEASE）
    此篇翻译的是Spring Boot官方指南 Part III. 使用 Spring Boot (Using Spr...
    K天道酬勤阅读 6,726评论 0赞 21
  • 短信
    新年在即，常怀感恩之心，常念相助之人，常感相识之缘，常忆朋友之情！真正的情谊，贵时不重，贫时不轻。真正的快乐，节日...
    物化长新阅读 218评论 0赞 0
  • 温柔的晚风
    温柔的晚风 1 台风在南方肆虐着，北方还浸在伏热之中。虽说已入秋，但炎热还是不停的出来浪一下。 早上推开窗户一股清...
    生达成长规划阅读 413评论 0赞 1