Apache+Tomcat实现负载均衡(2)

<%@ page contentType="text/html; charset=GBK" %>
<%@ page import="java.util.*" %>
<html><head><title>Cluster Test</title></head>
<body>
<%
  //HttpSession session = request.getSession(true);
  System.out.println(session.getId());
  out.println("<br> SESSION ID:" + session.getId()+"<br>"); 
  // 如果有新的请求,则添加session属性
  String name = request.getParameter("name");
  if (name != null && name.length() > 0) {
    String value = request.getParameter("value");
    session.setAttribute(name, value);
  } 
    out.print("<b>Session List:</b>"); 
    Enumeration<String> names = session.getAttributeNames();
    while (names.hasMoreElements()) {
        String sname = names.nextElement();
        String value = session.getAttribute(sname).toString();
        out.println( sname + " = " + value+"<br>");
        System.out.println( sname + " = " + value);
  }
%>
  <form action="testCluster.jsp" method="post">
    名称:<input type=text size=20>
    <br>
    值:<input type=text size=20>
    <br>
    <input type=submit value="提交">
  </form>

<b>负载均衡测试:此为:Tomcat7_a上的文件,<font color=red>bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb</font><b>
</body>
</html>

此时访问就会再个不同的页面了,一个为aaaaaaaaaaaaaaaaaaaaaaaaaaaa 一个为bbbbbbbbbbbbbbbbbbbbbbbbbbb;

如下图所示:

Apache+Tomcat实现负载均衡

Apache+Tomcat实现负载均衡

看到的两个Session的值不同,因为这里还没有session的共享配置

注意:

以上仅仅实现了负载均衡,但是对于两个负载同时宕机的话,就需要另外的一台服务器来代替了,这第n+1台服务器就叫热备服务器,配置方式与以上相同,仅需要写上status=+H 标识即可。

BalancerMember :8009 status=+H

以上负载均衡就算全部完成了,如果要实现Session共享,最简单的方式就是在Tomcat中进行配置,配置如下:

在 service.xml文件中的 Engine节点,添加如下代码:

<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"
                      port="4001"
                      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.MessageDispatch15Interceptor"/>
          </Channel>

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/26578ed18ad6296b5e3e2702efaf1c45.html