使用idea,springboot，springsession，redis实现分布式微服务的session 共享

Posted 成功的路上总是离不开贵人的帮助，名师的指点和小人的刺激。

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了使用idea,springboot，springsession，redis实现分布式微服务的session 共享相关的知识，希望对你有一定的参考价值。

本次开发环境：idea2016.3.4 +jdk1.8+maven3.3.9+redis+springboot+jedis

 本文中的项目使用Maven来管理项目依赖，使用Spring Session和Redis的组合来代替原有的HttpSession实现Session在不同项目之间的共享

项目结构：

构建Spring Boot 

pom文件如下

<modelVersion>4.0.0</modelVersion>

<groupId>com.cky.sessionshare</groupId>
<artifactId>spring-session-share</artifactId>
<packaging>jar</packaging>
<version>1.0-SNAPSHOT</version>

<!-- spring boot 基本环境 -->
<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>1.3.1.RELEASE</version>
</parent>

<properties>
  <java.version>1.8</java.version>
</properties>
<dependencies>
  <!--spring boot web应用基本环境配置 -->
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>

 
</dependencies>

<build>
  <plugins>
    <plugin>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-maven-plugin</artifactId>
    </plugin>
  </plugins>
</build>


Application.java


实现Spring Boot的启动main函数


@SpringBootApplication
public class Application {
    // 自动配置Spring框架
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}


测试


测试代码


创建一个类HelloWorldController用于测试


@RestController
public class HelloWorldController {

    @RequestMapping("/index/{name}")
    @ResponseBody
    public String index(@PathVariable String name) {

        if (null == name) {
            name = "boy";
        }

        return "hello world " + name;
    }
}
运行Application.java来启动Spring Boot，访问”http://localhost:8080/index/陈冠希”出现以下页面，说明Spring Boot部署成功




加入Spring Session框架


pom.xml


引入Spring Session和Redis需要的依赖


 <!--spring boot 与redis应用基本环境配置 -->
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-redis</artifactId>
  </dependency>

  <!--spring session 与redis应用基本环境配置,需要开启redis后才可以使用，不然启动Spring boot会报错 -->
  <dependency>
    <groupId>org.springframework.session</groupId>
    <artifactId>spring-session-data-redis</artifactId>
  </dependency>
</dependencies>



Spring Session配置


创建一个Spring配置，用于创建一个支持Spring Session的Servlet Filter来代替原有的HttpSession的实现。


@EnableRedisHttpSession(maxInactiveIntervalInSeconds= 1800)
public class SessionConfig {

    @Value("${redis.hostname:localhost}")
    String HostName;

    @Value("${redis.port:6379}")
    int Port;
    @Bean
    public JedisConnectionFactory connectionFactory() {
        JedisConnectionFactory connection = new JedisConnectionFactory();
        return connection;
    }
}



JedisConnectionFactory


默认连接端口:6379 
默认连接地址:localhost 
需要修改则可以使用JedisConnectionFactory的setPort()方法和setHostName()方法来修改默认的端口和连接地址


这里可以引入配置文件使Redis的配置更加灵活


创建配置文件application.properties


 


redis.homename = localhost
redis.port = 6379



在类SessionConfig中引入配置文件的值


修改后的SessionConfig类代码如下：


@EnableRedisHttpSession(maxInactiveIntervalInSeconds= 1800)
public class SessionConfig {

    @Value("${redis.hostname:localhost}")
    String HostName;

    @Value("${redis.port:6379}")
    int Port;
    @Bean
    public JedisConnectionFactory connectionFactory() {
        JedisConnectionFactory connection = new JedisConnectionFactory();
        connection.setPort(Port);
        connection.setHostName(HostName);

        return connection;
    }
}


加载Spring Session配置


加载Spring Session配置，使得Servlet容器在每一次请求时都使用我们的springSessionRepositoryFilter过滤器。


public class SessionInitializer  extends AbstractHttpSessionApplicationInitializer{
    public SessionInitializer (){
        super(SessionConfig.class);
    }

}


测试


以上已经完成了Spring Boot + Spring Session +Redis的配置 
测试是否可以在不同的容器（e.g. Tomcat），不同的项目中都访问到同一个Session


运行Redis


拷贝一个项目


