我有三台机器位于不同的网络中：
- 作为主
- 作为节点-1
- 作为节点-2
在作为主节点中，我将 WildFly 作为域主机主，两个节点将 WildFly 作为域主机从属，每个节点都在 full-ha 服务器组中启动一个实例。从主 Web 控制台中，我可以看到 full-ha 配置文件运行时中的两个节点，如果我部署 WAR，它会在两个节点上正确启动。
现在，我试图实现的是 WAR 的两个实例之间的消息传递，即从 as-node-1 中的生产者实例发送消息，所有节点中的消费者都应该收到该消息。
这是我尝试过的：在WildFly中添加了一个主题domain.xml：
<jms-topic name="MyTopic" entries="java:/jms/my-topic"/>
创建 JAX-RS 端点以触发绑定到主题的生产者：
@Path("jms")
@RequestScoped
public class MessageEndpoint {
@Inject
JMSContext context;
@Resource(mappedName = "java:/jms/my-topic")
Topic myTopic;
@GET
public void sendMessage() {
this.context.createProducer().send(this.myTopic, "Hello!");
}
}
创建侦听主题的 MDB：
@MessageDriven(activationConfig = {
@ActivationConfigProperty(
propertyName = "destination",
propertyValue = "java:/jms/my-topic"
),
@ActivationConfigProperty(
propertyName = "destinationType",
propertyValue = "javax.jms.Topic")
)
)
public class MyMessageListener implements MessageListener {
private final static Logger LOGGER = /* ... */
public void onMessage(Message message) {
try {
String body = message.getBody(String.class)
LOGGER.info("Received message: " + body);
} catch (JMSException e) {
throw new RuntimeException(e);
}
}
}
但是当我curl as-node-1/jms时，我只在节点 1 中看到日志，而当我curl as-node-2/jms时，我只在节点 2 中看到日志。
消息不应该在部署 WAR 的所有节点上传递吗？我错过了什么？
因为我提出了完全相同的问题 - 把答案放在这里。
是的，如果目标是主题，则应将消息传递到所有节点。
使用默认配置，ActiveMQ Artemis使用广播来发现并连接到其他节点(在同一发现组中(上的其他ActiveMQ实例：
<discovery-group name="dg-group1" jgroups-channel="activemq-cluster"/>
<cluster-connection name="my-cluster" discovery-group="dg-group1" connector-name="http-connector" address="jms"/>
仍然需要确保 jms-topic 的 JNDI 名称以">jms"开头，以匹配上面行中的address="jms"(在您的情况下可以："java:/jms/my-topic"(
在您的示例中，要使其在所有节点上工作，唯一遗漏的是：<cluster password="yourPassword" user="activemqUser"/>
(当然activemqUser必须更早添加用户，例如使用 addUser.sh 脚本(。
这允许 ActiveMQ 实例相互通信。所谓的核心桥连接是在节点之间创建的。如ActiveMQ手册中所述：
..这是在幕后透明地完成的 - 您不必 为每个节点声明显式网桥
如果一切正常，则可以在服务器中找到网桥.log：AMQ221027: Bridge ClusterConnectionBridge@63549ead [name=sf.my-cluster ...] is connected.
顺便说一句，如果目标是队列，那么ActiveMQ不会向其他节点发送消息，除非消息未在本地使用。
P.s. 正如这里回答的那样，这是指将事件分发到集群中所有节点的经典方法。