3分钟搞定springboot整合redis

不多说直接上代码：

<!-- redis -->

<dependency>

<groupId>orgspringframeworkboot</groupId>

<artifactId>spring-boot-starter-data-redis</artifactId>

<exclusions>

<exclusion>

<groupId>redisclients</groupId>

<artifactId>jedis</artifactId>

</exclusion>

<exclusion>

<groupId>iolettuce</groupId>

<artifactId>lettuce-core</artifactId>

</exclusion>

</exclusions>

</dependency>

<!-- 添加jedis客户端 -->

<dependency>

<groupId>redisclients</groupId>

<artifactId>jedis</artifactId>

</dependency>

<!--spring20集成redis所需common-pool2-->

<!-- 必须加上，jedis依赖此 -->

<dependency>

<groupId>orgapachecommons</groupId>

<artifactId>commons-pool2</artifactId>

<version>250</version>

</dependency>

<!-- 将作为Redis对象序列化器 -->

<dependency>

<groupId>comalibaba</groupId>

<artifactId>fastjson</artifactId>

<version>1247</version>

</dependency>

#Matser的ip地址

redishostName=1721644148

#端口号

redisport=6379

#如果有密码

redispassword=

#客户端超时时间单位是毫秒 默认是2000

redistimeout=10000

#最大空闲数

redismaxIdle=300

#连接池的最大数据库连接数。设为0表示无限制,如果是jedis 24以后用redismaxTotal

#redismaxActive=600

#控制一个pool可分配多少个jedis实例,用来替换上面的redismaxActive,如果是jedis 24以后用该属性

redismaxTotal=1000

#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。

redismaxWaitMillis=1000

#连接的最小空闲时间 默认1800000毫秒(30分钟)

redisminEvictableIdleTimeMillis=300000

#每次释放连接的最大数目,默认3

redisnumTestsPerEvictionRun=1024

#逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1

redistimeBetweenEvictionRunsMillis=30000

#是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个

redistestOnBorrow=true

#在空闲时检查有效性, 默认false

redistestWhileIdle=true

package comjunsidemoconfig;

import orgspringframeworkbeansfactoryannotationValue;

import orgspringframeworkcontextannotationBean;

import orgspringframeworkcontextannotationConfiguration;

import orgspringframeworkcontextannotationPropertySource;

import orgspringframeworkdataredisconnectionRedisConnectionFactory;

import orgspringframeworkdataredisconnectionjedisJedisConnectionFactory;

import orgspringframeworkdatarediscoreRedisTemplate;

import orgspringframeworkdataredisserializerGenericJackson2JsonRedisSerializer;

import orgspringframeworkdataredisserializerStringRedisSerializer;

import comjunsidemoutilsRedisUtil;

import redisclientsjedisJedisPoolConfig;

/

Redis配置类

@author pzx

2019年6月8日

/

@Configuration

@PropertySource("classpath:redisproperties")

public class RedisConfig {

@Value("${redismaxIdle}")

private Integer maxIdle;

@Value("${redismaxTotal}")

private Integer maxTotal;

@Value("${redismaxWaitMillis}")

private Integer maxWaitMillis;

@Value("${redisminEvictableIdleTimeMillis}")

private Integer minEvictableIdleTimeMillis;

@Value("${redisnumTestsPerEvictionRun}")

private Integer numTestsPerEvictionRun;

@Value("${redistimeBetweenEvictionRunsMillis}")

private long timeBetweenEvictionRunsMillis;

@Value("${redistestOnBorrow}")

private boolean testOnBorrow;

@Value("${redistestWhileIdle}")

private boolean testWhileIdle;

@Value("${springredisclusternodes}")

private String clusterNodes;

@Value("${springredisclustermax-redirects}")

private Integer mmaxRedirectsac;

/

JedisPoolConfig 连接池

@return

/

@Bean

public JedisPoolConfig jedisPoolConfig() {

JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();

// 最大空闲数

jedisPoolConfigsetMaxIdle(maxIdle);

// 连接池的最大数据库连接数

jedisPoolConfigsetMaxTotal(maxTotal);

// 最大建立连接等待时间

jedisPoolConfigsetMaxWaitMillis(maxWaitMillis);

// 逐出连接的最小空闲时间 默认1800000毫秒(30分钟)

jedisPoolConfigsetMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);

// 每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3

jedisPoolConfigsetNumTestsPerEvictionRun(numTestsPerEvictionRun);

// 逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1

jedisPoolConfigsetTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);

// 是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个

