Spring Boot Redis 集成配置详解

spring Boot 熟悉后，集成一个外部扩展是一件很容易的事，集成Redis也很简单，看下面步骤配置：

一、添加pom依赖

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-redis</artifactId>
    </dependency>

二、创建 RedisClient.java

注意该类存放的package

package org.springframework.data.redis.connection.jedis;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.UnsupportedEncodingException;

import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Protocol;
import redis.clients.jedis.exceptions.JedisException;

/**
 * 工具类 RedisClient
 * 因为本类中获取JedisPool调用的是JedisConnectionFactory中protected修饰的方法fetchJedisConnector()
 * 所以该类需要与JedisConnectionFactory在同一个package中
 *
 * @author 单红宇(CSDN CATOOP)
 * @create 2017年4月9日
 */
public class RedisClient {

  private static Logger logger = LoggerFactory.getLogger(RedisClient.class);

  private JedisConnectionFactory factory;

  public RedisClient(JedisConnectionFactory factory) {
    super();
    this.factory = factory;
  }

  /**
   * put操作（存储序列化对象）+ 生效时间
   * 
   * @param key
   * @param value
   * @return
   */
  public void putObject(final String key, final Object value, final int cacheSeconds) {
    if (StringUtils.isNotBlank(key)) {
      redisTemplete(key, new RedisExecute<Object>() {
        @Override
        public Object doInvoker(Jedis jedis) {
          try {
            jedis.setex(key.getBytes(Protocol.CHARSET), cacheSeconds, serialize(value));
          } catch (UnsupportedEncodingException e) {
          }

          return null;
        }
      });
    }
  }

  /**
   * get操作（获取序列化对象）
   * 
   * @param key
   * @return
   */
  public Object getObject(final String key) {
    return redisTemplete(key, new RedisExecute<Object>() {
      @Override
      public Object doInvoker(Jedis jedis) {
        try {
          byte[] byteKey = key.getBytes(Protocol.CHARSET);
          byte[] byteValue = jedis.get(byteKey);
          if (byteValue != null) {
            return deserialize(byteValue);
          }
        } catch (UnsupportedEncodingException e) {
          return null;
        }
        return null;
      }
    });
  }

  /**
   * setex操作
   * 
   * @param key
   *      键
   * @param value
   *      值
   * @param cacheSeconds
   *      超时时间，0为不超时
   * @return
   */
  public String set(final String key, final String value, final int cacheSeconds) {
    return redisTemplete(key, new RedisExecute<String>() {
      @Override
      public String doInvoker(Jedis jedis) {
        if (cacheSeconds == 0) {
          return jedis.set(key, value);
        }
        return jedis.setex(key, cacheSeconds, value);
      }
    });
  }

  /**
   * get操作
   * 
   * @param key
   *      键
   * @return 值
   */
  public String get(final String key) {
    return redisTemplete(key, new RedisExecute<String>() {
      @Override
      public String doInvoker(Jedis jedis) {
        String value = jedis.get(key);
        return StringUtils.isNotBlank(value) && !"nil".equalsIgnoreCase(value) ? value : null;
      }
    });
  }

  /**
   * del操作
   * 
   * @param key
   *      键
   * @return
   */
  public long del(final String key) {
    return redisTemplete(key, new RedisExecute<Long>() {
      @Override
      public Long doInvoker(Jedis jedis) {
        return jedis.del(key);
      }
    });
  }

  /**
   * 获取资源
   * 
   * @return
   * @throws JedisException
   */
  public Jedis getResource() throws JedisException {
    Jedis jedis = null;
    try {
      jedis = factory.fetchJedisConnector();
    } catch (JedisException e) {
      logger.error("getResource.", e);
      returnBrokenResource(jedis);
      throw e;
    }
    return jedis;
  }

  /**
   * 获取资源
   * 
   * @return
   * @throws JedisException
   */
  public Jedis getJedis() throws JedisException {
    return getResource();
  }

  /**
   * 归还资源
   * 
   * @param jedis
   * @param isBroken
   */
  public void returnBrokenResource(Jedis jedis) {
    if (jedis != null) {
      jedis.close();
    }
  }

  /**
   * 释放资源
   * 
   * @param jedis
   * @param isBroken
   */
  public void returnResource(Jedis jedis) {
    if (jedis != null) {
      jedis.close();
    }
  }

