一、简介
Redis 的数据库的整合在 java 里面提供的官方工具包：jedis，所以即便你现在使用的是 SpringBoot，那么也继续使用此开发包。
二、redidTemplate操作
在 Spring 支持的 Redis 操作之中提供有一个 RedisTemplate 处理程序类，利用这个类可以非常方便的实现 Redis 的各种基本数 据操作。
1、引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2、配置yml
spring:
redis:
host: 47.52.199.52
port:
password:
timeout:
database:
jedis:
pool:
max-active:
max-idle:
min-idle:
max-wait:
3、使用示例
@RunWith(SpringRunner.class)
@SpringBootTest
@WebAppConfiguration
public class DemoApplicationTests { @Resource
private RedisTemplate<String, String> redisTemplate; @Test
public void testRedis(){
redisTemplate.opsForValue().set("xing","12345678");
System.out.println(redisTemplate.opsForValue().get("xing"));
} }
三、配置多个Redis
由于在项目的实际开发过程之中 Redis 的使用会非常的频繁， 那么就有可能出现这样一种问题：现在的项目里面要求连接两 个 Redis 数据库。SpringBoot 里面针对于 Redis 的连接配置本质上只提供有一个连接配置项，那么如果你真的需要进行更多的 Redis 的连接配置，那么就需要自己来进行 Redis 的创建管理了。相当于直接使用spring-data-redis。
1、引入依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
2、配置yml
spring：
redis-two:
host: 47.52.199.52
port: 6379
password: 123456
timeout: 1000
database: 0
pool:
max-active: 10
max-idle: 8
min-idle: 2
max-wait: 100
3、初始化连接，创建实例
RedisTwoConfig.java
package com.example.demo.config.redisConfig; import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import redis.clients.jedis.JedisPoolConfig; @Configuration
public class RedisTwoConfig { @Bean("redisTwo")
public RedisTemplate<String, Object> getRedisTemplate(
@Value("${spring.redis-two.host}") String hostName,
@Value("${spring.redis-two.password}") String password,
@Value("${spring.redis-two.port}") int port,
@Value("${spring.redis-two.database}") int database,
@Value("${spring.redis-two.pool.max-active}") int maxActive,
@Value("${spring.redis-two.pool.max-idle}") int maxIdle,
@Value("${spring.redis-two.pool.min-idle}") int minIdle,
@Value("${spring.redis-two.pool.max-wait}") long maxWait) { System.out.println(hostName+port+password);
RedisConnectionFactory factory = this.getRedisConnectionFactory(
hostName, password, port, maxActive, maxIdle, minIdle, maxWait,
database); // 建立Redis的连接
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
redisTemplate.setConnectionFactory(factory);
redisTemplate.setKeySerializer(new StringRedisSerializer()); // key的序列化类型
redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer()); // value的序列化类型
return redisTemplate;
} public RedisConnectionFactory getRedisConnectionFactory(String hostName,
String password, int port, int maxActive, int maxIdle, int minIdle,
long maxWait, int database) { // 是负责建立Factory的连接工厂类
JedisConnectionFactory jedisFactory = new JedisConnectionFactory();
jedisFactory.setHostName(hostName);
jedisFactory.setPort(port);
jedisFactory.setPassword(password);
jedisFactory.setDatabase(database);
JedisPoolConfig poolConfig = new JedisPoolConfig(); // 进行连接池配置
poolConfig.setMaxTotal(maxActive);
poolConfig.setMaxIdle(maxIdle);
poolConfig.setMinIdle(minIdle);
poolConfig.setMaxWaitMillis(maxWait);
jedisFactory.setPoolConfig(poolConfig);
jedisFactory.afterPropertiesSet(); // 初始化连接池配置
return jedisFactory;
}
}
4、使用示例
@RunWith(SpringRunner.class)
@SpringBootTest
@WebAppConfiguration
public class RedisTest {
@Resource
private RedisTemplate<String, Object> redisTemplate; @Resource
private StringRedisTemplate stringRedisTemplate; @Resource(name = "redisTwo")
private RedisTemplate<String, Object> redisTemplate2; @Test
public void testRedis2(){
UserPO userPO = new UserPO();
userPO.setAge(25);
userPO.setName("小明");
userPO.setUid(111L);
redisTemplate2.opsForValue().set("user25",userPO);
UserPO result = (UserPO) redisTemplate2.opsForValue().get("user25");
System.out.println(result);
}
}