Tomcat会话保持方式实现与MSM配置实例

Tomcat会话保持方式

(1). session sticky:简单的基于会话保持机制,在调度器上实现;

  • source_ip:源地址绑定
    • nginx: ip_hash
    • haproxy: source
    • lvs: sh
  • cookie:基于cookie绑定
    • nginx:hash
    • haproxy: cookie

(2). session cluster:delta session manager ;是tomcat自带的会话集群;在调度器上不需要做会话绑定;
(3). session server:redis(store), memcached(cache);使用memcached构建session server;跟前端调度器没关系,tomcat要能调用后端的某个服务器的API完成会话数据存取;

注:此处基于前文中的LNAMT环境演示中配置的两台tomcat主机作为后端主机实验

1. 基于session sticky方式:

第一种方式实现::mod_proxy_http模块,并基于cookie实现会话粘性

session-sticky1.png

  编辑http的配置文件:
  [root@localhost ~]# vim /etc/httpd/conf.d/mod_proxy_http.conf
      内容如下:
      Header add Set-Cookie "ROUTEID=.%{BALANCER_WORKER_ROUTE}e; path=/" env=BALANCER_ROUTE_CHANGED
    <Proxy balancer://tcsrvs>
        BalancerMember http://192.168.43.15:8080 route=tomcatA loadfactor=1
        BalancerMember http://192.168.43.16:8080 route=tomcatB loadfactor=2
        ProxySet lbmethod=byrequests
        ProxySet stickysession=ROUTEID
    </Proxy>
    
    <VirtualHost *:80>
        ServerName www.inux.com
        ProxyVia ON
        ProxyRequests Off
        ProxyPreserveHost ON
        <Proxy *>
            Require all granted
        </Proxy>
        ProxyPass / balancer://tcsrvs/
        ProxyPassReverse / balancer://tcsrvs/
        <Location />
            Require all granted
        </Location>
    </VirtualHost>
[root@localhost ~]# httpd -t
Syntax OK
[root@localhost ~]# systemctl reload httpd.service

浏览器访问测试:


session-sticky2.png

在httpd中的mod_proxy_balancer模块,自带有管理页面:

在上文http配置文件中添加一个管理页面的location
[root@localhost ~]# vim /etc/httpd/conf.d/mod_proxy_http.conf
    <Location /balancer-manager>
        SetHandler balancer-manager
        ProxyPass !
        Require all granted
    </Location>
[root@localhost ~]# httpd -t
[root@localhost ~]# systemctl reload httpd.service

浏览器输入:http://192.168.43.12/balancer-manager

balancer-manager.png

第二种方式实现:mod_proxy_ajp模块

session-sticky3.png

[root@localhost ~]# httpd -M | grep "ajp" 
 proxy_ajp_module (shared)  确保mod_proxy_ajp模块加载并启用  
[root@localhost ~]# mv /etc/httpd/conf.d/mod_proxy_http.conf  /etc/httpd/conf.d/mod_proxy_http.conf.bak
[root@localhost ~]# vim /etc/httpd/conf.d/mod_proxy_ajp.conf
编辑内容如下: 
    <proxy balancer://tcsrvs>
            BalancerMember ajp://192.168.43.15:8009
            BalancerMember ajp://192.168.43.16:8009
            ProxySet lbmethod=byrequests
    </Proxy>
    
    <VirtualHost *:80>
            ServerName www.inux.com
            ProxyVia On
            ProxyRequests Off
            ProxyPreserveHost On
            <Proxy *>
                    Require all granted
            </Proxy>
            ProxyPass / balancer://tcsrvs/
            ProxyPassReverse / balancer://tcsrvs/
            <Location />
                    Require all granted
            </Location>
            <Location /balancer-manager>
                    SetHandler balancer-manager
                    ProxyPass !
                    Require all granted
            </Location>
    </VirtualHost>
[root@localhost ~]# httpd -t
[root@localhost ~]# systemctl restart httpd.service

使用浏览器访问可是实现轮询访问后端tomcat主机

第三种方式实现:nginx+tomcat

session-sticky4.png
<1> 源地址绑定:

修改nginx.conf配置文件中upstream上下文中:
[root@localhost ~]# vim /usr/local/nginx/conf/conf.d/proxy_nginx.conf
    upstream websrvs {
      server 192.168.43.15:8080 ;
      server 192.168.43.16:8080 ;
      server 127.0.0.1:80 backup;
      ip_hash;
      }
    server {
    listen 80;
    server_name www.ilinux.io;
    index index.html index.jsp;
    location / {
                proxy_pass http://websrvs;
            }
        }


 <2>基于cookie绑定:
 [root@localhost ~]# vim /usr/local/nginx/conf/conf.d/proxy_nginx.conf
     upstream websrvs {
      server 192.168.43.15:8080 ;
      server 192.168.43.16:8080 ;
      server 127.0.0.1:80 backup;
      hash srv_id;
      }
    server {
    listen 80;
    server_name www.ilinux.io;
    index index.html index.jsp;
    location / {
                proxy_pass http://websrvs;
            }
        }
