我正在独立模式下设置 EAP 7 集群。我按照本教程设置了我的集群。
然后我开始用一个简单的JMS应用程序测试JMS系统。每次发送 JMS 消息时，我都会观察到 JMS 消息计数仅在其中一个节点中更新(而不是视频中显示的两个节点)。发送的消息总数等于来自两个节点的计数总和。
但是，由于节点是集群的，我希望 JMS 统计信息是同步的(如视频所示)，因此两个节点都应显示集群中收到的消息总数，而不是仅显示其中的一部分。
此外，在发送计划消息时，如果节点持有消息死亡，则消息将被阻止，直到死节点重新启动。这绝对是不可接受的，因为我希望计划的消息由另一个(正在运行的)节点传递。
所有测试均使用默认的独立全 HA 执行.xml
以下是重现该问题的所有步骤：
环境设置
- 下载 eap7.1/7.2 或 wildfly12/14 并解压缩到目录
- 将目录重命名为 my-dir-node1
- 将 your-dir-node1 复制到 my-dir-node2
- 更新配置
- 转到 my-dir-node1/standalone 并将 standalone-full-ha.xml复制到 inalone-full-ha-test.xml
- 编辑 my-dir-node1/standalone/standalone-full-ha-test.xml
- 将 name="node1" 添加到根元素：
<server xmlns="urn:jboss:domain:5.0" name="node1"> - 搜索
<cluster password="${jboss.messaging.cluster.password:CHANGE ME!!}"/>并将其替换为<cluster password="${jboss.messaging.cluster.password:mypassword}"/> - 在
<jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>后添加<jms-queue name="JMSTest" entries="java:/jms/queue/test"/> - 转到 my-dir-node2/standalone 并重复上述步骤。 确保将其命名为"节点2"而不是"节点1">
通过将 test-jms.war 复制到 my-dir-node1/standalone/deploy 和 your-dir-node2/standalone/deploy 来部署测试应用
我的测试应用的内容
<%@ page import="javax.naming.InitialContext" %>
<%@ page import="javax.jms.*" %>
<%@ page import="java.util.logging.Logger" %>
<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<%
Logger logger = Logger.getLogger("JMSSender");
InitialContext initialContext = new InitialContext();
ConnectionFactory factory = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
Destination destination = (Destination)initialContext.lookup("java:/jms/queue/test");
Connection connection = factory.createConnection();
Session session1 = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer messageProducer = session1.createProducer(destination);
String body = request.getParameter("message");
if (body == null)
body = "Hello World!";
TextMessage message = session1.createTextMessage(body);
String delay = request.getParameter("delay");
if (delay != null)
message.setJMSDeliveryTime(System.currentTimeMillis() + Integer.parseInt(delay));
messageProducer.send(message);
logger.info("Send message: " + body);
%>
<html>
<head>
<title>Test JMS Sender</title>
</head>
<body>
<h1>Message</h1>
<p><strong><%=body%></strong></p>
<p>Add ?message=xxx to the url to change the message.</p>
<p>Add ?delay=xxx to the url to schedule a delivery at a later time. The unit of delay is in millisecond. ie: 1 second = 1000 </p>
</body>
</html>
JMS 接收器：
import org.apache.log4j.Logger;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
@MessageDriven(mappedName = "testQueue", activationConfig = {
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge")
, @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
, @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:/jms/queue/test")
})
public class JMSReceiver implements MessageListener {
// Logger for the class
private static Logger logger = Logger.getLogger(JMSReceiver.class.getName());
@Override
public void onMessage(Message message) {
TextMessage t = (TextMessage) message;
try {
logger.info(t.getText());
} catch (JMSException e) {
logger.info(e.getMessage());
}
}
}
网络.xml
<?xml version="1.0" encoding="UTF-8"?>
<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_4_0.xsd"
version="4.0">
<welcome-file-list>
<welcome-file>index.jsp</welcome-file>
</welcome-file-list>
</web-app>
您对 EAP 中的消息传递集群(以及您链接的视频)的理解不正确。如果向 EAP 中的消息传递群集发送 1 条消息，则群集中只有1个节点具有该消息。这些消息不会在群集中的所有节点之间复制。集群中每个节点的 JMS 统计信息不一定是同步的。
实际上，您所看到的是预期的行为。此外，这是您链接的视频中演示的内容。在视频中，客户端应用程序每次运行时发送2条消息。一条消息转到一个群集节点，第二条消息转到另一个群集节点。这就是为什么每个节点上的"添加的消息"指标增加并且似乎同步的原因。发送 2 条消息时，每个节点上的"添加的消息数"指标增加 1 (1+1=2)。添加到群集中队列的消息总数可以通过对群集中每个节点的"添加的消息数"求和来确定。
了解此行为非常重要，因为这意味着如果群集中的某个节点出现故障，则该节点上的所有消息都将不可用(如您所观察到的)。如果您希望消息在节点发生故障时可用，则需要配置实时/备份对。有关如何完成此操作的更多详细信息，请参阅 EAP 文档。