java集群会话管理_架构设计之SpringSession分布式集群会话管理

前言

通常在web开发中&＃xff0c;会话管理是很重要的一部分&＃xff0c;用于存储与用户相关的一些数据。对于JAVA开发者来说&＃xff0c;项目中的session一般由Tomcat或者jetty容器来管理。

特点介绍

尽管使用特定的容器可以很好地实现会话管理&＃xff0c;但是独立容器挂掉或者由于其他原因重启会导致用户信息丢失&＃xff0c;并且无法支持分布式集群会话管理。

上图举例&＃xff1a;

这是一个简单的负载均衡集群架构模型&＃xff0c;后端三台Tomcat服务&＃xff0c;假设每台服务都使用自己的会话管理&＃xff0c;而集群策略是基于加权轮询的方式实现。试想一下&＃xff0c;用户是不是永远无法登陆系统&＃xff1f;

当然&＃xff0c;你可能会想&＃xff0c;我可以使用基于IP_hash的方式实现负载均衡嘛。但是如果地区分布相对单一&＃xff0c;产生的hash值分布可能也不会太均匀&＃xff0c;那就起不到负载均衡的作用了。

一般来说&＃xff0c;有两种解决方案&＃xff0c;session复制和session统一管理。对于session复制&＃xff0c;简单的几台还是可以的&＃xff0c;但是如果上百台甚至上千台就要考虑复制成本问题了。

对于统一session管理可以是关系型数据库&＃xff0c;比如MySql(基本不用&＃xff0c;考虑到效率问题)&＃xff1b;非关系型数据库 redis&＃xff0c;memcache等等。

解决方案

基于Tomcat的会话插件实现tomcat-redis-session-manager 和tomcat-memcache-session-manager&＃xff0c;会话统一由NoSql管理。对于项目本身来说&＃xff0c;无须改动代码&＃xff0c;只需要简单的配置Tomcat的server.xml就可以解决问题。但是插件太依赖于容器&＃xff0c;并且对于Tomcat各个版本的支持不是特别的好

重写Tomcat的session管理&＃xff0c;代码耦合度高&＃xff0c;不利于维护。

使用开源的session管理框架&＃xff0c;比如spring_session&＃xff0c;既不需要修改Tomcat配置&＃xff0c;又无须重写代码&＃xff0c;只需要配置相应的参数即可。

功能实现

下面&＃xff0c;主要是基于spring_session实现的分布式集群会话管理案例。

项目需要使用到spring_Mvc4.2.5,spring_session-1.2.2和redis-3.2.8(需要自行安装redis服务)。

配置相关JAR包(spring mvc相关jar包依赖自行配置)&＃xff1a;

org.springframework.session

spring-session-data-redis

1.2.2.RELEASE

spring-mvc.xml

xmlns:context&＃61;"http://www.springframework.org/schema/context" xmlns:mvc&＃61;"http://www.springframework.org/schema/mvc"

xsi:schemaLocation&＃61;"http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd

http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd

http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">

Spring MVC Configuration

text/html;charset&＃61;UTF-8

config.properties

#&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;#

#&＃61;&＃61;&＃61;&＃61;&＃61; System settings &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;#

#&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;#

#产品信息设置

productName&＃61;科帮网 srping session

copyrightYear&＃61;2017

version&＃61;V1.0.0

#分页配置

page.pageSize&＃61;10

#索引页路径

web.view.index&＃61;/index

#登陆页面

web.view.login&＃61;/login

#视图文件存放路径

web.view.prefix&＃61;/WEB-INF/views/

web.view.suffix&＃61;.jsp

#静态文件后缀

web.staticFile&＃61;.css,.js,.png,.jpg,.gif,.jpeg,.bmp,.ico,.swf,.psd,.htc,.htm,.html,.crx,.xpi,.exe,.ipa,.apk

spring-redis.xml

xmlns:xsi&＃61;"http://www.w3.org/2001/XMLSchema-instance" xmlns:context&＃61;"http://www.springframework.org/schema/context"

xmlns:aop&＃61;"http://www.springframework.org/schema/aop" xmlns:tx&＃61;"http://www.springframework.org/schema/tx"

xsi:schemaLocation&＃61;"http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd

http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd

http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd" default-autowire&＃61;"byName" default-lazy-init&＃61;"true">

class&＃61;"org.springframework.data.redis.connection.jedis.JedisConnectionFactory">

redis.properties

#redis中心

redis.host&＃61;127.0.0.1

redis.port&＃61;6379

redis.password&＃61;123456

redis.maxIdle&＃61;100

redis.maxActive&＃61;300

redis.maxWait&＃61;1000

redis.testOnBorrow&＃61;true

redis.timeout&＃61;100000

web.xml

spring_session

contextConfigLocation

classpath:spring-redis.xml

springSessionRepositoryFilter

org.springframework.web.filter.DelegatingFilterProxy

springSessionRepositoryFilter

/*

org.springframework.web.context.ContextLoaderListener

encodingFilter

org.springframework.web.filter.CharacterEncodingFilter

encoding

UTF-8

forceEncoding

true

encodingFilter

/*

springServlet

org.springframework.web.servlet.DispatcherServlet

contextConfigLocation

classpath*:/spring-mvc*.xml

1

springServlet

/

login

测试功能

最后&＃xff0c;启动项目访问http://localhost:8080/spring_session/login

登录redis服务&＃xff0c;执行以下命令&＃xff1a;

KEYS *

注意&＃xff0c;对比sessionId是一致的。

网上很多同学&＃xff0c;启动的时候找不到 springSessionRepositoryFilter&＃xff0c;注意在spring-redis.xml加入context:annotation-config/ 配置即可。