SpringBoot中实现分布式的Session共享

浅浅的花香味﹌ 2022-12-10 01:28 159阅读 0赞

## 一. SpringBoot中实现Session共享 ##

**1. 创建web项目**

我们按照之前的经验，创建一个web程序，并将之改造成Spring Boot项目，具体过程略。

![5777403be550ce9cf75d97647f5610ca.png][]

**2.添加依赖包**

<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.session</groupId>
         <artifactId>spring-session-core</artifactId>
     </dependency>

**3.创建application.yml文件**

server:
       port: 8080
     #配置redis
     spring:
       redis:
         host: 127.0.0.1
         port: 6379
         #password: 123456
         jedis:
           pool:
             max-idle: 8
             min-idle: 0
             max-active: 8
             #max-wait: 60000
         #timeout: 3000 #超时一定要大于0
       session:
         #设置session存储类型
         store-type: redis

这里可以设置多种session的store-type：

![d63da93854e5956f8f5ea0b0ce28a044.png][]

我们这里选择利用redis来对session进行集中存储，实现session共享。

**4.创建Session配置类**

package com.yyg.boot.config;
     
    import org.springframework.context.annotation.Configuration;
    import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;
     
    /**
     * @Author 一一哥Sun
     * @Date Created in 2020/4/28
     * @Description 开启Redis Http Session
     */
    @Configuration
    @EnableRedisHttpSession(maxInactiveIntervalInSeconds = 3600)
    public class RedisHttpSessionConfiguration {
     
    }

在这里添加@EnableRedisHttpSession注解，可以通过maxInactiveIntervalInSeconds属性设置Session的过期时间。

**5.创建一个Controller接口方法**

该接口方法当用户不存在时提示“用户不存在”，否则会提示“用户存在”。

package com.yyg.boot.web;
     
    import lombok.extern.slf4j.Slf4j;
    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.Cookie;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpSession;
     
    /**
     * @Author 一一哥Sun
     * @Date Created in 2020/4/28
     * @Description Description
     */
    @Slf4j
    @RestController
    public class SessionController {
     
        @RequestMapping("/session")
        public Object springSession(@RequestParam("username") String username, HttpServletRequest request, HttpSession session) {
            Cookie[] cookies = request.getCookies();
            if (cookies != null && cookies.length > 0) {
                for (Cookie cookie : cookies) {
                    log.warn(cookie.getName() + "=" + cookie.getValue());
                }
            }
     
            Object value = session.getAttribute("username");
            if (value == null) {
                log.warn("用户不存在");
                //保存session
                session.setAttribute("username", "{username: '" + username + "', age: 30}");
            } else {
                log.warn("用户存在");
            }
     
            return "username=" + value;
        }
     
    }

**6.创建入口类**

package com.yyg.boot;
     
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
     
    /**
     * @Author 一一哥Sun
     * @Date Created in 2020/4/28
     * @Description Description
     */
    @SpringBootApplication
    public class SpringSessionApplication {
     
        public static void main(String[] args){
            springapplication.run - 这个网站可出售。 - 最佳的springapplication 来源和相关信息。(SpringSessionApplication.class,args);
        }
     
    }

**7.完整项目结构**

![e3d8f4dbb510beb189307114413c4bb5.png][]

**8.启动项目进行测试**

第一次在浏览器中进行访问，会看到浏览器中的username=null,并且控制台中展示的log信息为“用户不存在”，说明此时还没有创建出session。但是当第一次访问之后，session就被创建出来了，并且被存储到了redis中，实现了持久化存储。可以看如下图：

![05ad876b03642eb5d652d8aa7726cc05.png][]

第二次访问，就会看到username已经可以获取到新的信息了。

![d41f9990fd2199c92ed4876c5e36db5e.png][]

log控制台中也看到已经提示“用户存在”的信息了。

![bc0f9440b49e841e82f600c6472bb796.png][]

并且我们可以看到Redis控制台中，提示了TTL过期时间是3660，每隔1秒钟刷新1次，3600秒后过期。

![67d650326530deabbf94ff99b223e87d.png][]

此时我们可以分别启动一个8080和8081进程，在两个进程上分别测试session接口。

#进入到项目的target目录下，执行java -jar命令，部署我们的jar包
     
    F:\onlineWorks\boot-demos\demo43_springsession\target>java -jar demo43_springsession-1.0-SNAPSHOT.jar --server.port=8080
     
    F:\onlineWorks\boot-demos\demo43_springsession\target>java -jar demo43_springsession-1.0-SNAPSHOT.jar --server.port=8081

![ae1da7b96650d21a5c19e2c9b41e8ea8.png][]

![63fc015f9f891793ac846059f284da53.png][]

在浏览器中，我们的8080和8081端口上访问时，可以看到有一个共同的Session信息：

![b6905576fc3449ca0b78a805b3f39973.png][]

可以看到在两个不同的进程端口上，都分别访问到了同一个session信息，说明我们实现了分布式进程中session共享。可见在有了Spring Session后，实现session共享还是很简单得到。

[5777403be550ce9cf75d97647f5610ca.png]: /images/20221123/3ae4c4b5145944629424b8d180e87627.png
[d63da93854e5956f8f5ea0b0ce28a044.png]: /images/20221123/da1d9c5b41bf43f9820ffff5663bcf84.png
[e3d8f4dbb510beb189307114413c4bb5.png]: /images/20221123/f688268f091741c183e5a84b9144a21f.png
[05ad876b03642eb5d652d8aa7726cc05.png]: /images/20221123/6469ad64b83a4d2abe61059cfa6a3f64.png
[d41f9990fd2199c92ed4876c5e36db5e.png]: /images/20221123/d008e82bb8eb42089179bdd169d6a008.png
[bc0f9440b49e841e82f600c6472bb796.png]: /images/20221123/d634473ab2c545fc96a08d952ada5ae3.png
[67d650326530deabbf94ff99b223e87d.png]: /images/20221123/f89c1287547b4e3ab0a28fa02a2bc4e2.png
[ae1da7b96650d21a5c19e2c9b41e8ea8.png]: /images/20221123/d5fd895209a542c8af6a7de8833d6a97.png
[63fc015f9f891793ac846059f284da53.png]: /images/20221123/aae5e5e9f81f40a38b170ea816c338d5.png
[b6905576fc3449ca0b78a805b3f39973.png]: /images/20221123/b7d3c1ae90834c0291a314e34107b4f6.png