  /**
   * 操作jedis客户端模板
   * 
   * @param key
   * @param execute
   * @return
   */
  public <R> R redisTemplete(String key, RedisExecute<R> execute) {
    Jedis jedis = null;
    try {
      jedis = getResource();
      if (jedis == null) {
        return null;
      }

      return execute.doInvoker(jedis);
    } catch (Exception e) {
      logger.error("operator redis api fail,{}", key, e);
    } finally {
      returnResource(jedis);
    }
    return null;
  }

  /**
   * 功能简述: 对实体Bean进行序列化操作.
   * 
   * @param source
   *      待转换的实体
   * @return 转换之后的字节数组
   * @throws Exception
   */
  public static byte[] serialize(Object source) {
    ByteArrayOutputStream byteOut = null;
    ObjectOutputStream ObjOut = null;
    try {
      byteOut = new ByteArrayOutputStream();
      ObjOut = new ObjectOutputStream(byteOut);
      ObjOut.writeObject(source);
      ObjOut.flush();
    } catch (IOException e) {
      e.printStackTrace();
    } finally {
      try {
        if (null != ObjOut) {
          ObjOut.close();
        }
      } catch (IOException e) {
        ObjOut = null;
      }
    }
    return byteOut.toByteArray();
  }

  /**
   * 功能简述: 将字节数组反序列化为实体Bean.
   * 
   * @param source
   *      需要进行反序列化的字节数组
   * @return 反序列化后的实体Bean
   * @throws Exception
   */
  public static Object deserialize(byte[] source) {
    ObjectInputStream ObjIn = null;
    Object retVal = null;
    try {
      ByteArrayInputStream byteIn = new ByteArrayInputStream(source);
      ObjIn = new ObjectInputStream(byteIn);
      retVal = ObjIn.readObject();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        if (null != ObjIn) {
          ObjIn.close();
        }
      } catch (IOException e) {
        ObjIn = null;
      }
    }
    return retVal;
  }

  interface RedisExecute<T> {
    T doInvoker(Jedis jedis);
  }
}

三、创建Redis配置类

RedisConfig.Java

package com.shanhy.example.redis;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.connection.jedis.RedisClient;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * Redis配置
 * 
 * @author 单红宇(CSDN catoop)
 * @create 2016年9月12日
 */
@Configuration
public class RedisConfig {

  @Bean
  public RedisTemplate<String, Object> redisTemplate(JedisConnectionFactory factory) {
    RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
    template.setConnectionFactory(factory);
    template.setKeySerializer(new StringRedisSerializer());
    template.setValueSerializer(new RedisObjectSerializer());
    template.afterPropertiesSet();
    return template;
  }

  @Bean
  public RedisClient redisClient(JedisConnectionFactory factory){
    return new RedisClient(factory);
  }
}

RedisObjectSerializer.java

package com.shanhy.example.redis;

import org.springframework.core.convert.converter.Converter;
import org.springframework.core.serializer.support.DeserializingConverter;
import org.springframework.core.serializer.support.SerializingConverter;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.SerializationException;

/**
 * 实现对象的序列化接口
 * @author  单红宇(365384722)
 * @create  2017年4月9日
 */
public class RedisObjectSerializer implements RedisSerializer<Object> {

  private Converter<Object, byte[]> serializer = new SerializingConverter();
  private Converter<byte[], Object> deserializer = new DeserializingConverter();

  static final byte[] EMPTY_ARRAY = new byte[0];

  @Override
  public Object deserialize(byte[] bytes) {
    if (isEmpty(bytes)) {
      return null;
    }

    try {
      return deserializer.convert(bytes);
    } catch (Exception ex) {
      throw new SerializationException("Cannot deserialize", ex);
    }
  }

  @Override
  public byte[] serialize(Object object) {
    if (object == null) {
      return EMPTY_ARRAY;
    }

    try {
      return serializer.convert(object);
    } catch (Exception ex) {
      return EMPTY_ARRAY;
    }
  }

  private boolean isEmpty(byte[] data) {
    return (data == null || data.length == 0);
  }

}

四、创建测试方法

下面代码随便放一个Controller里

  @Autowired
  private RedisTemplate<String, Object> redisTemplate;

  /**
   * 缓存测试
   *
   * @return
   * @author SHANHY
   * @create 2016年9月12日
   */
  @RequestMapping("/redisTest")
  public String redisTest() {
    try {
      redisTemplate.opsForValue().set("test-key", "redis测试内容", 2, TimeUnit.SECONDS);// 缓存有效期2秒

      logger.info("从Redis中读取数据：" + redisTemplate.opsForValue().get("test-key").toString());

      TimeUnit.SECONDS.sleep(3);

      logger.info("等待3秒后尝试读取过期的数据：" + redisTemplate.opsForValue().get("test-key"));
    } catch (InterruptedException e) {
      e.printStackTrace();
    }

    return "OK";
  }

