QQ账号登录	立即注册>>

您现在的位置：论坛 › 盖世程序员(我猜到了开头却没有猜到结局) › 运维优化 > Tomcat6 配置集群和Apache2负载均衡配合详解

总共48087条微博

动态微博

发表新帖

查看: 2405|回复: 0

Tomcat6 配置集群和Apache2负载均衡配合详解

admin

1244 主题	544 听众	1万金钱

管理员

TA的每日心情

	衰 2021-2-2 11:21

签到天数: 36 天

[LV.5]常住居民I

电梯直达

楼主

发表于 2014-07-16 19:54:09 |只看该作者 |倒序浏览

Tomcat6 配置集群和Apache2负载均衡
环境

apache-tomcat-6.0.28 两个，分别为tomcat1、tomcat2。下文中如果没特指tomcat1还是tomcat2，那么tomcat1和tomcat2都要进行操作。
apache2.2 一个。

tomcat集群修改tomcat Engine

打开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 2端口配置

由于tomcat1和tomcat2在同一台机器上，所以为了防止端口冲突，其中的一个 tomcat相关端口需要修改。在这里修改tomcat2。
打开tomcat下conf/server.xml文件，修改如下：
<Server port="8005" shutdown="SHUTDOWN">修改为<Server port="9005" shutdown="SHUTDOWN">。
<Connector port="8080" protocol="HTTP/1.1" connectionTimeout="20000" redirectPort="8443" />修改为 <Connector port="9080" protocol="HTTP/1.1" connectionTimeout="20000" redirectPort="9443" />。
<Connector port="8009" protocol="AJP/1.3" redirectPort="8443" />修改为 <Connector port="9009" protocol="AJP/1.3" redirectPort="9443" />。

提示：tomcat在不同机器上，此步骤可省略。

集群和Session复制

打开tomcat下conf/server.xml文件，在tomcat <Engine></Engine>内加入下面代码：

其中同台机器上的TCP Port不要冲突，TCP Port CulsterChannelReciver的port属性，默认为4000,tomcat识别的范围为4000-4100,这里把tomcat2 TCP Port改为4001。

应用程序支持集群

在应用程序web.xml中加入<distributable/>元素使应用程序支持集群，即Web应用是以这样的方式编程的：支持集群的服务器可安全地在多个服务器上分布Web应用。或者打开tomcat下conf/context.xml文件,修改<Context >为<Context distributable="true"> ，让tomcat发布的应用程序支持集群。
这里采取修改<Context>方法。

context复制

对context添加一个实现类即可实现context复制，打开tomcat下conf/context.xml文件,修改<Context>为

如果我们之前已经修改了<Context>为<Context distributable="true">，需要再添加上distributable="true"这个属性。

测试Tomcat集群

在tomcat/webapps下，新建一文件夹为test，在test文件夹下建立test.jsp文件，文件内容，如下：

<%@ page contentType="text/html; charset=UTF-8"%>
< %@ page import="java.util.*" %>
< html><head><title>Cluster App Test</title></head>
< body>
Server Info:
< %
out.println(request.getLocalAddr() + " : " + request.getLocalPort()+"<br>");%>
< %
request.setCharacterEncoding("UTF-8");
out.println("<br> ID " + session.getId()+"<br>");
String dataName = request.getParameter("dataName");

if (dataName != null && dataName.length() > 0) {
String dataValue = request.getParameter("dataValue");
session.setAttribute(dataName, dataValue);
}

out.print("<b>Session 内容列表</b> <br>");

Enumeration e = session.getAttributeNames();
while (e.hasMoreElements()) {
String name = (String)e.nextElement();
String value = session.getAttribute(name).toString();
out.println( name + " :" + value+"<br>");
}
%>
<form action="test.jsp" method="POST" >
名称:<input type=text size=20 name="dataName">
<br>
值 &nbsp&nbsp:<input type=text size=20 name="dataValue">
<br>
<input type=submit value="提交" >
</form>
< /body>
< /html>