jedisPoolConfigsetTestOnBorrow(testOnBorrow);

// 在空闲时检查有效性, 默认false

jedisPoolConfigsetTestWhileIdle(testWhileIdle);

return jedisPoolConfig;

}

/

@param jedisPoolConfig

@return

/

@Bean

public JedisConnectionFactory JedisConnectionFactory(JedisPoolConfig jedisPoolConfig){

JedisConnectionFactory JedisConnectionFactory = new JedisConnectionFactory(jedisPoolConfig);

//连接池

JedisConnectionFactorysetPoolConfig(jedisPoolConfig);

//IP地址

JedisConnectionFactorysetHostName("1721644148");

//端口号

JedisConnectionFactorysetPort(6379);

//如果Redis设置有密码

//JedisConnectionFactorysetPassword(password);

//客户端超时时间单位是毫秒

JedisConnectionFactorysetTimeout(5000);

return JedisConnectionFactory;

}

/

实例化 RedisTemplate 对象

@return

/

@Bean

public RedisTemplate<String, Object> functionDomainRedisTemplate(RedisConnectionFactory redisConnectionFactory) {

RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();

initDomainRedisTemplate(redisTemplate, redisConnectionFactory);

return redisTemplate;

}

/

设置数据存入 redis 的序列化方式,并开启事务

@param redisTemplate

@param factory

/

private void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate, RedisConnectionFactory factory) {

//如果不配置Serializer，那么存储的时候缺省使用String，如果用User类型存储，那么会提示错误User can't cast to String！

redisTemplatesetKeySerializer(new StringRedisSerializer());

redisTemplatesetHashKeySerializer(new StringRedisSerializer());

redisTemplatesetHashValueSerializer(new GenericJackson2JsonRedisSerializer());

redisTemplatesetValueSerializer(new GenericJackson2JsonRedisSerializer());

// 开启事务

redisTemplatesetEnableTransactionSupport(true);

redisTemplatesetConnectionFactory(factory);

}

@Bean(name = "redisUtil")

public RedisUtil redisUtil(RedisTemplate<String, Object> redisTemplate) {

RedisUtil redisUtil = new RedisUtil();

redisUtilsetRedisTemplate(redisTemplate);

return redisUtil;

}

}

redis单机集群搭建好了之后，发现通过外网ip链接不了集群，一直报错。此时需要修改以下内容

bind 改为0000

关闭保护模型

最后也是最重要的一点，启动集群使用外网ip加端口号

并且修改生成的nodesconf文件中myself的内网地址为外网地址

Spring Boot是目前非常流行的Java Web开发框架，Redis是非关系型数据库的一种，以键值对的形式存储。Spring对Redis的支持是通过Spring Data Redis来实现的，给我们提供了RedisTemplate和StringRedisTemplate两种模板来 *** 作数据。Spring Boot框架也提供了对Redis的支持，下面我们来讲一下Spring Boot框架整合Redis的步骤。

工具/材料

IntelliJ IDEA

Spring Boot整合Redis我们需要添加依赖的jar包，spring-boot-starter-data-redis中包含spring和redis相关的jar包，jedis作为redis的客户端也需要添加到工程中，Spring Boot的版本信息在父pom中已指定，子模块中的spring相关的jar包无需另外指定。

<dependency>

<groupId>orgspringframeworkboot</groupId>

<artifactId>spring-boot-starter-data-redis</artifactId>

</dependency>

<dependency>

<groupId>redisclients</groupId>

<artifactId>jedis</artifactId>

<version>300-m1</version>

</dependency>

Spring Boot会根据applicationproperties中的配置对Redis的属性进行自动配置，并注入到RedisProperties类中。在applicationproperties配置文件中这些属性都是以springredis为前缀的，值得注意的是在Spring Boot 15x版本中默认的Redis客户端是jedis，因此在配置文件中无需指定，如下图所示。

Spring Boot 15x版本的整合配置网上可以搜索大量的文章，然而Spring Boot 2x版本的整合资料却非常少，甚至提供的配置不能正常使用，因此本文主要讲解Spring Boot 2x整合Redis以及Redis的使用情况。spring-boot 2x版本有jedis和lettuce两种客户端，因此我们必须要去指定使用哪一种客户端，两个客户端的配置如下图所示，本文使用的是Jedis客户端连接池，具体的配置如下。

# Redis数据库索引（默认为0）

springredisdatabase=0

# Redis服务器地址

springredishost=127001

# Redis服务器连接端口

springredisport=6379

# Redis服务器连接密码（默认为空）

