在实际项目中,前台代码部署在nginx中,后台服务内嵌了tomcat运行在不同的节点中,常见的架构如下:
在上述架构中,nginx转发前台请求,第一次登录后,将用户登录信息写入到一台服务session中(假设为A节点),再次请求后,假设nginx转发到了B节点,B服务节点中没有session用户登录信息,此时还需要登录,session在服务集群内不可用,不符合预期,示例代码如下:
package com.gingko.session.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpSession;
@RestController
@RequestMapping("/login")
public class LoginController {
@GetMapping("/toLogin")
public String toLogin(@RequestParam String userName, @RequestParam String password,
HttpSession httpSession) {
//校验用户名密码...
//用户名加入session
httpSession.setAttribute("userName",userName);
return "登录成功";
}
@GetMapping("/getLoginUser")
public String getLoginUser(HttpSession httpSession) {
return "session获取的值是:" + httpSession.getAttribute("userName") ;
}
}
基于上述的代码测试效果如下(后台启动了2个服务,端口分别是8081和8082),从下图中可以看出8081登录后,访问8082时获取不到登录信息。
分布式session解决方案有很多,本文阐述【Session集中存储】的解决方案,即将session集中存储到某个地方,本文演示存储到redis中,架构示意图如下:
代码架构引入redis和spring session,示例代码如下:
1、引入 redis和spring session依赖
<?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>
<groupId>com.gingko</groupId>
<artifactId>distributed-session</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>distributed-session</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<spring-boot.version>2.7.6</spring-boot.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-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
<encoding>UTF-8</encoding>
</configuration>
</plugin>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring-boot.version}</version>
<configuration>
<mainClass>com.gingko.session.DistributedSessionApplication</mainClass>
<skip>true</skip>
</configuration>
<executions>
<execution>
<id>repackage</id>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
2、修改配置,增加对redis和session的支持
# 应用服务 WEB 访问端口
server:
port: 8081
spring:
redis:
host: 192.168.136.130 #redis
port: 6379
database: 0
session:
store-type: redis #session 存储方式
timeout: 1800 #session 过期时间 30分钟
3、启动2个应用测试(端口8081和8082),从下图中可以看出8081登录后,redis缓存中增加了session信息,8082也可以获取到登录信息,符合预期。