springboot配置redis过程详解

2019-11-26 08:38:18

字体：大中小

来源：转载

供稿：网友

在springboot中，默认继承好了一套完好的redis包，可以直接使用，但是如果使用中出了错不容易找到错误的原因，因此这里使用自己配置的redis；

需要使用的三个主要jar包：

<dependency>      <groupId>redis.clients</groupId>      <artifactId>jedis</artifactId>      <version>2.9.0</version>    </dependency><dependency>      <groupId>org.springframework.data</groupId>      <artifactId>spring-data-redis</artifactId>    </dependency><dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-configuration-processor</artifactId>      <optional>true</optional>    </dependency>

使用spring-boot-configuration-processor包主要是用来配置加载文件

package com.zs.springboot.config.redis;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.stereotype.Component;/** * @Company * @Author Zs * 将这个类作为spring的一个组件，添加@ConfigurationProperties(prefix = "spring.redis")注解，就会默认从application.properties * 文件中加载前缀为spring.redis的配置信息，配置文件中的配置字段与该类中的属性一致，通过setter方法来设值 * @Date Create in 2019/8/30 **/@Component@ConfigurationProperties(prefix = "spring.redis")public class RedisProperties {  private String ip;  private Integer[] ports;  private Integer maxActive;  private Integer maxWait;  private Integer expire;  public String getIp() {    return ip;  }  public void setIp(String ip) {    this.ip = ip;  }  public Integer[] getPorts() {    return ports;  }  public void setPorts(Integer[] ports) {    this.ports = ports;  }  public Integer getMaxActive() {    return maxActive;  }  public void setMaxActive(Integer maxActive) {    this.maxActive = maxActive;  }  public Integer getMaxWait() {    return maxWait;  }  public void setMaxWait(Integer maxWait) {    this.maxWait = maxWait;  }  public Integer getExpire() {    return expire;  }  public void setExpire(Integer expire) {    this.expire = expire;  }}

在application中配置redis：

然后配置redis的配置类，使用jdisCluster来操作redis：

package com.zs.springboot.config.redis;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.context.properties.EnableConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.JedisCluster;import java.util.HashSet;import java.util.Set;/** * @Company * @Author Zs * @Date Create in 2019/8/30 **/@Configurationpublic class RedisConfiguration {  private RedisProperties redisProperties;  public RedisConfiguration(RedisProperties redisProperties) {    this.redisProperties = redisProperties;  }  @Bean  public JedisCluster jedisCluster() {    Integer[] ports = redisProperties.getPorts();    String host = redisProperties.getIp();    Set<HostAndPort> hostAndPortSet = new HashSet<>();    for (Integer port : ports) {      hostAndPortSet.add(new HostAndPort(host, port));    }    return new JedisCluster(hostAndPortSet, redisProperties.getMaxActive(), redisProperties.getMaxWait());  }}

编辑redis的增删该方法：

/** * @Company * @Author Zs * @Date Create in 2019/8/28 **/@Servicepublic class RedisService {  @Autowired  private JedisCluster jedisCluster;  private static final String SET_SUCCESS = "OK";  /**   * 添加string数据，成功返回code：200，失败code：404   * @param key   * @param value   * @return   */  public Map<String, Object> set(String key, Object value) {    Map<String, Object> map = new HashMap<>();    String result = jedisCluster.set(key, JsonUtil.toJsonString(value));    if (SET_SUCCESS.equals(result)) {      map.put(Status.SUCCESS.getCodeName(), Status.SUCCESS.getCode());    } else {      map.put(Status.FILED.getCodeName(), Status.FILED.getCode());    }    return map;  }  /**   * 从redis根据key获取string数据   * @param key   * @return   */  public String get(String key) {    String jsonString = jedisCluster.get(key);    if (jsonString==null || jsonString.equals("")) {      return null;    }    return jsonString;  }  /**   * 删除string数据   * @param key   * @return   */  public Map<String, Object> del(String key) {    Map<String, Object> map = new HashMap<>();    Long del = jedisCluster.del(key);    if (del>0) {      map.put("code", 200);    } else {      map.put("code", 404);    }    return map;  }  /**   * 设置失效时间   * @param key   * @param seconds   * @return   */  public Long expire(String key,Integer seconds) {    return jedisCluster.expire(key, seconds);  }}

注意不能在service层中注入service，如果需要可以在controller层将redisService做为参数传递进去，如果在service层中注入其他的service对象，可能造成事务的串联，读到脏数据。

该方法需要使用到jsonUtil类，将数据转为json字符串存储

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

上一篇：深入了解Spring中的FactoryBean

下一篇：Java实现图片倒影的源码实例内容