SpringBoot對常用的數(shù)據(jù)庫支持外，對NoSQL 數(shù)據(jù)庫也進(jìn)行了封裝自動(dòng)化。
redis介紹
Redis是目前業(yè)界使用最廣泛的內(nèi)存數(shù)據(jù)存儲(chǔ)。相比memcached，Redis支持更豐富的數(shù)據(jù)結(jié)構(gòu)，例如hashes, lists, sets等，同時(shí)支持?jǐn)?shù)據(jù)持久化。除此之外，Redis還提供一些類數(shù)據(jù)庫的特性，比如事務(wù)，HA，主從庫。可以說Redis兼具了緩存系統(tǒng)和數(shù)據(jù)庫的一些特性，因此有著豐富的應(yīng)用場景。本文介紹Redis在Spring Boot中兩個(gè)典型的應(yīng)用場景。
如何使用
1、引入 spring-boot-starter-redis
org.springframework.boot
spring-boot-starter-redis
2、添加配置文件
# REDIS (RedisProperties)
# Redis數(shù)據(jù)庫索引（默認(rèn)為0）
spring.redis.database=0
# Redis服務(wù)器地址
spring.redis.host=192.168.0.58
# Redis服務(wù)器連接端口
spring.redis.port=6379
# Redis服務(wù)器連接密碼（默認(rèn)為空）
spring.redis.password=
# 連接池最大連接數(shù)（使用負(fù)值表示沒有限制）
spring.redis.pool.max-active=8
# 連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒有限制）
spring.redis.pool.max-wait=-1
# 連接池中的最大空閑連接
spring.redis.pool.max-idle=8
# 連接池中的最小空閑連接
spring.redis.pool.min-idle=0
# 連接超時(shí)時(shí)間（毫秒）
spring.redis.timeout=0
3、添加cache的配置類
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport{
@Bean
public KeyGenerator keyGenerator() {
return new KeyGenerator() {
@Override
public Object generate(Object target, Method method, Object... params) {
StringBuilder sb = new StringBuilder();
sb.append(target.getClass().getName());
sb.append(method.getName());
for (Object obj : params) {
sb.append(obj.toString());
}
return sb.toString();
}
};
}
@SuppressWarnings("rawtypes")
@Bean
public CacheManager cacheManager(RedisTemplate redisTemplate) {
RedisCacheManager rcm = new RedisCacheManager(redisTemplate);
//設(shè)置緩存過期時(shí)間
//rcm.setDefaultExpiration(60);//秒
return rcm;
}
@Bean
public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
StringRedisTemplate template = new StringRedisTemplate(factory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
template.setValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
}
4、好了，接下來就可以直接使用了
@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(Application.class)
public class TestRedis {
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Autowired
private RedisTemplate redisTemplate;
@Test
public void test() throws Exception {
stringRedisTemplate.opsForValue().set("aaa", "111");
Assert.assertEquals("111", stringRedisTemplate.opsForValue().get("aaa"));
}
@Test
public void testObj() throws Exception {
User user=new User("aa@126.com", "aa", "aa123456", "aa","123");
ValueOperations operations=redisTemplate.opsForValue();
operations.set("com.neox", user);
operations.set("com.neo.f", user,1,TimeUnit.SECONDS);
Thread.sleep(1000);
//redisTemplate.delete("com.neo.f");
boolean exists=redisTemplate.hasKey("com.neo.f");
if(exists){
System.out.println("exists is true");
}else{
System.out.println("exists is false");
}
// Assert.assertEquals("aa", operations.get("com.neo.f").getUserName());
}
}
以上都是手動(dòng)使用的方式，如何在查找數(shù)據(jù)庫的時(shí)候自動(dòng)使用緩存呢，看下面；
5、自動(dòng)根據(jù)方法生成緩存
@RequestMapping("/getUser")
@Cacheable(value="user-key")
public User getUser() {
User user=userRepository.findByUserName("aa");
System.out.println("若下面沒出現(xiàn)“無緩存的時(shí)候調(diào)用”字樣且能打印出數(shù)據(jù)表示測試成功");
return user;
}
其中value的值就是緩存到redis中的key。
共享Session-spring-session-data-redis
分布式系統(tǒng)中，sessiong共享有很多的解決方案，其中托管到緩存中應(yīng)該是最常用的方案之一。
Spring Session官方說明
Spring Session provides an API and implementations for managing a user’s session information.
如何使用
1、引入依賴
org.springframework.session
spring-session-data-redis
2、Session配置：
@Configuration
@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 86400*30)
public class SessionConfig {
}
maxInactiveIntervalInSeconds: 設(shè)置Session失效時(shí)間，使用Redis Session之后，原Boot的server.session.timeout屬性不再生效
好了，這樣就配置好了，我們來測試一下
3、測試
添加測試方法獲取sessionid
@RequestMapping("/uid")
String uid(HttpSession session) {
UUID uid = (UUID) session.getAttribute("uid");
if (uid == null) {
uid = UUID.randomUUID();
}
session.setAttribute("uid", uid);
return session.getId();
}
登錄redis 輸入 keys ‘*sessions*’
t
t(spring:session:expirations:1472976480000
其中 1472976480000為失效時(shí)間，意思是這個(gè)時(shí)間后session失效，db031986-8ecc-48d6-b471-b137a3ed6bc4 為sessionId,登錄http://localhost:8080/uid 發(fā)現(xiàn)會(huì)一致，就說明session 已經(jīng)在redis里面進(jìn)行有效的管理了。
如何在兩臺或者多臺中共享session
其實(shí)就是按照上面的步驟在另一個(gè)項(xiàng)目中再次配置一次，啟動(dòng)后自動(dòng)就進(jìn)行了session共享。
示例代碼：
https://github.com/ityouknow/spring-boot-examples
參考
Redis的兩個(gè)典型應(yīng)用場景
http://emacoo.cn/blog/spring-redis
pringBoot應(yīng)用之分布式會(huì)話
https://segmentfault.com/a/1190000004358410