[root@localhost ~]# nginx -t
nginx: the configuration file /usr/local/nginx/conf/nginx.conf syntax is ok
nginx: configuration file /usr/local/nginx/conf/nginx.conf test is successful
[root@localhost ~]# nginx -s reload
注意:使用session sticky做会话保持,缺陷是损坏负载均衡效果,某一主机掉线其上的会话也会丢失,这种方法实际中并不使用;真正用时,可使用会话集群或会话服务器来做会话绑定;
2. Tomcat Session Replication Cluster
tomcat-Cluster.png

(1) 配置启用集群,将下列配置放置于server.xml配置文件的<engine><host>段中;(注:此处为tomcat-8.5.34,版本,配置文件与之前版本略有不同)

<Engine name="Catalina" defaultHost="localhost" jvmRoute="node6">   #请确认此处jvmRoute名称与前代worker名称保持一致;
       
     <Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster"
                channelSendOptions="8">
                <Manager className="org.apache.catalina.ha.session.DeltaManager"
                expireSessionsOnShutdown="false"
                notifyListenersOnReplication="true"/>
                <Channel className="org.apache.catalina.tribes.group.GroupChannel">
                <Membership className="org.apache.catalina.tribes.membership.McastService"
                        address="228.0.0.4"
                        port="45564"
                        frequency="500"
                        dropTime="3000"/>
                <Receiver className="org.apache.catalina.tribes.transport.nio.NioReceiver"
                        address="auto"   #此处绑定的地址为auto时,会自动解析本地主机名,并解析得出的IP地址作为使用的地址;
                        port="4000"
                        autoBind="100"
                        selectorTimeout="5000"
                        maxThreads="6"/>

                <Sender className="org.apache.catalina.tribes.transport.ReplicationTransmitter">
                <Transport className="org.apache.catalina.tribes.transport.nio.PooledParallelSender"/>
                </Sender>
                <Interceptor className="org.apache.catalina.tribes.group.interceptors.TcpFailureDetector"/>
                <Interceptor className="org.apache.catalina.tribes.group.interceptors.MessageDispatchInterceptor"/>
                <Interceptor className="org.apache.catalina.tribes.group.interceptors.ThroughputInterceptor"/>

                </Channel>

                <Valve className="org.apache.catalina.ha.tcp.ReplicationValve"
                        filter=""/>
                <Valve className="org.apache.catalina.ha.session.JvmRouteBinderValve"/>
                <Deployer className="org.apache.catalina.ha.deploy.FarmWarDeployer"
                        tempDir="/tmp/war-temp/"
                        deployDir="/tmp/war-deploy/"
                        watchDir="/tmp/war-listen/"
                        watchEnabled="false"/>

            <ClusterListener className="org.apache.catalina.ha.session.ClusterSessionListener"/>
            </Cluster>

(2)配置webapps
编辑WEB-INF/web.xml,添加<distributable/>

[root@node6 ~]# systemctl stop tomcat.service 
[root@node6 ~]# cd /usr/local/tomcat
[root@node6 tomcat]# cp /usr/local/tomcat/conf/web.xml /usr/local/tomcat/webapps/test/WEB-INF/
[root@node6 tomcat]# vim /usr/local/tomcat/webapps/test/WEB-INF/web.xml
在文件中<servlet>之前添加`<distributable/>`

在另外一个tomcat主机上同样部署上两步即可
(3) 启动tomcat,查看日志

