# 节点1配置（192.168.1.10）
cat > /Tomcat/app/conf/server.xml << EOF

























EOF

# 节点2配置（192.168.1.11）
cat > /Tomcat/app/conf/server.xml << EOF

























EOF

# 在应用的web.xml中启用分布式会话
cat > /Tomcat/app/webapps/myapp/WEB-INF/web.xml << EOF



SessionTest
com.fgedu.SessionTest


SessionTest
/session


EOF

# 创建会话测试Servlet
mkdir -p /Tomcat/app/webapps/myapp/WEB-INF/classes/com/fgedu

cat > /Tomcat/app/webapps/myapp/WEB-INF/classes/com/fgedu/SessionTest.java << EOF package com.fgedu; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession; import java.io.IOException; import java.io.PrintWriter; public class SessionTest extends HttpServlet { @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { resp.setContentType("text/html"); PrintWriter out = resp.getWriter(); HttpSession session = req.getSession(true); Integer count = (Integer) session.getAttribute("count"); if (count == null) { count = 1; } else { count++; } session.setAttribute("count", count); out.println("“);
out.println(““);
out.println(“”);
out.println(“

Session Test

“);
out.println(“

Session ID: ” + session.getId() + “

“);
out.println(“

Count: ” + count + “

“);
out.println(“

Server: ” + req.getLocalAddr() + “:” + req.getLocalPort() + “

“);
out.println(“”);
}
}
EOF

# 编译Servlet
javac -d /Tomcat/app/webapps/myapp/WEB-INF/classes /Tomcat/app/webapps/myapp/WEB-INF/classes/com/fgedu/SessionTest.java

# 配置Nginx负载均衡
cat > /etc/nginx/conf.d/tomcat_cluster.conf << EOF upstream tomcat_cluster { server 192.168.1.10:8080; server 192.168.1.11:8080; } server { listen 80; server_name fgedu.net.cn; location / { proxy_pass http://tomcat_cluster; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; proxy_set_header X-Forwarded-Proto $scheme; } } EOF # 重启Nginx服务 systemctl restart nginx # 启动两个Tomcat节点 # 节点1 /Tomcat/app/bin/startup.sh # 节点2 /Tomcat/app/bin/startup.sh # 查看集群状态 # 查看Tomcat日志 cat /Tomcat/app/logs/catalina.out | grep "Cluster" # 输出示例： INFO: Cluster is about to start INFO: Received memberAdded: org.apache.catalina.tribes.membership.MemberImpl[tcp://192.168.1.11:4000,{192.168.1.11, 4000, 64000, 0}] INFO: Cluster is now operational

# 测试会话复制
# 第一次访问
curl http://fgedu.net.cn/myapp/session

# 输出示例：

Session Test

Session ID: 9F8E7D6C5B4A3B2C1D0E

Count: 1

Server: 192.168.1.10:8080

# 第二次访问（应该保持会话）
curl -b “JSESSIONID=9F8E7D6C5B4A3B2C1D0E” http://fgedu.net.cn/myapp/session

# 输出示例：

Session Test

Session ID: 9F8E7D6C5B4A3B2C1D0E

Count: 2

Server: 192.168.1.11:8080

# 第三次访问（继续保持会话）
curl -b “JSESSIONID=9F8E7D6C5B4A3B2C1D0E” http://fgedu.net.cn/myapp/session

# 输出示例：

Session Test

Session ID: 9F8E7D6C5B4A3B2C1D0E

Count: 3

Server: 192.168.1.10:8080

# 验证会话复制
# 查看Tomcat日志中的会话复制信息
cat /Tomcat/app/logs/catalina.out | grep “replication”

# 输出示例：
INFO: Replication of session 9F8E7D6C5B4A3B2C1D0E completed successfully

# 故障转移测试
# 1. 首先访问应用，获取会话
curl http://fgedu.net.cn/myapp/session

# 输出示例：

Session Test

Session ID: 9F8E7D6C5B4A3B2C1D0E

Count: 1

Server: 192.168.1.10:8080

# 2. 停止节点1
/Tomcat/app/bin/shutdown.sh

# 3. 再次访问应用，应该自动转移到节点2
curl -b “JSESSIONID=9F8E7D6C5B4A3B2C1D0E” http://fgedu.net.cn/myapp/session

# 输出示例：

Session Test

Session ID: 9F8E7D6C5B4A3B2C1D0E

Count: 2

Server: 192.168.1.11:8080

# 4. 验证故障转移
# 查看Nginx日志
cat /var/log/nginx/access.log | grep “fgedu.net.cn”

# 输出示例：
192.168.1.1 – – [21/Jul/2024:11:00:00 +0800] “GET /myapp/session HTTP/1.1” 200 200 “-” “curl/7.68.0”
192.168.1.1 – – [21/Jul/2024:11:00:05 +0800] “GET /myapp/session HTTP/1.1” 200 200 “-” “curl/7.68.0”

# 查看节点2的Tomcat日志
cat /Tomcat/app/logs/catalina.out | grep “Member removed”

# 输出示例：
INFO: Received memberRemoved: org.apache.catalina.tribes.membership.MemberImpl[tcp://192.168.1.10:4000,{192.168.1.10, 4000, 64000, 0}]

更多学习教程公众号风哥教程itpux_com