问题标签 [node-amqp]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
772 浏览

node.js - Meteor + node-amqp:无法通过 SSL 连接到 RabbitMQ 服务器

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

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

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

0 投票
1 回答
120 浏览

javascript - 在 Meteor 中运行的回调中未定义的回调参数

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

在节点打印中:

在流星打印中:

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

0 投票
1 回答
4928 浏览

node.js - Node-amqp example of Topic exchange

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.

0 投票
1 回答
886 浏览

node.js - rabbitmq 的 node.js 订阅客户端(实现主题(ExcahangeName))

我正在尝试编写一个 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。

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

0 投票
1 回答
1631 浏览

javascript - Node.js+node_amqp.js 无法连接到 ActiveMQ 61616 或 5672 端口

需要一些建议。

这是一个示例,我从 node.js 开始:

ActiveMQ 写入记录:

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

netstat -antp 返回:

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

0 投票
1 回答
1016 浏览

node.js - 等到 node-amqp 发送消息?

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

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

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

0 投票
2 回答
2191 浏览

node.js - AMQP 警告:检测到可能的 EventEmitter 内存泄漏。增加了 11 位听众。

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

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

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

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

0 投票
1 回答
2154 浏览

node.js - node-amqp + rabbitMQ 如何将 post 请求转换为消息

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

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

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

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

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

0 投票
1 回答
1702 浏览

node.js - RabbitMQ & node-amqp - 默认交换未确认

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

代码:

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

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

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

0 投票
1 回答
1740 浏览

rabbitmq - 为什么 Rabbitmq 集群以 Round-Robin 方式向消费者传递消息

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

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

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