[root@node6 ~]# systemctl start tomcat.service
[root@node6 ~]# tail -200 /usr/local/tomcat/logs/catalina.2018-10-11.log 
...
11-Oct-2018 01:55:47.979 INFO [localhost-startStop-1] org.apache.catalina.ha.session.DeltaManager.getAllClusterSessions Manager [localhost#/test], requesting session state from [org.apache.catalina.tribes.membership.MemberImpl[tcp://{192, 168, 43, 15}:4000,{192, 168, 43, 15},4000, alive=15628, securePort=-1, UDP Port=-1, id={-94 23 -31 -98 -14 -48 67 -28 -91 -88 37 -65 11 99 96 66 }, payload={}, command={}, domain={}]]. This operation will timeout if no session state has been received within [60] seconds.
...

(4)在浏览器输入:http://192.168.43.11/test/
基于调度器后端不同主机,但会话保持不变;

tomcat-Cluster1.png

tomcat-Cluster2.png
3. session server: memcached-session-manager

memcached-session-manager项目地址:

http://code.google.com/p/memcached-session-manager/, https://github.com/magro/memcached-session-manager

memcached-msm.png

(1)在后端192.168.43.13和192.168.43.14两台主机上安装memcached

[root@localhost ~]# yum -y install memcached
[root@localhost ~]# rpm -ql memcached
/etc/sysconfig/memcached
/usr/bin/memcached
/usr/bin/memcached-tool
/usr/lib/systemd/system/memcached.service
/usr/share/doc/memcached-1.4.15
/usr/share/doc/memcached-1.4.15/AUTHORS
/usr/share/doc/memcached-1.4.15/CONTRIBUTORS
/usr/share/doc/memcached-1.4.15/COPYING
/usr/share/doc/memcached-1.4.15/ChangeLog
/usr/share/doc/memcached-1.4.15/NEWS
/usr/share/doc/memcached-1.4.15/README.md
/usr/share/doc/memcached-1.4.15/protocol.txt
/usr/share/doc/memcached-1.4.15/readme.txt
/usr/share/doc/memcached-1.4.15/threads.txt
/usr/share/man/man1/memcached-tool.1.gz
/usr/share/man/man1/memcached.1.gz
[root@localhost ~]# systemctl start memcached
[root@localhost ~]# ss -tnlp | grep memcached
LISTEN     0      128          *:11211                    *:*                   users:(("memcached",pid=17429,fd=26))
LISTEN     0      128         :::11211                   :::*                   users:(("memcached",pid=17429,fd=27))

(2)配置MSM
下载如下jar文件至各tomcat节点的tomcat安装目录下的lib目录中,

javolution-5.4.3.1.jar                   
msm-javolution-serializer-2.1.1.jar
memcached-session-manager-2.1.1.jar      
spymemcached-2.11.7.jar
memcached-session-manager-tc8-2.1.1.jar

分别在两个tomcat上的某host上定义一个用于测试的context容器,并在其中创建一个会话管理器,如下所示:

<Context path="/test" docBase="test" reloadable="true">
     <Manager className="de.javakaffee.web.msm.MemcachedBackupSessionManager"
            memcachedNodes="n1:172.16.100.9:11211,n2:172.16.100.10:11211"
            failoverNodes="n1"
            requestUriIgnorePattern=".*\.(ico|png|gif|jpg|css|js)$"
            transcoderFactoryClass="de.javakaffee.web.msm.serializer.javolution.JavolutionTranscoderFactory"
          />
     </Context>

启动tomcat:

[root@node6 conf]# systemctl start tomcat

查看日志:

[root@node6 ~]# tail /usr/local/tomcat/logs/catalina.2018-10-13.log
...
    -  finished initialization:
    - sticky: true
    - operation timeout: 1000
    - node ids: [m1]
    - failover node ids: [m2]
    - storage key prefix: null

前端调度器上反代2个tomcat主机 配置如下:

server {
    listen 80;
    server_name www.ilinux.io;
    index index.html index.jsp;
    location / {
                proxy_pass http://websrvs;
            }
        }
upstream websrvs {
          server 192.168.43.15:8080;
          server 192.168.43.16:8080;
          server 127.0.0.1:80 backup;
             }

浏览器访问测试实现会话粘性:


session-server1.png
session-server2.png
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 199,440评论 5 467
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 83,814评论 2 376
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 146,427评论 0 330
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,710评论 1 270
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,625评论 5 359
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,014评论 1 275
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,511评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,162评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,311评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,262评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,278评论 1 328
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,989评论 3 316
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,583评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,664评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,904评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,274评论 2 345
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 41,856评论 2 339

推荐阅读更多精彩内容

  • 从三月份找实习到现在,面了一些公司,挂了不少,但最终还是拿到小米、百度、阿里、京东、新浪、CVTE、乐视家的研发岗...
    时芥蓝阅读 42,157评论 11 349
  • tomcat的会话保持方式有三种:1、session sticky:会话粘滞,通过同一个客户端的相关请求分发到同一...
    姜饼人_9e7b阅读 1,900评论 0 2
  • 一、前言 tomcat集群会话保持方式大体可以分为三种:1、session sticky:利用前端调度器的负载均衡...
    小尛酒窝阅读 1,028评论 0 0
  • 会话保持Tomcat ClusterTomcat实现会话粘滞Tomcat实现会话集群Tomcat实现会话服务器 一...
    哈喽别样阅读 447评论 0 0
  • 蛋黄溶豆做法: 婴儿️段or️段奶粉20g,蛋黄3个(柴鸡蛋的话4个),柠檬汁3滴,白砂糖5g以内(可有可无)。 ...
    高娇阅读 214评论 0 0