tomcat集群(共享session)

    其实就是上述这样的一个架构，下面是原理   

    1)  Apache装有一个模块，这个模块叫mod_jk   
2)  Apache通过80端口负责解析任何静态web内容

    3)  任何不能解析的内容，用表达式告诉mod_jk，让mod_jk派发给相关的app server去解释。   

    通过上述的文字描述我们可以得知：   

    1） 我们需要在Apache中先装一个mod_jk   

    2） 我们需要在httpd.conf中写点表达式   

    下面来实现。   

    1)  把mod_jk.so手工copy进我们的Apache安装目录的modules目录下   

    下载地址  http://www.apache.org/dist/tomcat/tomcat-connectors/jk/binaries/windows/   

 

 

####### Apache整合Tomcat start #######    #此处mod_jk的文件为你下载的文件    LoadModule jk_module modules/mod_jk.so    #指定tomcat监听配置文件地址    JKWorkersFile conf/workers.properties    #指定日志存放位置    JkLogFile logs/mod_jk.log    JkLogLevel info    <VirtualHost localhost>        ServerAdmin localhost        DocumentRoot "D:\www"        ServerName localhost                SetEnv force-proxy-request-1.0.1        SetEnv proxy-nokeepalive 1                DirectoryIndex index.html index.htm index.jsp index.action        ErrorLog logs/shsc-error_log.txt        CustomLog logs/shsc-access_log.txt common        JkMount /*WEB-INF ajp13        JkMount /*j_spring_security_check ajp13        JkMount /*.action ajp13        JkMount /servlet/* ajp13        JkMount /*.jsp ajp13        JkMount /*.do ajp13        JkMount /*.action ajp13        JkMount /*fckeditor/editor/filemanager/connectors/*.* ajp13        JkMount /fckeditor/editor/filemanager/connectors/* ajp13    </VirtualHost>    ####### Apache整合Tomcat end #######

    

    Apache    conf
    目录下 建个    workers.properties
    文件 内容如下： 

 

   

     

ps=    worker.list=ajp13 #模块版本    worker.ajp13.port=8009 #工作端口,若没占用则不用修改    worker.ajp13.host=localhost #本机,若上面的Apache主机不为localhost,作相应修改    worker.ajp13.type=ajp13 #类型    #worker.ajp13.lbfactor=1 #代理数,不用修改

            

   

 

 

   

    集群配置 tomcat6
   

    第一种，simple tcp cluster (tomcat5以上版本自带的基于tcp广播技术的集群，这种方法比较简单，只需修改server.xml配置文件即可)   

    在<Engine></Engine>添加如下配置代码，多台机器，只需修改第二个 address (本机地址)和port 即可。 

 

<Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster" channelSendOptions="6">  <Manager className="org.apache.catalina.ha.session.BackupManager" expireSessionsOnShutdown="false" notifyListenersOnReplication="true" mapSendOptions="6" />  <!--    <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="   192.168.67.143" port="   4001" selectorTimeout="100" 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.MessageDispatch15Interceptor" />    <Interceptor className="org.apache.catalina.tribes.group.interceptors.ThroughputInterceptor" />  </Channel>  <Valve className="org.apache.catalina.ha.tcp.ReplicationValve" filter=".*\.gif;.*\.js;.*\.jpg;.*\.png;.*\.htm;.*\.html;.*\.css;.*\.txt;" />  <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.JvmRouteSessionIDBinderListener" />  <ClusterListener className="org.apache.catalina.ha.session.ClusterSessionListener" />

 

      注意：在 Tomcat的集群复制中，分为DeltaManager和BackupManager两种，前者适合于小型系统，任何情况下，均进行Session复 制，消耗大量资源。所以，我们应该采用BackupManager，仅在需要的时候(Tomcat挂掉的时候)进行Session复制。如果是在同一台机器上配置多个tomcat实例来进行集群的测试，那么请一定要注意tomcat实例运行的端口和 集群所监听的端口是否冲突！   

   
     

   
    ⑥
    最后修改web应用WEB-INF目录下的    web.xml
    文件 在    </web-app>
    前加    <distributable />
   

       标签（这个是tomcat进行session复制所必须的，否则session不能进行复制！）   

          或者
    改变Tomcat的content.xml配置文件，修改 <Context distributable="true">   

 

 

   tomcat的集群部署修改动作都比较简单，但实际在运行过程中会出现一系列的问题，我这里列举我在配置后使用过程中出现的一些问题和要点，供大家参考：

 

