19、springcloud分布式Session之Spring Session

HttpSession是通過Servlet容器創建和管理的，像Tomcat/Jetty都是保存在內存中的。但是把應用搭建成分布式的集群，然后利用F5、LVS或Nginx做負載均衡，那么來自同一用戶的Http請求將有可能被分發到多個不同的服務器中。那問題來了，如何保證不同的服務器能夠共享同一份session數據呢？最簡單的想法,就是把session數據保存到內存以外的一個統一的地方，例如Memcached/Redis等數據庫中。那問題又來了，如何替換掉Servlet容器創建和管理的HttpSession的實現呢？

　　方案一：利用Servlet容器提供的插件功能，自定義HttpSession的創建和管理策略，並通過配置的方式替換掉默認的策略。這方面其實早就有開源項目了，例如memcached-session-manager(可以參考負載均衡+session共享(memcached-session-manager實現)，以及tomcat-redis-session-manager。不過這種方式有個缺點，就是需要耦合Tomcat/Jetty等Servlet容器的代碼。

　　方案二：設計一個Filter，利用HttpServletRequestWrapper，實現自己的 getSession()方法，接管創建和管理Session數據的工作。spring-session就是通過這樣的思路實現的。

 

 

 

 

 

1、 新建項目sc-redis-session，對應的pom.xml文件如下

 

<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>spring-cloud</groupId>

<artifactId>sc-redis-session</artifactId>

<version>0.0.1-SNAPSHOT</version>

<packaging>jar</packaging>

 

<name>sc-redis-session</name>

<url>http://maven.apache.org</url>

 

<parent>

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

<artifactId>spring-boot-starter-parent</artifactId>

<version>2.0.4.RELEASE</version>

</parent>

 

<dependencyManagement>

<dependencies>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-dependencies</artifactId>

<version>Finchley.RELEASE</version>

<type>pom</type>

<scope>import</scope>

</dependency>

 

</dependencies>

</dependencyManagement>

 

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<maven.compiler.source>1.8</maven.compiler.source>

<maven.compiler.target>1.8</maven.compiler.target>

</properties>

<dependencies>

<dependency>

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

<artifactId>spring-boot-starter-data-redis</artifactId>

</dependency>

 

<dependency>

<groupId>org.apache.commons</groupId>

<artifactId>commons-pool2</artifactId>

</dependency>

 

<dependency>

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

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

 

<dependency>

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

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

</dependency>

 

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>fastjson</artifactId>

<version>1.2.49</version>

</dependency>

</dependencies>

</project>

 

 

 

2、 新建springboot啟動類RedisSessionApplication.java

 

package com.redis.session;

 

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

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

 

@SpringBootApplication

@EnableRedisHttpSession

public class RedisSessionApplication {

 

public static void main(String[] args) {

SpringApplication.run(RedisSessionApplication.class, args);

}

}

 

 

說明：主要使用EnableRedisHttpSession注解開啟spring分布式session，該類的作用是配置org.springframework.session.web.http.SessionRepositoryFilter進行請求攔截

3、 新建配置文件application.yml

 

server:

  port: 7200

spring:

  session:

    store-type: redis

  application:

    name: sc-redis-session

  redis:

    host: 127.0.0.1

    password:

    port: 6379

    timeout: 10000 # 連接超時時間（毫秒）

    database: 0 # Redis默認情況下有16個分片，這里配置具體使用的分片，默認是0

    lettuce:

      pool:

        max-active: 8 # 連接池最大連接數（使用負值表示沒有限制） 默認 8

        max-wait: -1 # 連接池最大阻塞等待時間（使用負值表示沒有限制） 默認 -1

        max-idle: 8 # 連接池中的最大空閑連接 默認 8

        min-idle: 0 # 連接池中的最小空閑連接 默認 0

 

 

4、 新建一個UserController

 

package com.redis.session.controller;

 

import java.util.HashMap;

import java.util.Map;

 

import javax.servlet.http.Cookie;

import javax.servlet.http.HttpServletRequest;

 

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

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

 

import com.alibaba.fastjson.JSON;

import com.redis.session.model.User;

 

@RestController

public class UserController {

 

private static final Logger logger = LoggerFactory.getLogger(UserController.class);

 

/**

 * 把用戶放入session

 *

 * @param request

 * @return

 */

@RequestMapping("/user/login")

@ResponseBody

public Map<String, Object> login(HttpServletRequest request) {

// 取出session中的userName

Object loginUser = request.getSession().getAttribute("loginUser");

if (loginUser == null) {

logger.info("不存在session，設置user");

User u = new User();

u.setAge(23);

u.setId(1L);

u.setPosition("總裁");

u.setUserName("huangjinjin");

request.getSession().setAttribute("loginUser", u);

} else {

logger.info("存在session，user=" +  JSON.toJSONString(loginUser));

}

Cookie[] cookies = request.getCookies();

if (cookies != null && cookies.length > 0) {

for (Cookie cookie : cookies) {

logger.info(cookie.getName() + " : " + cookie.getValue());

}

}

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

resp.put("code", "000000");

resp.put("msg", "交易成功");

return resp;

}

 

/**

 * 獲取session的用戶

 *

 * @param request

 * @return

 */

@RequestMapping("/user/getUser")

@ResponseBody

public Map<String, Object> getUser(HttpServletRequest request) {

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

resp.put("code", "000000");

resp.put("msg", "交易成功");

resp.put("body", request.getSession().getAttribute("loginUser"));

Cookie[] cookies = request.getCookies();

if (cookies != null && cookies.length > 0) {

for (Cookie cookie : cookies) {

logger.info(cookie.getName() + " : " + cookie.getValue());

}

}

return resp;

}

 

}

 

 

 

5、 啟動項目，查看日志是否啟動成功

 

 

 

 

 

6、 使用谷歌瀏覽器訪問接口

第一次訪問登錄接口：http://127.0.0.1:7200/user/login

 

 

 

控制台打印：

 

 

 

第二次至第n次：控制台打印

 

 

 

 

 

訪問獲取session接口：返回對應的用戶數據

 

 

 

 

 

7、 通過reids客戶端redis-cli查看redis服務器的數據

 

 

 https://gitee.com/hjj520/spring-cloud-2.x