Apache2+Tomcat7集群实现

青旅半醒 2022-04-14 05:37 301阅读 0赞

文章转载[http://wiki.bsdn.org][http_wiki.bsdn.org]

# 概述 #

Tomcat是J2EE开发当中使用最多的应用服务器，本章就来介绍一下使用Apache2应用服务器加上Tomcat6一起实现应用集群与负载均衡。这里我们使用的Tomcat为7.0.26；Apache版本为2.2，如果您机器上没有，请到[www.apache.org][]上下载，Tomcat7.0.26有两个，我们这里称之为tomcat1和tomcat2,下文中如果没特指tomcat1还是tomcat2，那么tomcat1和tomcat2都要进行操作,apache2.2只有一个。所以都准备好之后，接下来我们就来看看如何进行配置。

# 配置Tomcat集群 #

打开tomcat下conf/server.xml文件，找到<Engine name="Catalina" defaultHost="localhost">，增加jvmRoute属性，以支持AJP负载均衡。  
tomcat1改为<Engine name="Catalina" defaultHost="localhost" jvmRoute="jvm1">  
tomcat2改为<Engine name="Catalina" defaultHost="localhost" jvmRoute="jvm2">  
因为我们的两个Tomcat在是一台机器上运行，所以我们有必要修改其中一个Tomcat采用端口，以保证两个同时运行时不会产生冲突(当然，如果两个tomcat不在一台机器上运行，那么这个步骤就可以省略)。我们这里修改的是tomcat2,打开tomcat2下conf/server.xml文件，修改如下：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;Server port=</code> 
      <code>"8005"</code> 
      <code>shutdown=</code> 
      <code>"SHUTDOWN"</code> 
      <code>&gt;</code> 
     </div> 
     <div> 
      <code>修改为</code> 
     </div> 
     <div> 
      <code>&lt;Server port=</code> 
      <code>"9005"</code> 
      <code>shutdown=</code> 
      <code>"SHUTDOWN"</code> 
      <code>&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;Connector port=</code> 
      <code>"8080"</code> 
      <code>protocol=</code> 
      <code>"HTTP/1.1"</code>&nbsp; 
      <code>connectionTimeout=</code> 
      <code>"20000"</code> 
      <code>redirectPort=</code> 
      <code>"8443"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>修改为</code> 
     </div> 
     <div> 
      <code>&lt;Connector port=</code> 
      <code>"9080"</code> 
      <code>protocol=</code> 
      <code>"HTTP/1.1"</code>&nbsp;&nbsp;&nbsp;&nbsp; 
      <code>connectionTimeout=</code> 
      <code>"20000"</code>&nbsp; 
      <code>redirectPort=</code> 
      <code>"9443"</code> 
      <code>/&gt;。</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;Connector port=</code> 
      <code>"8009"</code> 
      <code>protocol=</code> 
      <code>"AJP/1.3"</code> 
      <code>redirectPort=</code> 
      <code>"8443"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>修改为</code> 
     </div> 
     <div> 
      <code>&lt;Connector port=</code> 
      <code>"9009"</code> 
      <code>protocol=</code> 
      <code>"AJP/1.3"</code> 
      <code>redirectPort=</code> 
      <code>"9443"</code> 
      <code>/&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

端口修改完成，我们需要来配置一个集群环境中的session复制，打开tomcat下conf/server.xml文件，在<Engine></Engine>节点内加入下面代码：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>&lt;Cluster className=</code> 
      <code>"org.apache.catalina.ha.tcp.SimpleTcpCluster"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>channelSendOptions=</code> 
      <code>"6"</code> 
      <code>&gt;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Manager className=</code> 
      <code>"org.apache.catalina.ha.session.BackupManager"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>expireSessionsOnShutdown=</code> 
      <code>"false"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>notifyListenersOnReplication=</code> 
      <code>"true"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>mapSendOptions=</code> 
      <code>"6"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;!--</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Manager className=</code> 
      <code>"org.apache.catalina.ha.session.DeltaManager"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>expireSessionsOnShutdown=</code> 
      <code>"false"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>notifyListenersOnReplication=</code> 
      <code>"true"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>--&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Channel className=</code> 
      <code>"org.apache.catalina.tribes.group.GroupChannel"</code> 
      <code>&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Membership className=</code> 
      <code>"org.apache.catalina.tribes.membership.McastService"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>address=</code> 
      <code>"228.0.0.4"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>port=</code> 
      <code>"45564"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>frequency=</code> 
      <code>"500"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>dropTime=</code> 
      <code>"3000"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Receiver className=</code> 
      <code>"org.apache.catalina.tribes.transport.nio.NioReceiver"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>address=</code> 
      <code>"auto"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>port=</code> 
      <code>"5000"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>selectorTimeout=</code> 
      <code>"100"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>maxThreads=</code> 
      <code>"6"</code> 
      <code>/&gt;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Sender className=</code> 
      <code>"org.apache.catalina.tribes.transport.ReplicationTransmitter"</code> 
      <code>&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Transport className=</code> 
      <code>"org.apache.catalina.tribes.transport.nio.PooledParallelSender"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;/Sender&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Interceptor className=</code> 
      <code>"org.apache.catalina.tribes.group.interceptors.TcpFailureDetector"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Interceptor className=</code> 
      <code>"org.apache.catalina.tribes.group.interceptors.MessageDispatch15Interceptor"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Interceptor className=</code> 
      <code>"org.apache.catalina.tribes.group.interceptors.ThroughputInterceptor"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;/Channel&gt;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Valve className=</code> 
      <code>"org.apache.catalina.ha.tcp.ReplicationValve"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>filter=</code> 
      <code>".*\.gif|.*\.js|.*\.jpeg|.*\.jpg|.*\.png|.*\.htm|.*\.html|.*\.css|.*\.txt"</code> 
      <code>/&gt;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;Deployer className=</code> 
      <code>"org.apache.catalina.ha.deploy.FarmWarDeployer"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>tempDir=</code> 
      <code>"/tmp/war-temp/"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>deployDir=</code> 
      <code>"/tmp/war-deploy/"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>watchDir=</code> 
      <code>"/tmp/war-listen/"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>watchEnabled=</code> 
      <code>"false"</code> 
      <code>/&gt;</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;ClusterListener className=</code> 
      <code>"org.apache.catalina.ha.session.ClusterSessionListener"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&lt;/Cluster&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

其中同台机器上的TCP端口不能有冲突，所以在上面的配置当中，对于Tomcat2需要修改节点Culster->Channel\->Reciver的port属性，默认为5000,tomcat识别的范围为4000-4100,这里把tomcat2的这个port属性修改为4001。

这些配置都完成后，接下来我们就可以在这两个Tomcat当中添加一个简单应用来实际测试一下集群效果。

# 测试Tomcat集群 #

在tomcat/webapps下，新建一文件夹为test，test文件夹下创建WEB-INF目录，创建标准web.xml文件，文件中一定要加入<distributable/>标签以支持分布式应用。

web.xml文件内容如下：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;?xml version=</code> 
      <code>"1.0"</code> 
      <code>encoding=</code> 
      <code>"ISO-8859-1"</code> 
      <code>?&gt; &lt;web-app xmlns=</code> 
      <code>"<a href="http://java.sun.com/xml/ns/javaee" rel="nofollow"><span style="text-decoration:underline;"><span style="color:#0066cc;">http://java.sun.com/xml/ns/javaee"</span></span></a></code>&nbsp;&nbsp; 
      <code>xmlns:xsi=</code> 
      <code>"<a href="http://www.w3.org/2001/XMLSchema-instance" rel="nofollow"><span style="text-decoration:underline;"><span style="color:#0066cc;">http://www.w3.org/2001/XMLSchema-instance"</span></span></a></code>&nbsp;&nbsp; 
      <code>xsi:schemaLocation=</code> 
      <code>"<a href="http://java.sun.com/xml/ns/javaee%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0%C2%A0" rel="nofollow"><span style="text-decoration:underline;"><span style="color:#0066cc;">http://java.sun.com/xml/ns/javaee&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</span></span></a> <a href="http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" rel="nofollow"><span style="text-decoration:underline;"><span style="color:#0066cc;">http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"</span></span></a></code>&nbsp;&nbsp; 
      <code>version=</code> 
      <code>"3.0"</code>&nbsp;&nbsp; 
      <code>metadata-complete=</code> 
      <code>"true"</code> 
      <code>&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;display-name&gt;Welcome to Test Tomcat7 Cluster&lt;/display-name&gt;&nbsp;&nbsp; </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;description&gt;Welcome to Test Tomcat7 Cluster&lt;/description&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;distributable/&gt;</code> 
     </div> 
     <div> 
      <code>&lt;/web-app&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

在test文件夹下建立test.jsp文件，文件内容如下：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;%@ page contentType=</code> 
      <code>"text/html; charset=UTF-8"</code> 
      <code>%&gt;</code> 
     </div> 
     <div> 
      <code>&lt;%@ page </code> 
      <code>import</code> 
      <code>=</code> 
      <code>"java.util.*"</code> 
      <code>%&gt;</code> 
     </div> 
     <div> 
      <code>&lt;html&gt;&lt;head&gt;&lt;title&gt;Cluster App Test&lt;/title&gt;&lt;/head&gt;</code> 
     </div> 
     <div> 
      <code>&lt;body&gt;</code> 
     </div> 
     <div> 
      <code>Server Info:</code> 
     </div> 
     <div> 
      <code>&lt;%</code> 
     </div> 
     <div> 
      <code>out.println(request.getLocalAddr() + </code> 
      <code>" : "</code> 
      <code>+ request.getLocalPort()+</code> 
      <code>"&lt;br&gt;"</code> 
      <code>);%&gt;</code> 
     </div> 
     <div> 
      <code>&lt;%</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>out.println(</code> 
      <code>"&lt;br&gt; ID "</code> 
      <code>+ session.getId()+</code> 
      <code>"&lt;br&gt;"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>// 如果有新的 Session 属性设置</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>String dataName = request.getParameter(</code> 
      <code>"dataName"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>if</code> 
      <code>(dataName != </code> 
      <code>null</code> 
      <code>&amp;&amp; dataName.length() &gt; </code> 
      <code>0</code> 
      <code>) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>String dataValue = request.getParameter(</code> 
      <code>"dataValue"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>session.setAttribute(dataName, dataValue);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>out.println(</code> 
      <code>"&lt;b&gt;Session 列表&lt;/b&gt;&lt;br&gt;"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>System.out.println(</code> 
      <code>"============================"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>Enumeration e = session.getAttributeNames();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>while</code> 
      <code>(e.hasMoreElements()) { </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>String name = (String)e.nextElement();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>String value = session.getAttribute(name).toString();</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>out.println( name + </code> 
      <code>" = "</code> 
      <code>+ value+</code> 
      <code>"&lt;br&gt;"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>System.out.println( name + </code> 
      <code>" = "</code> 
      <code>+ value);</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>%&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;</code> 
      <code>&lt;form action=</code> 
      <code>"index.jsp"</code> 
      <code>method=</code> 
      <code>"POST"</code> 
      <code>&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>名称:&lt;input type=text size=</code> 
      <code>20</code> 
      <code>name=</code> 
      <code>"dataName"</code> 
      <code>&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;br&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>值:&lt;input type=text size=</code> 
      <code>20</code> 
      <code>name=</code> 
      <code>"dataValue"</code> 
      <code>&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;br&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;input type=submit&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;</code> 
      <code>&lt;/form&gt;</code> 
     </div> 
     <div> 
      <code>&lt;/body&gt;</code> 
     </div> 
     <div> 
      <code>&lt;/html&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

这个简单的JSP可以把提交的值保存到Session当中，同时显示出来。

启动tomcat1,等tomcat1启动完成后，启动tomcat2。先访问tomcat1对应的test工程[http://localhost:8080/test.jsp][http_localhost_8080_test.jsp]页面，输入值并提交，然后把链接转到tomcat2对应的test工程[http://localhost:9080/test.jsp][http_localhost_8080_test.jsp]页面，看看session内容是否相同，如果相同则说明session复制成功，也就是群集成功。  
接下来我们在这两个Tomcat前端添加一个Apache Http Server，所有访问请求通过这个Http Server进行转发，根据tomcat1或2的忙碌情况决定转发给tomcat1或者是tomcat2去处理用户请求。

# Apache负载均衡 #

打开并修改apache安装目录下conf/httpd.conf文件，找到下面这些内容：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>#LoadModule negotiation_module modules/mod_negotiation.so</code> 
     </div> 
     <div> 
      <code>#LoadModule proxy_module modules/mod_proxy.so</code> 
     </div> 
     <div> 
      <code>#LoadModule proxy_ajp_module modules/mod_proxy_ajp.so</code> 
     </div> 
     <div> 
      <code>#LoadModule proxy_balancer_module modules/mod_proxy_balancer.so</code> 
     </div> 
     <div> 
      <code>#LoadModule proxy_connect_module modules/mod_proxy_connect.so</code> 
     </div> 
     <div> 
      <code>#LoadModule proxy_ftp_module modules/mod_proxy_ftp.so</code> 
     </div> 
     <div> 
      <code>#LoadModule proxy_http_module modules/mod_proxy_http.so</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

去掉这些\#，也就是启用这些被注释掉的功能，并且在文件的未尾处添加下面这些内容：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>ProxyPass / balancer:</code> 
      <code>//cluster/ stickysession=JSESSIONID</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>ProxyPassReverse / balancer:</code> 
      <code>//cluster/</code> 
     </div> 
     <div> 
      <code>&lt;proxy balancer:</code> 
      <code>//cluster&gt;</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>BalancerMember ajp:</code> 
      <code>//127.0.0.1:8009 loadfactor=1 route=jvm1</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>BalancerMember ajp:</code> 
      <code>//127.0.0.1:9009 loadfactor=1 route=jvm2</code> 
     </div> 
     <div> 
      <code>&lt;/proxy&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

重新启动apache,以apache作为负载均衡器的tomcat集群建立完成，所有请求都可以通过请求apache http server，通过这个http server转发到具体的tomcat服务器。

# Tomcat集群和Session复制详解 #

### Cluster ###

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;Cluster className=</code> 
      <code>"org.apache.catalina.ha.tcp.SimpleTcpCluster"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>channelSendOptions=</code> 
      <code>"8"</code> 
      <code>&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

Tomcat集群的主元素，在Cluster元素里面配置了集群的详细信息。目前Tomcat仅提供了org.apache.catalina.ha.tcp.SimpleTcpCluste作为唯一的实现类。下面是Cluster详细属性：

<table> 
 <thead> 
  <tr> 
   <th> 
    <div> 
     <p>属性</p> 
    </div> </th> 
   <th> 
    <div> 
     <p>描述</p> 
    </div> </th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td> <p>className</p> </td> 
   <td> <p>Cluste的实现类，当前org.apache.catalina.ha.tcp.SimpleTcpCluste作为唯一的实现类。</p> </td> 
  </tr> 
  <tr> 
   <td> <p>channelSendOptions</p> </td> 
   <td> <p>Session发送方式，默认值为:8。当消息通过SimpleTcpCluster发送时，用来决定如何发送信息。</p> 
    <div style="border-width:1px;"> 
     <div> 
      <div> 
       <div> 
        <div> 
         <a href="http://wiki.bsdn.org/pages/viewpage.action?pageId=2621465" rel="nofollow"><span style="text-decoration:underline;"><span style="color:#0066cc;">?</span></span></a> 
        </div> 
        <table> 
         <tbody> 
          <tr> 
           <td> 
            <div title="Hint: double-click to select code"> 
             <div> 
              <code>int</code> 
              <code>options= Channel.SEND_OPTIONS_ASYNCHRONOUS |</code> 
             </div> 
             <div> 
              <code>Channel.SEND_OPTIONS_SYNCHRONIZED_ACK | Channel.SEND_OPTIONS_USE_ACK;</code> 
             </div> 
            </div> </td> 
          </tr> 
         </tbody> 
        </table> 
       </div> 
      </div> 
     </div> 
    </div> 
    <div style="border-width:1px;"> 
     <div> 
      <div> 
       <div> 
        <div> 
         <a href="http://wiki.bsdn.org/pages/viewpage.action?pageId=2621465" rel="nofollow"><span style="text-decoration:underline;"><span style="color:#0066cc;">?</span></span></a> 
        </div> 
        <table> 
         <tbody> 
          <tr> 
           <td> 
            <div title="Hint: double-click to select code"> 
             <div> 
              <code>Channel.SEND_OPTIONS_SYNCHRONIZED_ACK = </code> 
              <code>0x0004</code> 
             </div> 
             <div> 
              <code>Channel.SEND_OPTIONS_ASYNCHRONOUS = </code> 
              <code>0x0008</code> 
             </div> 
             <div> 
              <code>Channel.SEND_OPTIONS_USE_ACK = </code> 
              <code>0x0002</code> 
             </div> 
            </div> </td> 
          </tr> 
         </tbody> 
        </table> 
       </div> 
      </div> 
     </div> 
    </div> <p>如果使用异步(ASYNCHRONOUS)加应答(USE_ACK)方式来发送消息，那么值应该是10(8+2)或者0x000B。</p> </td> 
  </tr> 
 </tbody> 
</table>

### Manager ###

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;Manager className=</code> 
      <code>"org.apache.catalina.ha.session.DeltaManager"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>expireSessionsOnShutdown=</code> 
      <code>"false"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>notifyListenersOnReplication=</code> 
      <code>"true"</code> 
      <code>/&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

Manager用来在Tomcat节点之前复制Session，当前有两个实现类，分别为：org.apache.catalina.ha.session.DeltaManagert和org.apache.catalina.ha.session.BackupManager。DeltaManager调用SimpleTcpCluster.send方法来发送信息，复制并发送Session到集群下所有的节点，不管这个节点有没有部署当前程序。  
BackupManager通过自己直接调用channel来发送信息，复制并发送Session到集群下部署了当前程序的节点。  
DaltaManager的优点是经过实践确认和证明的，非常可靠，而BackupManager在可靠性上不如DaltaManager。DaltaManager缺点是要求集群节点必须部署了同样的程序，节点必须是同种类的。  
下面是Manager的属性描述：

<table> 
 <thead> 
  <tr> 
   <th> 
    <div> 
     <p>属性</p> 
    </div> </th> 
   <th> 
    <div> 
     <p>描述</p> 
    </div> </th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td> <p>className</p> </td> 
   <td> <p>Manager的实现类。</p> </td> 
  </tr> 
  <tr> 
   <td> <p>notifyListenersOnReplication</p> </td> 
   <td> <p>如果设置为true,当session属性被复制和移动的时候，session listener被通知</p> </td> 
  </tr> 
  <tr> 
   <td> <p>expireSessionsOnShutdown</p> </td> 
   <td> <p>当一个web程序被结束时，tomcat分发销毁命令到每个Session，并通知所有session listener执行。当集群下某个节点被停止时，如果想销毁所有节点下的的Session，设置为true，默认为false 。</p> </td> 
  </tr> 
 </tbody> 
</table>

BackupManager属性：

<table> 
 <thead> 
  <tr> 
   <th> 
    <div> 
     <p>属性</p> 
    </div> </th> 
   <th> 
    <div> 
     <p>描述</p> 
    </div> </th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td> <p>mapSendOptions</p> </td> 
   <td> <p>BackupManager通过一个可复制的map来实现session接受和发送，通过设置mapSendOptions来设定这个map以何种方式来发送信息，默认为:6(asynchronous)。</p> </td> 
  </tr> 
 </tbody> 
</table>

### Channel ###

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;Channel className=</code> 
      <code>"org.apache.catalina.tribes.group.GroupChannel"</code> 
      <code>&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

Channel是Apache Tribes的主组件，channel管理一组子组件，并和它们一起组成了tomcat实例间的通讯框架。在tomcat集群中，DeltaManager通过SimpleTcpCluster调用channel来实现信息传递，而BackupManager自己调用channel以及子组件这些组件来实现信息传递。ReplicatedContext也会调用channel传递context属性。  
下面是channel子组件  
\*MemberShip  
MemberShip组件自动检索发现集群里的新节点或已经停止工作的节点，并发出相应的通知。默认使用组播（Multicast）实现。  
\*Sender  
Sender组件管理从一个节点发送到另外一个节点的出站连接和数据信息，允许信息并行发送。默认使用TCP Client Sockets。  
\*Receiver  
Receiver组件负责监听接收其他节点传送过来的数据。默认使用non-blocking TCP Server sockets。  
\*Interceptor  
Channel通过Interceptor堆栈进行消息传递，在这里可以自定义消息的发送和接收方式，甚至MemberShip的处理方式。

### Value ###

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;Valve className=</code> 
      <code>"org.apache.catalina.ha.tcp.ReplicationValve"</code> 
      <code>filter=</code> 
      <code>" .*\.gif;.*\.js;.*\.jpg;.*\.png;.*\.css;.*\.txt; "</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&lt;Valve className=</code> 
      <code>"org.apache.catalina.ha.session.JvmRouteBinderValve"</code> 
      <code>/&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

Cluster下的Value同其他tomcat value一样，value在调用Http Request 链中起着拦截器的作用，用来决定什么情况下数据需要被复制。  
org.apache.catalina.ha.tcp.ReplicationValve，ReplicationValue在Http Request结尾判断当前数据是否需要被复制。它的具体属性描述如下表所示：

<table> 
 <thead> 
  <tr> 
   <th> 
    <div> 
     <p>属性</p> 
    </div> </th> 
   <th> 
    <div> 
     <p>描述</p> 
    </div> </th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td> <p>className</p> </td> 
   <td> <p>org.apache.catalina.ha.tcp.ReplicationValve，ReplicationValue</p> </td> 
  </tr> 
  <tr> 
   <td> <p>filter</p> </td> 
   <td> <p>Filter内容为url或者文件结尾，当访问链接配置filter时，不论实际session有没有改变，集群会认为session没有任何变化，从而不会复制和发送改变的session属性。Filter写法如下：filter=" .<strong>\.gif;.</strong>\.js;.<strong>\.jpg;.</strong>\.png;.<strong>\.css;.</strong>\.txt; "。filter使用正则表达式，每个url或者后缀以逗号分开。</p> </td> 
  </tr> 
 </tbody> 
</table>

### Deployer ###

使集群支持farmed deployment。这个功能还很弱，在变化和更改中。

### ClusterListener ###

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div title="Hint: double-click to select code"> 
     <div> 
      <code>&lt;ClusterListener className=</code> 
      <code>"org.apache.catalina.ha.session.JvmRouteSessionIDBinderListener"</code> 
      <code>/&gt;</code> 
     </div> 
     <div> 
      <code>&lt;ClusterListener className=</code> 
      <code>"org.apache.catalina.ha.session.ClusterSessionListener"</code> 
      <code>/&gt;&lt;/Cluster&gt;</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

Clusterlistener用来追踪信息发送和接收。JvmRouteSessionIDBinderListener用来监听session id的变化。这个listener仅当使用mod\_jk并且属性有jvmRoute时才起作用。当session id 改变后，JvmRouteBinderValve将广播这个信息并被此listener捕获。ClusterSessionListener用来监听集群组件接收信息，当使用DeltaManager的时候，信息被集群接收，并通过ClusterSessionListener传递给Session Manager。

# Apache负载均衡详解 #

[?][Link 1]

通过Apache自带的mod\_proxy某块来使用代理技术连接tomcat， ajp\_proxy需要tomcat提供ajp服务。

[http_wiki.bsdn.org]: http://wiki.bsdn.org/
[www.apache.org]: http://www.apache.org/
[Link 1]: http://wiki.bsdn.org/pages/viewpage.action?pageId=2621465
[http_localhost_8080_test.jsp]: http://localhost:8080/test.jsp