五、配置文件配置Redis

application.yml

spring:
 # Redis配置
 redis:
  host: 192.168.1.101
  port: 6379
  password:
  # 连接超时时间（毫秒）
  timeout: 10000
  pool:
   max-idle: 20
   min-idle: 5
   max-active: 20
   max-wait: 2

这样就完成了Redis的配置，可以正常使用 redisTemplate 了。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# springboot集成redis  # spring  # boot  # redis  # 详解springboot配置多个redis连接  # SpringBoot项目中使用redis缓存的方法步骤  # springboot与redis的简单整合实例  # Spring Boot整合Redis的完整步骤  # 在SpringBoot中添加Redis及配置方法  # SpringBoot中使用Redis的完整实例  # Spring Boot中使用Redis实战案例  # 序列化  # 的是  # 很容易  # 也很  # 正常使用  # 配置文件  # 大家多多  # 类中  # 客户端  # 完成了  # 因为本  # 是一件  # 在同一个  # logger  # getLogger  # static  # put  # private  # amp  # param 

相关文章： ,如何利用word制作宣传手册？  微信h5制作网站有哪些,免费微信H5页面制作工具？  郑州企业网站制作公司,郑州招聘网站有哪些？  广东专业制作网站有哪些,广东省能源集团有限公司官网？  实例解析angularjs的filter过滤器  建站上传速度慢？如何优化加速网站加载效率？  成都网站制作报价公司,成都工业用气开户费用？  网站制作公司,橙子建站是合法的吗？  宝塔建站后网页无法访问如何解决？  招贴海报怎么做,什么是海报招贴？  高端建站三要素：定制模板、企业官网与响应式设计优化  表情包在线制作网站免费,表情包怎么弄？  C++时间戳转换成日期时间的步骤和示例代码  建站之星价格显示格式升级，你的预算足够吗？  广州建站公司哪家好？十大优质服务商推荐  微网站制作教程,不会写代码，不会编程，怎么样建自己的网站？  C#怎么创建控制台应用 C# Console App项目创建方法  建站之星如何助力企业快速打造五合一网站？  如何用PHP快速搭建高效网站？分步指南  已有域名建站全流程解析：网站搭建步骤与建站工具选择  北京网站制作公司哪家好一点,北京租房网站有哪些？  如何用狗爹虚拟主机快速搭建网站？  专业网站建设制作报价,网页设计制作要考什么证？  上海网站制作开发公司,上海买房比较好的网站有哪些？  网站代码制作软件有哪些,如何生成自己网站的代码？  浙江网站制作公司有哪些,浙江栢塑信息技术有限公司定制网站做的怎么样？  如何将凡科建站内容保存为本地文件？  如何快速生成橙子建站落地页链接？  整人网站在线制作软件,整蛊网站退不出去必须要打我是白痴才能出去？  如何访问已购建站主机并解决登录问题？  建站之星如何实现PC+手机+微信网站五合一建站？  重庆市网站制作公司,重庆招聘网站哪个好？  太平洋网站制作公司,网络用语太平洋是什么意思？  深圳网站制作案例,网页的相关名词有哪些？  建站之星好吗？新手能否轻松上手建站？  哪家制作企业网站好,开办像阿里巴巴那样的网络公司和网站要怎么做？  如何快速辨别茅台真假？关键步骤解析  南京做网站制作公司,南京哈发网络有限公司，公司怎么样，做网页美工DIV+CSS待遇怎么样？  想学网站制作怎么学,建立一个网站要花费多少？  如何快速搭建支持数据库操作的智能建站平台？  魔毅自助建站系统：模板定制与SEO优化一键生成指南  西安专业网站制作公司有哪些,陕西省建行官方网站？  如何自定义建站之星网站的导航菜单样式？  如何确保西部建站助手FTP传输的安全性？  建站之星安装失败：服务器环境不兼容？  在线ppt制作网站有哪些,请推荐几个好的课件下载的网站？  长沙做网站要多少钱,长沙国安网络怎么样？  定制建站模板如何实现SEO优化与智能系统配置？18字教程  如何安全更换建站之星模板并保留数据？  建站之星如何通过成品分离优化网站效率？