Spring Boot高級教程之使用Redis實現(xiàn)session共享
Redis是一個緩存消息中間件及具有豐富特性的鍵值存儲系統(tǒng)。Spring Boot為Jedis客戶端庫和由Spring Data Redis提供的基于Jedis客戶端的抽象提供自動配置。spring-boot-starter-redis'Starter POM'為收集依賴提供一種便利的方式。
引入spring-boot-starter-redis,在pom.xml配置文件中增加配置如下(基于之前章節(jié)“Spring Boot 構(gòu)建框架”中的pom.xml文件):
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-redis</artifactId> </dependency>
可以注入一個自動配置的RedisConnectionFactory,StringRedisTemplate或普通的跟其他Spring Bean相同的RedisTemplate實例。默認(rèn)情況下,這個實例將嘗試使用localhost:6379連接Redis服務(wù)器。
@Component public class MyBean { private StringRedisTemplate template; @Autowired public MyBean(StringRedisTemplate template) { this.template = template; } // ... }
如果添加一個自己的任何自動配置類型的@Bean,它將替換默認(rèn)的(除了RedisTemplate的情況,它是根據(jù)bean的名稱'redisTemplate'而不是它的類型進(jìn)行排除的)。如果在classpath路徑下存在commons-pool2,默認(rèn)會獲得一個連接池工廠。
應(yīng)用使用Redis案例
添加配置文件,配置內(nèi)容如下:
# REDIS (RedisProperties) # Redis服務(wù)器地址 spring.redis.host=192.168.0.58 # Redis服務(wù)器連接端口 spring.redis.port=6379 # 連接超時時間(毫秒) spring.redis.timeout=0
redis配置類,具體代碼如下:
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.stereotype.Component; @Component @ConfigurationProperties(prefix = "spring.redis") public class RedisConn { private String host; private int port; private int timeout; public String getHost() { return host; } public void setHost(String host) { this.host = host; } public int getPort() { return port; } public void setPort(int port) { this.port = port; } public int getTimeout() { return timeout; } public void setTimeout(int timeout) { this.timeout = timeout; } @Override public String toString() { return "Redis [localhost=" + host + ", port=" + port + ", timeout=" + timeout + "]"; } }
注意:在RedisConn類中注解@ConfigurationProperties(prefix = "spring.Redis")的作用是讀取springboot的默認(rèn)配置文件信息中以spring.redis開頭的信息。
配置cache類
import java.lang.reflect.Method; import java.util.HashMap; import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.cache.CacheManager; import org.springframework.cache.annotation.CachingConfigurerSupport; import org.springframework.cache.annotation.EnableCaching; import org.springframework.cache.interceptor.KeyGenerator; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.data.redis.cache.RedisCacheManager; 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.core.StringRedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import org.springframework.stereotype.Component; import com.cachemodle.RedisConn; import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.databind.ObjectMapper; /** * * @author sandsa redis cache service * */ @Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport { @Autowired private RedisConn redisConn; /** * 生產(chǎn)key的策略 * * @return */ @Bean @Override 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(); } }; } /** * 管理緩存 * * @param redisTemplate * @return */ @SuppressWarnings("rawtypes") @Bean public CacheManager CacheManager(RedisTemplate redisTemplate) { RedisCacheManager rcm = new RedisCacheManager(redisTemplate); // 設(shè)置cache過期時間,時間單位是秒 rcm.setDefaultExpiration(60); Map<String, Long> map = new HashMap<String, Long>(); map.put("test", 60L); rcm.setExpires(map); return rcm; } /** * redis 數(shù)據(jù)庫連接池 * @return */ @Bean public JedisConnectionFactory redisConnectionFactory() { JedisConnectionFactory factory = new JedisConnectionFactory(); factory.setHostName(redisConn.getHost()); factory.setPort(redisConn.getPort()); factory.setTimeout(redisConn.getTimeout()); // 設(shè)置連接超時時間 return factory; } /** * redisTemplate配置 * * @param factory * @return */ @SuppressWarnings({ "rawtypes", "unchecked" }) @Bean public RedisTemplate<String, String> 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; } }
分析:緩存類繼承的是CachingConfigurerSupport,它把讀取的配置文件信息的RedisConn類對象注入到這個類中。在這個類中keyGenerator()方法是key的生成策略,CacheManager()方法是緩存管理策略,redisConnectionFactory()是redis連接,redisTemplate()方法是redisTemplate配置信息,配置后使redis中能存儲Java對象。
測試配置是否成功,實例:
@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("yoodb", "123"); Assert.assertEquals("123", stringRedisTemplate.opsForValue().get("yoodb")); } }
簡單封裝的Redis工具類,代碼如下:
import java.io.Serializable; import java.util.Set; import java.util.concurrent.TimeUnit; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.ValueOperations; import org.springframework.stereotype.Component; @Component public class RedisUtils { @SuppressWarnings("rawtypes") @Autowired private RedisTemplate redisTemplate; /** * 批量刪除對應(yīng)的value * * @param keys */ public void remove(final String... keys) { for (String key : keys) { remove(key); } } /** * 批量刪除key * * @param pattern */ @SuppressWarnings("unchecked") public void removePattern(final String pattern) { Set<Serializable> keys = redisTemplate.keys(pattern); if (keys.size() > 0) redisTemplate.delete(keys); } /** * 刪除對應(yīng)的value * * @param key */ @SuppressWarnings("unchecked") public void remove(final String key) { if (exists(key)) { redisTemplate.delete(key); } } /** * 判斷緩存中是否有對應(yīng)的value * * @param key * @return */ @SuppressWarnings("unchecked") public boolean exists(final String key) { return redisTemplate.hasKey(key); } /** * 讀取緩存 * * @param key * @return */ @SuppressWarnings("unchecked") public Object get(final String key) { Object result = null; ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); result = operations.get(key); return result; } /** * 寫入緩存 * * @param key * @param value * @return */ @SuppressWarnings("unchecked") public boolean set(final String key, Object value) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); operations.set(key, value); result = true; } catch (Exception e) { e.printStackTrace(); } return result; } /** * 寫入緩存 * * @param key * @param value * @return */ @SuppressWarnings("unchecked") public boolean set(final String key, Object value, Long expireTime) { boolean result = false; try { ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue(); operations.set(key, value); redisTemplate.expire(key, expireTime, TimeUnit.SECONDS); result = true; } catch (Exception e) { e.printStackTrace(); } return result; } }
查詢數(shù)據(jù)庫時自動使用緩存,根據(jù)方法生成緩存,參考代碼如下:
@Service public class UserService { @Cacheable(value = "redis-key") public UserInfo getUserInfo(Long id, String sex, int age, String name) { System.out.println("無緩存時調(diào)用----數(shù)據(jù)庫查詢"); return new UserInfo(id, sex, age, name); } }
注意:value的值就是緩存到redis中的key,此key是需要自己在進(jìn)行增加緩存信息時定義的key,用于標(biāo)識唯一性的。
Session 共享
分布式系統(tǒng)中session共享有很多不錯的解決方案,其中托管到緩存中是比較常見的方案之一,下面利用Session-spring-session-data-redis實現(xiàn)session共享。
引入依賴,在pom.xml配置文件中增加如下內(nèi)容:
<dependency> <groupId>org.springframework.session</groupId> <artifactId>spring-session-data-redis</artifactId> </dependency>
Session配置,具體代碼如下:
@Configuration @EnableRedisHttpSession(maxInactiveIntervalInSeconds = 86400*30) public class SessionConfig { }
maxInactiveIntervalInSeconds: 設(shè)置Session失效時間,使用Redis Session之后,原Spring Boot的server.session.timeout屬性不再生效。
測試實例,具體代碼如下:
@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服務(wù)端,輸入命令keys 'session*',查看緩存是否成功。
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- 基于SpringBoot+Redis的Session共享與單點登錄詳解
- SpringBoot2.x 整合Spring-Session實現(xiàn)Session共享功能
- Spring boot集成spring session實現(xiàn)session共享的方法
- Springboot實現(xiàn)多服務(wù)器session共享
- spring boot整合redis實現(xiàn)shiro的分布式session共享的方法
- 詳解springboot中redis的使用和分布式session共享問題
- spring boot與redis 實現(xiàn)session共享教程
- Springboot Session共享實現(xiàn)原理及代碼實例
相關(guān)文章
Java并發(fā)編程之JUC并發(fā)核心AQS同步隊列原理剖析
AbstractQueuedSynchronizer 簡稱 AQS,可能我們幾乎不會直接去使用它,但它卻是 JUC 的核心基礎(chǔ)組件,支撐著 java 鎖和同步器的實現(xiàn),大神 Doug Lea 在設(shè)計 JUC 包時希望能夠抽象一個基礎(chǔ)且通用的組件以支撐上層模塊的實現(xiàn),AQS 應(yīng)運而生2021-09-09Java 高并發(fā)十: JDK8對并發(fā)的新支持詳解
本文主要介紹Java 高并發(fā)JDK8的支持,這里整理了詳細(xì)的資料及1. LongAdder 2. CompletableFuture 3. StampedLock的介紹,有興趣的小伙伴可以參考下2016-09-09Java8深入學(xué)習(xí)系列(二)函數(shù)式編程
函數(shù)式編程,這個詞語由兩個名詞構(gòu)成,函數(shù),編程。編程這個詞我就不用解釋了,大家都是做這個的。函數(shù),其實單獨抽離出來這個詞語,也并不陌生,那二者組合后的到底是什么呢,下面這篇文章主要給大家介紹了關(guān)于Java8函數(shù)式編程的相關(guān)資料,需要的朋友可以參考下。2017-08-08