问题标签 [node-amqp]

我在 Meteor 应用程序中使用 node-amqp 通过 SSL 连接到 rabbitMQ 服务器。这是我的连接字符串：

但是，没有建立连接。以下是 RabbitMQ 错误日志：

我在记录溢出错误中所能找到的只是检查正在运行的 Erlang 版本。我试图与之建立连接的盒子正在使用最新版本。我不确定运行 RabbitMQ 的盒子，但我会调查一下。任何进一步的帮助将不胜感激。

我有一些代码，我想从我的 Meteor 应用程序中获取 RabbitMQ 的当前消息计数。在 Node 控制台中运行代码正确地给出了回调参数，但在 Meteor 中相同的代码只给出了第一个参数。

在节点打印中：

在流星打印中：

关于为什么在 Meteor 中运行时只有第一个（队列）参数出现的任何想法？我是流星菜鸟，所以也许是纤维问题？

Does anyone have an example of creating a topic exchange in Node-amqp? I've already gone through https://github.com/rabbitmq/rabbitmq-tutorials/tree/master/javascript-nodejs but unfortunately it doesn't recreate tutorials 4+ from the RabbitMQ website.

我正在尝试编写一个 node.js 客户端（订阅者模块）来使用来自 rabbitmq（AMQP）的消息。我正在尝试在 rabbitmq 中实现主题（exchangeName）。

我正在尝试使用 (easy-amqp) 或 postwait 来完成此任务。

我在 java 中编写了一个发布者方法，并想在 javascript（node.js）中编写一个订阅者方法。

我的 java 程序运行良好，我能够向rabbitmq 发送消息。

我想我搞砸了订阅者方法。当我运行订阅者方法时，它不会给我任何错误，也不会向控制台打印任何消息。

我的java方法有点像

//js中的订阅者方法（node.js） //使用（postwait-node-amqp）

这不会给我任何错误，但它甚至不会将任何消息打印到控制台。

所以后来我遇到了另一个名为 easy-amqp 的库。我试了一下

// 订阅者使用 easy-amqp。

这也没有给我想要的结果。

需要一些建议。

这是一个示例，我从 node.js 开始：

ActiveMQ 写入记录：

我认为，这个错误是因为 61616 端口的协议是 tcp，而不是 amqp。但是当我尝试在控制台输出中将端口更改为 5672 时，我看到：

netstat -antp 返回：

如您所见，ActiveMQ 监听 5672.. 但是，不要连接。为什么？？？我尝试了其他 node.js 模块，例如 node-amqp.js，但没有任何改变。可能是我错过了 connection_tunnig 中的某些内容吗？（frameSize 等）请，真的需要建议。谢谢你。

如果我使用以下代码向 RabbitMQ 发送消息：

...然后消息永远不会发送，并且该过程就退出了。如果我删除process.exit()，则发送消息，但该过程永远不会退出。

如何让node-amqp告诉我它何时发送消息？

我在 Node.js 中收到以下错误，我认为它与 AMQP 有关。

谁能指出问题可能是什么？

这是我用来连接的模块中的代码：

这里是我调用该方法的地方：

我有快速服务器设置来监听发布请求并将发布请求放入消息队列

上面的代码假设收集发布请求并放入队列，如果我发送 10 个请求，队列中将有 300 多条消息。我不理解这种行为，或者可能是我对将 'publish' 调用放入 'ready' 函数的理解是错误的，因为上面代码中的 'connected' 日志消息对于 10 个 post 请求打印超过 10 个。

是否由于“connection.end”未关闭连接而发生？

我想将每个 post 请求转换为 RabbitMQ 中的消息，请告知是否有更好的方法。

（我在 ubuntu 12.04 上使用最新的 node-amqp master 和 rabbit-server-3.1.4-1）

当我发布到默认交易所时，我似乎无法得到确认。我目前正在使用这篇文章建议的 node-amqp 的主分支建议的 node-amqp 的主分支。

代码：

我相信默认交换是一个空字符串的直接交换（所有其他选项都是默认的）。根据exchange.publish 方法，如果确认选项为真，它将调用提供的回调。我试图自己创建交易所，但也没有运气。

我可以使用我可以通过使用RabbitMQ 网站上的基本 python 接收脚本

默认交换是否在发布方法中发出确认消息？我叫错了吗？

我有 2 个 Rabbitmq 节点作为集群连接（没有队列复制），并且有 4 个工作人员，都绑定到同一个队列“myqueue”，现在，我手动将消息发布到该队列（发布者可以连接到任何兔子节点 .. 不影响结果）。

现在，发生了这种情况：每次我向该队列发布消息时，我发现消息以循环方式传递给工作人员/消费者，无论消费者或发布者连接到哪个节点，我总是得到同样的结果。

有人告诉我这是 Rabbitmq 的“prefetch_count”的效果，但我不明白这是怎么回事，甚至我也不知道这是否是正确的答案。