nodejs rhea npm for amqp无法在activemq artemis中的地址上创建订阅队列

Question

我有一个地址“pubsub.foo”已经在broker.xml中配置为多播。

<address name="pubsub.foo">
   <multicast/>
</address>

根据Artemis文档：

当客户端连接到具有多播元素的地址时，将自动为客户端创建客户端的订阅队列。

我正在创建一个简单的实用程序，使用rhea AMQP Node.js npm将消息发布到地址。

var connection = require('rhea').connect({ port: args.port, host: args.host, username:'admin', password:'xxxx' });

var sender = connection.open_sender('pubsub.foo');
sender.on('sendable', function(context) {
    var m = 'Hii test' 
    console.log('sent ' + m);
    sender.send({body:m});
    connection.close();
});

我启用了调试日志，在运行客户机代码时，我看到如下所示的消息。

2020-02-03 22:43:25,071 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl] Message org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage@68933e4b is not going anywhere as it didn't have a binding on address:pubsub.foo

我还尝试了该主题的不同变体，例如client1.pubsub.foo、pubsub.foo::client1，但是从客户机代码中看不到结果。请分享你的想法。我是ActiveMQ Artemis的新手。

Answer 1

你所观察到的实际上是预期的行为。

不幸的是，您引用的文档并不那么清楚。当它说将创建订阅队列以响应客户端的连接时，它实际上是指订阅者，而不是生产者。这就是它创建订阅队列的原因。多播地址（以及一般的发布/订阅）的语义规定，当没有订阅者时发送的消息将被删除。因此，您需要创建订阅服务器，然后发送消息。

如果您想要不同的语义，那么我建议您使用选播。