1、用户存入SESSION中的数据的问题

 

      使用tomcat集群进行SESSION复制，必须要保证你的session中存放的所有对象都是实现了java.io.Serializable接口 的，因为session复制就是序列化对象到其他WEB应用服务器上的，所以如果没有实现该接口，那么SESSION同步将会失败。另外一点，就是如果要 同步的机器比较多的话，那么要注意保证SESSION中存放的数据比较小，不要什么都存放到SESSION中，因为复制SESSION也是需要开销的，数 据越大开销也越大。

 

2、Tomcat执行SESSION复制的触发条件

 

      我们在tomcat的server.xml文件中集群部分cluster标签中可以看到属性：useDirtyFlag， 如果这个设置为true（默认的），那么只有当使用setAttribute往session中设置数据的时候才会同步其他WEB服务器的 SESSION，如果为false,那么每一次请求的sesison都会被同步到其他服务器上。因此在操作SESSION的时候要特别注意，避免出现 SESSION无法同步的问题。

 

      举个简单的例子，比如我们在单机应用情况下修改SESSION中用户的某一个数据，那么通常就是：

 

   

     

       
1. 
            

   User user = (User)request.getSession().getAttribute(“user”);

   
          

       
2. 
            

   User.setName(“my name”);

   
          

     

   

 

 

      这样我们就是直接存取出来，然后进行修改，虽然在单机情况下没有问题，但是在集群条件下，这样就导致了多台WEB服务器上的SESSION不同步的问 题，因为SESSION并没有改变，Tomcat无法监视session中某个数据的值是否发生了变化。因此，我们还需要执行如下操作以保证 SESSION的同步：

 

   

     

       
1. 
            

   request.getSession().setAttribute(“user”, user);

   
          

     

   

 

 

      所以，我们在操作SESSION的时候要特别注意！另外的建议就是，我们应该尽可能的不要修改SESSION中的数据。

 

      因为Tomcat的SESSION复制通信是通过组播功能来实现不同服务器之间的交互的，所以需要在服务器上开通组播功能，windows默认情况下是开通组播服务的，而Linux系统下默认是没有开通的，我们需要通过如下命令来开通其组播功能：

 

   

     

       
1. 
            

   route add -net 224.0.0.0 netmask 240.0.0.0 dev eth0

   
          

     

   

 

 

    如果需要服务器启动时即开通组播需在/etc/sysconfig/static-routes文件内加入eht0 net 224.0.0.0 netmask 240.0.0.0。具体组播概念请查阅CCNP相关内容。

 

    可以通过netstate -g 来查看组播状态，也可以在route -e 命令中看到   

        

        

    第二种，使用memcached共享session   

    memcached-session-manager 配置   

    让tomcat 调用memcached 来存储session 早就是一个很成熟的解决方案了，开源的msm 就可以解决这个问题。   

    官方给出的4 种序列化方案，其中kryo 是效率最高的，具体比较看官方地址：   

    http://code.google.com/p/memcached-session-manager/wiki/SerializationStrategies   

    下载地址：   

    http://code.google.com/p/memcached-session-manager/downloads/list   

    本次实验用的tomcat版本为6.0.18，以下为我用包,,谁有需要可以联系我,(高版本的自己测试如果不报错,,就可以直接用)   

    kryo-1.03.jar   

    reflectasm-0.9.jar   

    minlog-1.2.jar   

    kryo-serializers-0.8.jar   

    memcached-2.5.jar   

    memcached-session-manager-tc7-1.5.1.jar   

    msm-kryo-serializer-1.5.1.jar   

    memcached-session-manager-1.5.1.jar   

    把以上8个包丢在tomcat的lib文件夹   

    修 改Tomcat的配置文件context.xml，调整成新的session存储方式，在配置文件中<context>标签内加入一下代码 （如果memcached跟tomcat不在同一台机器，修改127.0.0.1为memcached所在机器的IP）：   

        

        

        

    <Manager className="de.javakaffee.web.msm.MemcachedBackupSessionManager"   

    memcachedNodes="n1:127.0.0.1:11211"   

    sticky="false"   

    lockingMode="auto"   

    sessionBackupAsync="false"   

    sessionBackupTimeout="1000"   

    transcoderFactoryClass="de.javakaffee.web.msm.serializer.kryo.KryoTranscoderFactory"   

    />   

    在tomcat/conf/logging.properties 文件中添加de.javakaffee.web.msm.level=FINE ， 就可以在   

    catalina.out 的日志中看到详细的session 存取情况。   

        

    一般前边还有Nginx做转发,分发给不同机器的tomcat上面,,    tomcat集群(共享session)