Tomcat 8.5/RHEL 会话复制管理器 |不会复制会话属性值答案

【问题标题】：Tomcat 8.5/RHEL Session Replication Manager | Session Attribute value will not be replicatedTomcat 8.5/RHEL 会话复制管理器 |不会复制会话属性值
【发布时间】：2020-08-18 09:20:59
【问题描述】：

我有一个不寻常的“错误”。我已经配置了 Tomcat 会话复制管理器 (Delta)。复制了 SessionID 和 Session 属性，但不复制属性的内容。

我在 server.xml 中的集群标签

<Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster"
                 channelSendOptions="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="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.MessageDispatchInterceptor"/>
          </Channel>

          <Valve className="org.apache.catalina.ha.tcp.ReplicationValve"
                 filter=""/>
          <Valve className="org.apache.catalina.ha.session.JvmRouteBinderValve"/>

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

../webapps/ROOT/WEB-INF/web.xml 在所有其他机器上：

<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee
                      http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
  version="3.1"
  metadata-complete="true">

  <display-name>Welcome to Tomcat</display-name>
  <description>
     Welcome to Tomcat
  </description>
<distributable/>
</web-app>

../webapps/ROOT/index.jsp 适用于所有实例（1、2、..）

<%@page import="java.util.ArrayList"%>
<%@page import="java.util.Date"%>


<%@page import="java.util.List"%>
<%@page contentType="text/html" pageEncoding="UTF-8"%> 
<%@ page import="javax.servlet.http.HttpUtils.*" %>

<!DOCTYPE html>

<html>

<style type="text/css"> 
     th {
        font-weight:bold;
        text-align:left;
    }
</style> 



    <head>
        <meta http-equiv="Content-Type" content"text/html"; charset=UTF-8">
        <title> JSP PAGE </title>
    </head>
    
    <body>
    
    <FONT size = 5 COLOR="#0000FF">
    
    Instance 1 <br/> <br/>
    
    </FONT>
    
    
    
    <hr/>
    
    
    <br/>
    
    <table cellpadding="10" >
    <tr> <th> Session Id </th> <td> <%=request.getSession().getId()%> </td> </tr>
    <tr> <th> Is it New Session </th> <td> <%=request.getSession().isNew()%> </td> </tr>
    <tr> <th> Session Create Date </th> <td> <%=new Date(request.getSession().getCreationTime())%>  </td> </tr>
    <tr> <th> Session Access Date </th> <td> <%=new Date(request.getSession().getLastAccessedTime())%> </td> </tr>
    </table>
    
    <br/><br/><br/><br/>
    
    <b> Cart List </b> <br/>
    
    <hr/>

    <ul>
    
    <%
        String bookName = request.getParameter("bookName");
        List<String> listOfBooks = (List<String>) request.getSession().getAttribute("Books");
        
        if (listOfBooks == null) {
            listOfBooks = new ArrayList<String>();
            request.getSession().setAttribute("Books", listOfBooks);
        }
        
        if (bookName != null) {
            listOfBooks.add(bookName);
        }
        
        for (String book : listOfBooks ) { 
            out.println("<li>"+book + "</li>");
        }
    %>
    </ul>
<form action="index.jsp" method="POST" >
         <input type= "text" name="bookName" placeholder="Enter bookname" required /> 
         <input type = "submit" value = "add to cart" > <br/> 
         
</form>

通过 index.jsp 添加一些会话属性/值后的结果

在 INSTANCE1（主要）

关于INSTANCE2（备份）（属性不会被复制！）

在日志文件中，我看到实例相互识别并且发送信号。但是

当我发送 ping -t 1 -c 2 228.0.0.4 时，我得到以下信息： 发送2个包，接收0个，100%丢包，时间5852ms
为什么复制的是 SessionID 和 Attribute，而不是 Attribute 的值？

【问题讨论】：

标签： tomcat8 session-replication

【解决方案1】：

我终于能够解决这个问题，当我键入关键字时，没有人，甚至官方的 java 文档都没有帮助，这在文档世界中是一个耻辱！！！！！！！你看，我不认为 java 有一种开箱即用的方式来通知其他实例，只要列表的内容发生变化。没有 DatasetChangedNotify 方法来通知其他 tomcat 实例列表内容已更改，只有当会话属性本身发生更改时。

没错。我知道您正在关注 Ramki 的教程；我也是。不要听从你在互联网上找到的疯狂建议，因为它们不起作用；我试过了。完全按照 Ramki 的教程进行操作；无论他在视频中做什么，您都可以执行，但将您的 JSP scriptlet 更改为：

String bookName = request.getParameter("bookName");
List<String> listOfBooks = (ArrayList<String>) request.getSession().getAttribute("Books");
if(listOfBooks == null) {
  listOfBooks = new ArrayList<String>();                                      
}
if(bookName != null) {
    listOfBooks.add(bookName);
}
request.getSession().setAttribute("Books", listOfBooks);
for(String book: listOfBooks) {
    out.println("<li>" + book + "</li><br />");
}

您现在可能已经理解了，但如果其他人需要更多帮助，这就是正在发生的事情：在教程中，Ramki 仅在开始时将 listOfBooks 设置为 Books 会话属性的对象。它应该每次都设置它。

每当调用 setAttribute 方法时，所有 tomcat 实例都会收到通知，名称为 Books 的会话属性已更改，如果是列表，则会扫描列表，因此所有实例都会知道内容已被更改更改并将显示它们。不必担心您将始终将 Books 属性设置为自身，因为它只会被覆盖。

如果 setAttribute 只被调用一次，只要 listOfBooks 为空，当列表发生变化时，只有运行 scriptlet 的 tomcat 实例会被通知并根据会话属性采取相应的行动，但所有其他实例不会重新扫描他们在 Books 会话属性中的列表，因此他们的列表对他们来说仍然是空的。

这就是为什么您在第一个实例中有一个完整列表，但所有其他实例都有一个空列表。

【讨论】：