码迷,mamicode.com
首页 > 编程语言 > 详细

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

时间:2017-11-13 23:00:12      阅读:279      评论:0      收藏:0      [点我收藏+]

标签:project   容器   path   filter过滤器   localhost   tco   port   seconds   extend   

本次开发环境: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 共享

标签:project   容器   path   filter过滤器   localhost   tco   port   seconds   extend   

原文地址:http://www.cnblogs.com/edison20161121/p/7826841.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!