项目结构与主项目相同




 


修改容器端口


修改Spring Boot中自带Tomcat的接口 
在application.properties中加入server.port=8090


实现Session的读写


添加测试方法


主项目


在主项目中的类HelloWorldController中添加一个TestSession方法 
用于保存和读取Session 
修改后的代码如下


@RestController
public class HelloWorldController {

    @RequestMapping("/index/{name}")
    @ResponseBody
    public String index(@PathVariable String name) {

        if (null == name) {
            name = "boy";
        }

        return "hello world " + name;
    }

    @RequestMapping("/tsession/{age}")
    @ResponseBody
    public String TestSession(HttpServletRequest req, HttpServletResponse resp, @PathVariable String age){
        req.getSession().setAttribute("age", age);
        String a = (String) req.getSession().getAttribute("age");

        return a;
    }
}


测试项目


为了测试是否可以读取Session，测试项目的Session不做保存操作 
修改测试项目的HelloWorldController类中的TestSession方法 
修改后的代码为


@RestController
public class WelcomeController {

    @RequestMapping("/welcome/{name}")
    @ResponseBody
    public String index(@PathVariable String name) {

        if (null == name) {
            name = "edison";
        }
        
        return "welcome " + name;
    }

    @RequestMapping("/tsession/{age}")
    @ResponseBody
    public String TestSession(HttpServletRequest req, HttpServletResponse resp, @PathVariable String age){
        String a = (String) req.getSession().getAttribute("age");
        return a;
    }
}


开始测试


分别运行主项目和测试项目的Application.java文件


验证


先登录”http://localhost:8080/tsession/88“保存Session信息，结果如下图所示： 




再登录”http://localhost:8090/tsession/88“，测试是否可以读取到之前的信息：若结果如下图，这表示测试成功：




 


 


 这时用redis desktop manager查看redis发现数据




 


用谷歌查看刚才传递的给服务的cookie




优化


若每一次创建项目都要写一次的Session的配置，那么代码的复用性太差，那么不如把Session的配置单独打包出来，之后只需要在项目中加入一个依赖就可以实现Spring Session的功能。


项目结构


 




 


 pom文件如下


<?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 http://maven.apache.org/maven-v4_0_0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <groupId>com.springboot.sessionshare</groupId>
  <artifactId>springbootsessionshare</artifactId>
  <packaging>jar</packaging>
  <version>0.0.1-SNAPSHOT</version>

  <name>A Camel Route</name>

  <!-- spring boot 基本环境 -->
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.3.1.RELEASE</version>
  </parent>

  <dependencies>
    <!--spring boot web应用基本环境配置 -->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!--spring boot 与redis应用基本环境配置 -->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-redis</artifactId>
    </dependency>

    <!--spring session 与redis应用基本环境配置,需要开启redis后才可以使用，不然启动Spring boot会报错 -->
    <dependency>
      <groupId>org.springframework.session</groupId>
      <artifactId>spring-session-data-redis</artifactId>
    </dependency>

  </dependencies>

</project>
配置类SessionConfig和加载类SessionInitializer的代码与之前没有变化


Maven install


由于项目依赖是由Maven来管理的，那么使用Maven install将项目安装到Maven的本地仓库当中 




测试


创建测试项目


pom.xml


先获取去需要依赖的项目的Maven位置，位置在安装到本地仓库的项目的pom.xml文件中获取




将位置加入到测试项目中 




设置端口


server.port=8050



其他测试文件


Application.java文件和HelloWorldController文件代码与之前的一致，以下就不贴出代码了


 


 


开始测试


运行Redis-运行测试项目中的Application.java文件-访问”http://localhost:8050/tsession/100” 


若效果与下图效果一致，则创建成功 






 


 


 


 










 


 


以上是关于使用idea,springboot，springsession，redis实现分布式微服务的session 共享的主要内容，如果未能解决你的问题，请参考以下文章
 

 为啥我的idea中没有sping boot 1.5.7的版本


 使用idea创建springboot项目


 mac电脑的idea中的spring boot 怎么修改tomcat的端口号


 使用IDEA 中 实现springboot 热部署 （spring boot devtools版）


 SpringBoot  idea下的环境搭建及demo


 idea 有没有spring boot插件