1. 思路
在傳統的單服務架構中,一般來說,只有一個服務器,那么不存在 Session 共享問題,但是在分布式/集群項目中,Session 共享則是一個必須面對的問題:
在如上架構中,客戶端發起一個請求,這個請求到達 Nginx 上之后,被 Nginx 轉發到 Tomcat A 上,然后在 Tomcat A 上往 Session 中保存了一份數據,下次又來一個請求,這個請求被轉發到 Tomcat B 上,此時再去 Session 中獲取數據,發現沒有之前的數據。對於這一類問題的解決,思路很簡單,就是將各個服務之間需要共享的數據,保存到一個公共的地方(主流方案就是 Redis):
當所有 Tomcat 需要往 Session 中寫數據時,都往 Redis 中寫,當所有 Tomcat 需要讀數據時,都從 Redis 中讀。這樣,不同的服務就可以使用相同的 Session 數據。
若手動往 Redis 中存儲、讀取數據,相當於使用一些 Redis 客戶端工具來實現這樣的功能,工作量太大。
簡化的方案就是使用 Spring Session 來實現這一功能:Spring Session 就是使用 Spring 中的代理過濾器,將所有的 Session 操作攔截下來,自動將數據同步到 Redis 中,或者自動從 Redis 中讀取數據。
對於開發者來說,所有關於 Session 同步的操作都是透明的,開發者使用 Spring Session,一旦配置完成后,具體的用法就像使用一個普通的 Session 一樣。
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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.2.1.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.tsvv</groupId> <artifactId>Spring-Session</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>war</packaging> <name>Spring-Session</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-thymeleaf</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>org.springframework.boot</groupId> <artifactId>spring-boot-starter-tomcat</artifactId> <scope>provided</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> <exclusions> <exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId> </exclusion> </exclusions> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
application.yml中配置Redis:
spring:
redis:
host: 192.168.2.102
port: 6379
配置完成后 ,就可以使用 Spring Session 了,其實就是使用普通的 HttpSession ,其他的 Session 同步到 Redis 等操作,框架已經自動完成:
package com.tsvv.controller;
import javax.servlet.http.HttpSession; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class IndexController { @Value("${server.port}") private Integer port; @RequestMapping("/set") public String setPort(HttpSession session) { session.setAttribute("tsvv", "Spring Session"); return String.valueOf(port); } @RequestMapping("/get") public String getPort(HttpSession session) { return session.getAttribute("tsvv").toString()+":"+port; } }
2. 項目打包后得到兩個war,分別以8091、8092端口啟動:
nohup java -jar SpringSession8091.war --server.port=8091 &
nohup java -jar SpringSession8092.war --server.port=8092 &
- nohup 表示當終端關閉時,Spring Boot 不要停止運行
- & 表示讓 Spring Boot 在后台啟動
3. 配置並啟動Nginx:
server { listen 80; server_name 192.168.2.102; #charset koi8-r; #access_log logs/host.access.log main; location / { proxy_pass http://tsvvLinux; } } upstream tsvvLinux{ server 192.168.2.102:8091; server 192.168.2.102:8092; }
4. 運行:
redis:
5. 總結:
本文參考自:https://mp.weixin.qq.com/s/EGkuPbv9DEzaVwGXD3_KIA