一. 簡介

         springboot2.0整合redis可以參照博主的另一篇文章： springboot2.0整合redis

          在分散式專案中，為了保持無狀態的應用，用redis做session伺服器。springsession可以和redis很好的配合。

二. 程式碼

2.1 pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.example</groupId>
    <artifactId>demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>demo</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

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

        <!-- jackson序列化 -->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>

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

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>
 

2.2 application.yml

server:
  port: 8080


# redis相關配置
spring:
  redis:
    database: 0
    host: redis伺服器IP
    port: 6379
    password: 密碼

2.3 RedisConfig

package com.example.demo.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
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.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;

/**
 * @author yuanshushu
 * @date 2018/9/1
 * @description REDIS配置類
 */
@Configuration
@EnableRedisHttpSession
public class RedisConfig {

    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);

        // 使用Jackson2JsonRedisSerialize 替換預設的jdkSerializeable序列化
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

        // 設定value的序列化規則和 key的序列化規則
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }


}
 

2.4 SessionController

2.4.1 8080埠的Controller

列印session資訊和向session中儲存使用者資訊

package com.example.demo.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;

/**
 * @author yuanshushu
 * @date 2018/9/1
 * @description SESSION控制類
 */
@RestController
public class SessionController {

    @GetMapping("/test")
    public Map<String, Object> testSessionId(HttpServletRequest request) {

        Map<String, Object> sessionIdPortMap = new HashMap<String, Object>();

        // 獲取session資訊
        sessionIdPortMap.put("sessionId：", request.getSession().getId());
        sessionIdPortMap.put("伺服器埠：", request.getServerPort());

        // 向session中儲存使用者資訊 key規則： user + "_" + uid
        request.getSession().setAttribute("user_1", "{uid:1,username:
 
[email protected]}");

        return sessionIdPortMap;
    }


}

2.4.2 8081埠的controller

 列印session資訊和獲取session中使用者資訊

package com.example.demo.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.Map;

/**
 * @author yuanshushu
 * @date 2018/9/1
 * @description SESSION控制類
 */
@RestController
public class SessionController {

    @GetMapping("/test")
    public Map<String, Object> testSessionId(HttpServletRequest request) {

        Map<String, Object> sessionIdPortMap = new HashMap<String, Object>();

        // 獲取session資訊
        sessionIdPortMap.put("sessionId：", request.getSession().getId());
        sessionIdPortMap.put("伺服器埠：", request.getServerPort());

        // 獲取session中uid為1的使用者的資訊
        String user_1 = (String) request.getSession().getAttribute("user_1");
        sessionIdPortMap.put("user_1", user_1);

        return sessionIdPortMap;
    }


}

2.5 啟動類

package com.example.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

三. 測試

此時，可以通過redis desktop manager檢視，有一個session生成，時間預設為半小時。

此時，將專案複製一份，埠改為8081，訪問http://localhost:8081/test，仍然得到相同的sessionId,並可以得到session中儲存的使用者資訊：

說明session已經被redis共享了。

此時，如果將專案關閉，再啟動，仍然會是這個sessionId（預設半小時失效）。

在專案中，可以通過一個工具類，封裝獲取session的方法，然後對該session做操作。