SpringBoot(三) :Spring boot 中 Redis 的使用

SpringBoot對經常使用的數據庫支持外,對NoSQL 數據庫也進行了封裝自動化。git

redis介紹

Redis是目前業界使用最普遍的內存數據存儲。相比memcached,Redis支持更豐富的數據結構,例如hashes, lists, sets等,同時支持數據持久化。除此以外,Redis還提供一些類數據庫的特性,好比事務,HA,主從庫。能夠說Redis兼具了緩存系統和數據庫的一些特性,所以有着豐富的應用場景。本文介紹Redis在Spring Boot中兩個典型的應用場景。github

如何使用

一、引入 spring-boot-starter-redisredis

1spring

2數據庫

3segmentfault

4緩存

<dependency> 服務器

    <groupId>org.springframework.boot</groupId> session

    <artifactId>spring-boot-starter-redis</artifactId> 數據結構

</dependency>

二、添加配置文件

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

# REDIS (RedisProperties)

# Redis數據庫索引(默認爲0

spring.redis.database=0 

# Redis服務器地址

spring.redis.host=192.168.0.58

# Redis服務器鏈接端口

spring.redis.port=6379 

# Redis服務器鏈接密碼(默認爲空)

spring.redis.password= 

# 鏈接池最大鏈接數(使用負值表示沒有限制)

spring.redis.pool.max-active=8 

# 鏈接池最大阻塞等待時間(使用負值表示沒有限制)

spring.redis.pool.max-wait=-1 

# 鏈接池中的最大空閒鏈接

spring.redis.pool.max-idle=8 

# 鏈接池中的最小空閒鏈接

spring.redis.pool.min-idle=0 

# 鏈接超時時間(毫秒)

spring.redis.timeout=0

三、添加cache的配置類

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

@Configuration

@EnableCaching

publicclass  RedisConfig extendsCachingConfigurerSupport{

     

    @Bean

    publicKeyGenerator keyGenerator() {

        returnnew  KeyGenerator() {

            @Override

            publicObject generate(Object target, Method method, Object... params) {

                StringBuilder sb = newStringBuilder();

                sb.append(target.getClass().getName());

                sb.append(method.getName());

                for(Object obj : params) {

                    sb.append(obj.toString());

                }

                returnsb.toString();

            }

        };

    }

 

    @SuppressWarnings("rawtypes")

    @Bean

    publicCacheManager cacheManager(RedisTemplate redisTemplate) {

        RedisCacheManager rcm = newRedisCacheManager(redisTemplate);

        //設置緩存過時時間

        //rcm.setDefaultExpiration(60);//秒

        returnrcm;

    }

     

    @Bean

    publicRedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {

        StringRedisTemplate template = newStringRedisTemplate(factory);

        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = newJackson2JsonRedisSerializer(Object.class);

        ObjectMapper om = newObjectMapper();

        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

        jackson2JsonRedisSerializer.setObjectMapper(om);

        template.setValueSerializer(jackson2JsonRedisSerializer);

        template.afterPropertiesSet();

        returntemplate;

    }

 

}

四、好了,接下來就能夠直接使用了

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

@RunWith(SpringJUnit4ClassRunner.class)

@SpringApplicationConfiguration(Application.class)

publicclass  TestRedis {

 

    @Autowired

    privateStringRedisTemplate stringRedisTemplate;

     

    @Autowired

    privateRedisTemplate redisTemplate;

 

    @Test

    publicvoid  test() throwsException {

        stringRedisTemplate.opsForValue().set("aaa""111");

        Assert.assertEquals("111", stringRedisTemplate.opsForValue().get("aaa"));

    }

     

    @Test

    publicvoid  testObj() throwsException {

        User user=newUser("aa@126.com""aa""aa123456""aa","123");

        ValueOperations<String, User> 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");

        booleanexists=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());

    }

}

以上都是手動使用的方式,如何在查找數據庫的時候自動使用緩存呢,看下面;

五、自動根據方法生成緩存

1

2

3

4

5

6

7

@RequestMapping("/getUser")

@Cacheable(value="user-key")

publicUser getUser() {

    User user=userRepository.findByUserName("aa");

    System.out.println("若下面沒出現「無緩存的時候調用」字樣且能打印出數據表示測試成功"); 

    returnuser;

}

其中value的值就是緩存到redis中的key

共享Session-spring-session-data-redis

分佈式系統中,sessiong共享有不少的解決方案,其中託管到緩存中應該是最經常使用的方案之一,

Spring Session官方說明

Spring Session provides an API and implementations for managing a user’s session information.

如何使用

一、引入依賴

1

2

3

4

<dependency>

    <groupId>org.springframework.session</groupId>

    <artifactId>spring-session-data-redis</artifactId>

</dependency>

二、Session配置:

1

2

3

4

@Configuration

@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 86400*30)

publicclass  SessionConfig {

}

maxInactiveIntervalInSeconds: 設置Session失效時間,使用Redis Session以後,原Boot的server.session.timeout屬性再也不生效

好了,這樣就配置好了,咱們來測試一下

三、測試

添加測試方法獲取sessionid

1

2

3

4

5

6

7

8

9

@RequestMapping("/uid")

    String uid(HttpSession session) {

        UUID uid = (UUID) session.getAttribute("uid");

        if(uid == null) {

            uid = UUID.randomUUID();

        }

        session.setAttribute("uid", uid);

        returnsession.getId();

    }

登陸redis 輸入 keys ‘*sessions*’

1

2

t<spring:session:sessions:db031986-8ecc-48d6-b471-b137a3ed6bc4

t(spring:session:expirations:1472976480000

其中 1472976480000爲失效時間,意思是這個時間後session失效,db031986-8ecc-48d6-b471-b137a3ed6bc4 爲sessionId,登陸http://localhost:8080/uid 發現會一致,就說明session 已經在redis裏面進行有效的管理了。

如何在兩臺或者多臺中共享session

其實就是按照上面的步驟在另外一個項目中再次配置一次,啓動後自動就進行了session共享。

 

示例代碼

參考

相關文章
相關標籤/搜索