分布式session解决方案

发布于:2025-06-28 ⋅ 阅读:(18) ⋅ 点赞:(0)

        在实际项目中,前台代码部署在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也可以获取到登录信息,符合预期。


网站公告

今日签到

点亮在社区的每一天
去签到