springredispassword=xylx1t!@#

# 配置jedis连接池

# 连接池最大连接数（使用负值表示没有限制）

springredisjedispoolmax-active=8

# 连接池最大阻塞等待时间（使用负值表示没有限制）

springredisjedispoolmax-wait=-1ms

# 连接池中的最大空闲连接

springredisjedispoolmax-idle=8

# 连接池中的最小空闲连接

springredisjedispoolmin-idle=0

# 连接超时时间（毫秒）

springredistimeout=5000ms

由配置我们可以看到spring-boot 2x版本时间设置需要加单位ms，因为参数的类型为Duration。另外springredistimeout尽量不要配置0，否则可能会出现iolettucecoreRedisCommandTimeoutException: Command timed out超时错误。

配置文件编辑完成后，我们开始编写代码实现Redis数据的存储和读取。我们创建一个RedisUtil工具类，该类使用@Component注解表示交由Spring管理，StringRedisTemplate是Spring提供的，可以使用@Autowired注解直接注入，接下来便可以书写存和取的代码了。

@Component

public class RedisUtil {

@Autowired

private StringRedisTemplate redisTemplate;

/

存字符串

@param key 缓存键

@param value 缓存值

@param expireTime过期时间(s)

/

public void setString(String key, String value, int expireTime){

ValueOperations<String, String> ops = redisTemplateopsForValue();

if (expireTime != 0) {

opsset(key, value, expireTime, TimeUnitSECONDS);

} else {

opsset(key,value);

}

}

/

取字符串

@param key 缓存键

@return缓存值

/

public String getString(String key){

ValueOperations<String, String> ops = thisredisTemplateopsForValue();

return opsget(key);

}

接下来我们编写Controller层代码去调用RedisUtil工具类，实现数据的存储和读取，代码比较简单可以参考下图。若想验证Redis是否可用，还需要编写启动类，如下图所示。

由上图可看到我们编写了一个post请求用于存储字符串，get请求用于取出字符串。启动类通过main方法启动应用，接下来我们使用postman去模拟浏览器调用post和get请求，由下图可以看到Redis存储的数据成功被取出。

接下来我们介绍Jedis，这是一个封装了Redis的客户端，在Spring Boot整合Redis的基础上，可以提供更简单的API *** 作。因此我们需要配置JedisPool的Bean，代码如下，其中@Configuration注解表明这是一个配置类，我们在该类中注入RedisProperties，并且使用@Bean注解指定JedisPool。

@Configuration

public class RedisConfiguration {

@Autowired

private RedisProperties properties;

@Bean

public JedisPool getJedisPool(){

JedisPoolConfig config = new JedisPoolConfig();

configsetMaxIdle(propertiesgetJedis()getPool()getMaxIdle());

configsetMaxTotal(propertiesgetJedis()getPool()getMaxActive());

configsetMaxWaitMillis(propertiesgetJedis()getPool()getMaxWait()toMillis());

JedisPool pool = new JedisPool(config,propertiesgetHost(),

propertiesgetPort(),100,

propertiesgetPassword(), propertiesgetDatabase());

return pool;

}

}

接下来我们编辑JedisUtil工具类，通过SpringBoot容器的@Component注解来自动创建，并且注入JedisPool，使用jedisPoolgetResource()方法来获取Jedis，并最终实现 *** 作redis数据库，其代码如下。

@Component

public class JedisUtil {

@Autowired

JedisPool jedisPool;

//获取key的value值

public String get(String key) {

Jedis jedis = jedisPoolgetResource();

String str = "";

try {

str = jedisget(key);

} finally {

try {

jedisclose();

} catch (Exception e) {

eprintStackTrace();

}

}

return str;

}

public String set(String key, String value) {

Jedis jedis = jedisPoolgetResource();

String str = "";

try {

str = jedisset(key, value);

} finally {

try {

jedisclose();

} catch (Exception e) {

eprintStackTrace();

}

}

return str;

}

}

JedisUtil工具类编写完成后，我们修改之前的RedisController，并注入JedisUtil，代码如下图所示。然后再用postman分别调用post和get接口，我们可以看到成功取到了新的key的value值。

特别提示

在Spring Boot整合Redis前本机需安装Redis，另外可以使用RedisDesktopManager这个Redis这个桌面管理工具查看Redis中的数据。

以上就是关于3分钟搞定springboot整合redis全部的内容，包括:3分钟搞定springboot整合redis、JedisCluster连接redis集群一直报Could not get a resource from the pool、Spring Boot如何整合Redis等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！