专栏名称: hryou0922
目录
相关文章推荐
德州晚报  ·  她被永久封禁!彻底凉凉 ·  9 小时前  
冯唐  ·  要红了! ·  2 天前  
鲁中晨报  ·  突然暴跌!超21万人爆仓 ·  2 天前  
51好读  ›  专栏  ›  hryou0922

Spring Boot系列十二 通过redis实现Tomcat集群的Session同步及从源码分析其原理

hryou0922  · 掘金  ·  · 2018-02-07 02:06

正文

1. 概述

在tomcat等web容器中,session是保存在本机内存中。如果我们对tomcat做集群,不可避免要涉及到session同步的问题,必须保证同一个集群中的tomcat的session是共享的。本文通过Spring boot实现分布式系统Session同步,主要包括如下内容:

  • 详细介绍demo实现
  • 从源码的角度分析其实现原理

2. 多个tocmat的Session的管理。

在tomcat等web容器中,session是保存在本机内存中。如果我们对tomcat做集群,不可避免要涉及到session同步的问题,必须保证同一个集群中的tomcat的session是共享的。 为了tomcat集群正常的工作,通常有以下的方法:

a. 在tomcat的前端配置nginx等,采用ip_hash负载均衡算法,保证来自同一个IP的访客固定访问一个后端服务器,这样避免多个tomcat需要session同步的问题。这个方法也有缺陷,如果这台服务停机了,则所有的用户状态都丢失了
b. 通过tomcat自带的cluster方式,多个tomcat之间实时共享session信息,但是此方法随着tomcat数量和请求量增加性能会下降的比较厉害
c. 利用filter方法
d. 利用terracotta服务器共享session
e. 利用redis、memcached等中间件存储session

下文演示在spring boot中使用redis实现session的共享

3. spring boot中使用redis实现session的共享

3.1. Demo工程介绍

工程名称: redis
引入依赖jar

<!-- spring 引入 session 信息存储到redis里的依赖包  -->
<dependency>
    <groupId>org.springframework.session</groupId>
    <artifactId>spring-session-data-redis</artifactId>
</dependency>

application-dev.properties的session相关配置参数

### session的配置 start ############
# session的存储方式的类型配置
spring.session.store-type=redis
#spring.session.redis.namespace=
# session 存活时间
server.session.timeout=300
### session的配置 end ############

测试类SessionTestCtrl
在SessionTestCtrl.java中,我们会发现在配置redis共享后对session的操作和默认的session操作没有任何区别,其原理我们在下文的原理里再说。
此类有3个方法:
login(): 模拟登陆,在session中存储一个值

@RequestMapping("login")
public Map<String,Object> login(HttpServletRequest request) {
    HttpSession httpSession = request.getSession();
    // 设置session中的值
    httpSession.setAttribute("username", "hry" + System.currentTimeMillis());

    Map<String,Object> rtnMap = new HashMap<>();
    Enumeration<String> attributeNames = request.getSession().getAttributeNames();
    while(attributeNames.hasMoreElements()){
        String name = attributeNames.nextElement();
        rtnMap.put(name, httpSession.getAttribute(name));
    }
    rtnMap.put("sessionId", httpSession.getId());
    return rtnMap;
}

getSession(): 从session中获取值

@RequestMapping("get-session")
public Object getSession(HttpServletRequest request) {
    HttpSession httpSession = request.getSession();
    Map<String,Object> rtnMap = new HashMap<>();
    Enumeration<String> attributeNames = request.getSession().getAttributeNames();
    while(attributeNames.hasMoreElements()){
        String name = attributeNames.nextElement();
        rtnMap.put(name, httpSession.getAttribute(name));
    }
    int count;
    try {
        count = Integer.parseInt(String.valueOf(httpSession.getAttribute("count")));
        count++;
    }catch (NumberFormatException e){
        count = 1;
    }
    httpSession.setAttribute("count",count+"");

    rtnMap.put("sessionId", httpSession.getId());
    return rtnMap;
}

invalidate(): 使的sesion值失效

@RequestMapping("invalidate")
 public int invalidate(HttpServletRequest request) {
     HttpSession httpSession = request.getSession();
     httpSession.invalidate();
     return 1;
 }

SessionTestCtrl的完整代码 这里

3.2. 测试

启动RedisApplication
登录: http://127.0.0.1:8080/login
输出:
{"count":"5","sessionId":"a095bdf3-e907-4fac-bf5e-132f7d737000","username":"hry1517311682642"}

获取session的信息: http://127.0.0.1:8080/get-session
输出:

{"count":"5","sessionId":"a095bdf3-e907-4fac-bf5e-132f7d737000","username":"hry1517311682642"}

查看redis里的session的值:我们的session值已经存储到redis中了
这里写图片描述

查看浏览器里cookies的值和我们生成的session值相同,说明我们redis生成的session代替了默认的session.
这里写图片描述
服务重启后,访问 http://127.0.0.1:8080/get-session ,session值不变,说明redis保存session生效了
输出:

{"count":"7","sessionId":"a095bdf3-e907-4fac-bf5e-132f7d737000","username":"hry1517311682642"}

执行使用session失效的URL: http://127.0.0.1:8080/invalidate ,再去执行 http://127.0.0.1:8080/get-session ,此时session值变了,且count值没有了,说明invalidate方法成功了

{"sessionId":"a54128d6-55c5-4233-aa97-54816b51c5cf"}  

4. 从源码的角度分析其实现原理

在上文中,我们发现使用redis共享session后,对其的操作和普通的session操作没有任何区别,我们可以通过源代码查找其原理。

4.1. ExpiringSessionHttpSession

在spring-session-data-redis定义新的HttpSession对象代替默认:ExpiringSessionHttpSession ExpiringSessionHttpSession:此类继承HttpSession,上文中对Session的操作实际就是这个session

class ExpiringSessionHttpSession<S extends ExpiringSession> implements HttpSession { 
…
} 

通过类的继承关系,可知道,除了使用redis存储共享session,还有GemFire, Hazelcast,jdbc,mongo,Map等
这里写图片描述







请到「今天看啥」查看全文