这个简单的工程用来可以把提交的值保存到Session，并显示出来。启动tomcat1,等tomcat1启动完成后，启动tomcat2。先访问tomcat1对应的test工程test.jsp页面，输入值，并提交，然后把链接转到tomcat2对应的test工程test.jsp页面，看看session内容是否相同。如果相同则测试成功。

Apache负载均衡

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

#LoadModule negotiation_module modules/mod_negotiation.so
#LoadModule proxy_module modules/mod_proxy.so
#LoadModule proxy_ajp_module modules/mod_proxy_ajp.so
#LoadModule proxy_balancer_module modules/mod_proxy_balancer.so
#LoadModule proxy_connect_module modules/mod_proxy_connect.so
#LoadModule proxy_ftp_module modules/mod_proxy_ftp.so
#LoadModule proxy_http_module modules/mod_proxy_http.so

去掉"#"。
在文件最后加入：

ProxyPass / balancer://cluster/ stickysession=JSESSIONID

ProxyPassReverse / balancer://cluster/
< proxy balancer://cluster>
BalancerMember ajp://127.0.0.1:8009 loadfactor=1 route=jvm1
BalancerMember ajp://127.0.0.1:9009 loadfactor=1 route=jvm2
< /proxy>

重新启动apache,以apache作为负载均衡器的tomcat集群建立完成。

tomcat集群和Session复制详解Cluster

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

属性	描述
className	Cluste的实现类，当前org.apache.catalina.ha.tcp.SimpleTcpCluste作为唯一的实现类。
channelSendOptions	Session发送方式，默认值为:8。当消息通过SimpleTcpCluster发送时，用来决定如何发送信息。 file:///C:/Users/user/AppData/Local/YNote/Data/qq57D9FF2695CBD92A0CA37197DDB53806/ba4faf0a62094fa7815db0ea13f28dc0/n-attachment.pngfile:///C:/Users/user/AppData/Local/YNote/Data/qq57D9FF2695CBD92A0CA37197DDB53806/ba4faf0a62094fa7815db0ea13f28dc0/n-attachment.pngfile:///C:/Users/user/AppData/Local/YNote/Data/qq57D9FF2695CBD92A0CA37197DDB53806/ba4faf0a62094fa7815db0ea13f28dc0/n-attachment.png
int options= Channel.SEND_OPTIONS_ASYNCHRONOUS	Channel.SEND_OPTIONS_SYNCHRONIZED_ACK	Channel.SEND_OPTIONS_USE_ACK;

Channel.SEND_OPTIONS_SYNCHRONIZED_ACK = 0x0004Channel.SEND_OPTIONS_ASYNCHRONOUS = 0x0008Channel.SEND_OPTIONS_USE_ACK = 0x0002

如果使用异步(ASYNCHRONOUS)加应答(USE_ACK)方式来发送消息，那么值应该是10(8+2)或者0x000B。|

Manager

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

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

BackupManager属性

属性	描述
mapSendOptions	BackupManager通过一个可复制的map来实现session接受和发送，通过设置mapSendOptions来设定这个map以何种方式来发送信息，默认为值:6(asynchronous)。

Channel

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

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

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

Deployer

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

ClusterListener

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

Apache负载均衡详解

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

科帮网 1、本主题所有言论和图片纯属会员个人意见，与本社区立场无关
2、本站所有主题由该帖子作者发表，该帖子作者与科帮网享有帖子相关版权
3、其他单位或个人使用、转载或引用本文时必须同时征得该帖子作者和科帮网的同意
4、帖子作者须承担一切因本文发表而直接或间接导致的民事或刑事法律责任
5、本帖部分内容转载自其它媒体，但并不代表本站赞同其观点和对其真实性负责
6、如本帖侵犯到任何版权问题，请立即告知本站，本站将及时予与删除并致以最深的歉意
7、科帮网管理员和版主有权不事先通知发贴者而删除本文