您的位置：首页 > 数据库 > Redis

SpringBoot集成Redis的三种方式

2020-03-21 00:00 761 查看

SpringBoot集成Redis的三种方式:

AutoConfig加载
自己写代码加载
xml加载

使用这三种方式都需要：

1.添加依赖

2.写配置信息

spring.redis.database=0
spring.redis.host=localhost
spring.redis.port=6379
# 连接超时时间单位 ms（毫秒）
spring.redis.timeout=3000

# 连接池中的最大空闲连接，默认值也是8。
spring.redis.pool.max-idle=8
#连接池中的最小空闲连接，默认值也是0。
spring.redis.pool.min-idle=0
# 如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
spring.redis.pool.max-active=8
# 等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException
spring.redis.pool.max-wait=-1

方式一：使用Autoconfiguration自动加载。

因为上面引入了spring-boot-start-data-redis，所以可以使用RedisAutoConfiguration类加载properties文件的配置。

**
* Standard Redis configuration.
*/
@Configuration
protected static class RedisConfiguration {

@Bean
@ConditionalOnMissingBean(name = "redisTemplate")
public RedisTemplate<Object, Object> redisTemplate(
RedisConnectionFactory redisConnectionFactory)
throws UnknownHostException {
RedisTemplate<Object, Object> template = new RedisTemplate<Object, Object>();
template.setConnectionFactory(redisConnectionFactory);
return template;
}

@Bean
@ConditionalOnMissingBean(StringRedisTemplate.class)
public StringRedisTemplate stringRedisTemplate(
RedisConnectionFactory redisConnectionFactory)
throws UnknownHostException {
StringRedisTemplate template = new StringRedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
return template;
}
}

此种方式会默认加载applicaiton中的redis配置，提供了以下两种bean

RedisTemplate<Object,Object> 可以对Redis中key和value都为object类型的数据进行操作,默认会将对象使用JdkSerializationRedisSerializer进行序列化

StringRedisTemplate可以对Redis中key和value都是String类型的数据进行操作。

方式二：自己写代码加载。

@Configuration
public class RedisConfig{

private Logger logger = LoggerFactory.getLogger(this.getClass());

@Value("${spring.redis.host}")
private String host;

@Value("${spring.redis.port}")
private int port;

@Value("${spring.redis.timeout}")
private int timeout;

@Value("${spring.redis.password}")
private String password;

@Value("${spring.redis.database}")
private int database;

@Value("${spring.redis.pool.max-idle}")
private int maxIdle;

@Value("${spring.redis.pool.min-idle}")
private int minIdle;

/**
* redis模板，存储关键字是字符串，值是Jdk序列化
* @Description:
* @param factory
* @return
*/
@Bean
public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory) {
RedisTemplate<String,Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(factory);
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(redisSerializer);
redisTemplate.setHashKeySerializer(redisSerializer);
//JdkSerializationRedisSerializer序列化方式;
JdkSerializationRedisSerializer jdkRedisSerializer=new JdkSerializationRedisSerializer();
redisTemplate.setValueSerializer(jdkRedisSerializer);
redisTemplate.setHashValueSerializer(jdkRedisSerializer);
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
}

方式三：使用xml加载。

在程序入口添加：

@ImportResource(locations={"classpath:spring-redis.xml"})

在resource文件夹下新建文件spring-redis.xml

使用：

用注解注入Template，直接调用就好了。

@Repository
public class RedisService {

@Autowired
StringRedisTemplate stringRedisTemplate;

public void add(String key, User user, Long time) {
Gson gson = new Gson();
stringRedisTemplate.opsForValue().set(key, gson.toJson(user), time, TimeUnit.MINUTES);
}

public void add(String key, List<User> users, Long time) {
Gson gson = new Gson();
String src = gson.toJson(users);
stringRedisTemplate.opsForValue().set(key, src, time, TimeUnit.MINUTES);
}

public User get(String key) {
String source = stringRedisTemplate.opsForValue().get(key);
if (!StringUtils.isEmpty(source)) {
return new Gson().fromJson(source, User.class);
}
return null;
}

public List<User> getUserList(String key) {
String source = stringRedisTemplate.opsForValue().get(key);
if (!StringUtils.isEmpty(source)) {
return new Gson().fromJson(source, new TypeToken<List<User>>() {
}.getType());
}
return null;
}

public void delete(String key) {
stringRedisTemplate.opsForValue().getOperations().delete(key);
}
}

��果是测试的话：

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class RedisTest {

@Autowired
RedisService redisService;

@Before
public void setUp() {

}

@Test
public void get() {
User user = new User();
user.setName("wangjianfeng");
user.setAge(22);
redisService.add("userByName:" + user.getName(), user, 10L);
List<User> list = new ArrayList<>();
list.add(user);
redisService.add("list", list, 10L);
User user1 = redisService.get("userByName:wangjianfeng");
Assert.notNull(user1, "user is null");
List<User> list2 = redisService.getUserList("list");
Assert.notNull(list2, "list is null");
}
}

SpringBoot使用Redis缓存：

Springboot提供了很多缓存管理器，比如：

SimpleCacheManager
EhCacheManager
CaffeineCacheManager
GuavaCacheManager
CompositeCacheManager

SpringData提供了缓存管理器：RedisCacheManager

在SpringBoot中，在程序入口，加上@EnableCaching注解自动化配置合适的管理器。

然后我们使用自己写代码配置的方式，修改RedisConfig添加@EnableCaching注解，并继承CachingCongigurerSupport

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport{
...
}

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签： SpringBoot集成Redis

相关文章推荐

新的分享

章节导航