SpringBoot中redis的使用介紹

REmote DIctionary Server(Redis) 是一個由Salvatore Sanfilippo寫的key-value存儲系統。

Redis是一個開源的使用ANSI C語言編寫、遵守BSD協議、支持網絡、可基於內存亦可持久化的日志型、Key-Value數據庫，並提供多種語言的API。

它通常被稱為數據結構服務器，因為值（value）可以是 字符串(String), 哈希(Map), 列表(list), 集合(sets) 和 有序集合(sorted sets)等類型。

Redis是目前行業使用最廣泛的內存數據存儲。比memcached更受歡迎，Redis支持更豐富的數據結構，同時支持數據持久化。

除此之外，Redis還提供一些類數據庫的特性，比如事務，HA，主從庫。可以說Redis兼具了緩存系統和數據庫的一些特性，因此有着豐富的應用場景。

 

redis在SpringBoot2.0版本后如何使用

第一步：引入spring-boot-starter-data-redis依賴包

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

 

第二步：編寫配置文件application.yml（當然，也可以通過profile機制指向不同的環境配置文件）

spring:
  # profiles:
  #  active: dev
  redis:
    database: 0
    host: www.weiyi.com
    password: null
    max-active: 8
    max-idle: 500
    max-wait: 1
    min-idle: 0
    port: 6379
    timeout: 5000ms

 

第三步：添加redis的Java配置類

package ooh.chaos.configuration;

import ooh.chaos.configuration.FastJsonRedisSerializer;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import org.springframework.cache.interceptor.KeyGenerator;
import org.springframework.session.SessionRepository;
import org.springframework.session.data.redis.RedisOperationsSessionRepository;

/**
 * redis 配置
 */
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    @Bean
    @Override
    public KeyGenerator keyGenerator() {
        return (target, method, 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();
        };
    }

    /**
     * 設置 redisTemplate 序列化方式
     *
     * @param factory
     * @return
     */
    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<Object, Object>();
        redisTemplate.setConnectionFactory(factory);
        // 設置值（value）的序列化采用FastJsonRedisSerializer。
        FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);
        redisTemplate.setValueSerializer(fastJsonRedisSerializer);
        redisTemplate.setHashValueSerializer(fastJsonRedisSerializer);
        // 設置鍵（key）的序列化采用StringRedisSerializer。
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        redisTemplate.setDefaultSerializer(fastJsonRedisSerializer);
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }

    /**
     * 設置spring session redis 序列化方式
     *
     * @param factory
     * @return
     */
    @Bean
    public SessionRepository sessionRepository(RedisConnectionFactory factory) {
        RedisOperationsSessionRepository sessionRepository = new RedisOperationsSessionRepository(
                redisTemplate(factory));
        FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);
        sessionRepository.setDefaultSerializer(fastJsonRedisSerializer);
        sessionRepository.setDefaultMaxInactiveInterval(36000);
        return sessionRepository;
    }

}

 

最后一步：在SpringBoot項目中使用redis

1.引入redis操作bean

@Autowired
private RedisTemplate<Object, Object> redisTemplate;

2.使用redisTemplate操作redis，手動使用方式

// 增加token邏輯，Created by xiaoshiyilang on 2018/10/19
String md5Key = DigestUtils.md5Hex(Constants.TOKEN_KEY_PRE + user.getUid());
if (redisTemplate.opsForValue().get(md5Key) != null) {
    redisTemplate.delete(md5Key);
}
String md5Token = DigestUtils.md5Hex(generalToken() + user.getUid());
if (redisTemplate.opsForValue().get(md5Token) != null) {
　　redisTemplate.delete(md5Token);
}
// 返回給前端的Token
redisTemplate.opsForValue().set(md5Key, md5Token);
// 設置Token過期時間
redisTemplate.expire(md5Key, 86400 * 30, TimeUnit.SECONDS);
// 記錄成功的用戶id
redisTemplate.opsForValue().set(md5Token, user.getUid());
// 設置登錄用戶過期時間
redisTemplate.expire(md5Token, 86400 * 30, TimeUnit.SECONDS);

另一種使用方式：自動根據方法生成緩存

@Cacheable(value = "user-key")
public User getUser(Long id) {
    User user = userService.selectByPrimaryKey(id);
    System.out.println("若下面沒出現“無緩存的時候調用”字樣且能打印出數據表示測試成功");
    return user;
}

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

 

SpringBoot下使用Redis實現session共享

分布式系統中，session會面臨需要在多個項目中共享的問題，包括集群，負載均衡也是需要session共享的，有很多的解決方案，其中托管到redis這樣的緩存中是最常用的方案之一，小Alan在這里也和大家聊一聊

第一步：引入spring-session-data-redis依賴包

<dependency>
        <groupId>org.springframework.session</groupId>
        <artifactId>spring-session-data-redis</artifactId>
</dependency>

 

第二步：添加session的Java配置類

package com.only.tech.user.configuration;

import org.springframework.context.annotation.Configuration;
import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;

/**
 * session配置，30分鍾過期
 */
@Configuration
@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 60 * 30)
public class SessionConfig {

}

maxInactiveIntervalInSeconds: 設置Session失效時間，使用Redis Session之后，原Boot的server.session.timeout屬性不再生效。

 

最后一步：測試session是否生效

添加測試方法獲取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客戶端查看是否保存sessionid相關的值

訪問瀏覽器執行多個請求如果是同一個sessionid就說明session已經在redis中進行有效的管理了。

 

如何在兩個項目或者多個項目中共享session（或者多台機器）

按照上面的步驟在另一個項目中再次配置一次session，啟動項目后自動就進行了session的共享機制。

 

注意：我在redis的Java配置類中設置了spring session redis 的序列化方式，因為我這里沒有使用SpringBoot默認的json序列化方式，而是使用了阿里的fastjson。

 

結束語：這城市總是風很大，孤獨的人晚回家，外面不像你想的那么好，風雨都要直接擋。願每個獨自走夜路的你，都足夠堅強。

 

佛系博主：AlanLee

博客地址：http://www.cnblogs.com/AlanLee

GitHub地址：https://github.com/AlanLee-Java

本文出自博客園，歡迎大家加入博客園。