问题标签 [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.
node.js - Meteor + node-amqp:无法通过 SSL 连接到 RabbitMQ 服务器
我在 Meteor 应用程序中使用 node-amqp 通过 SSL 连接到 rabbitMQ 服务器。这是我的连接字符串:
但是,没有建立连接。以下是 RabbitMQ 错误日志:
我在记录溢出错误中所能找到的只是检查正在运行的 Erlang 版本。我试图与之建立连接的盒子正在使用最新版本。我不确定运行 RabbitMQ 的盒子,但我会调查一下。任何进一步的帮助将不胜感激。
javascript - 在 Meteor 中运行的回调中未定义的回调参数
我有一些代码,我想从我的 Meteor 应用程序中获取 RabbitMQ 的当前消息计数。在 Node 控制台中运行代码正确地给出了回调参数,但在 Meteor 中相同的代码只给出了第一个参数。
在节点打印中:
在流星打印中:
关于为什么在 Meteor 中运行时只有第一个(队列)参数出现的任何想法?我是流星菜鸟,所以也许是纤维问题?
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.
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。
这也没有给我想要的结果。
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 等)请,真的需要建议。谢谢你。
node.js - 等到 node-amqp 发送消息?
如果我使用以下代码向 RabbitMQ 发送消息:
...然后消息永远不会发送,并且该过程就退出了。如果我删除process.exit()
,则发送消息,但该过程永远不会退出。
如何让node-amqp告诉我它何时发送消息?
node.js - AMQP 警告:检测到可能的 EventEmitter 内存泄漏。增加了 11 位听众。
我在 Node.js 中收到以下错误,我认为它与 AMQP 有关。
谁能指出问题可能是什么?
这是我用来连接的模块中的代码:
这里是我调用该方法的地方:
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)
node.js - RabbitMQ & node-amqp - 默认交换未确认
当我发布到默认交易所时,我似乎无法得到确认。我目前正在使用这篇文章建议的 node-amqp 的主分支建议的 node-amqp 的主分支。
代码:
我相信默认交换是一个空字符串的直接交换(所有其他选项都是默认的)。根据exchange.publish 方法,如果确认选项为真,它将调用提供的回调。我试图自己创建交易所,但也没有运气。
我可以使用我可以通过使用RabbitMQ 网站上的基本 python 接收脚本
默认交换是否在发布方法中发出确认消息?我叫错了吗?
rabbitmq - 为什么 Rabbitmq 集群以 Round-Robin 方式向消费者传递消息
我有 2 个 Rabbitmq 节点作为集群连接(没有队列复制),并且有 4 个工作人员,都绑定到同一个队列“myqueue”,现在,我手动将消息发布到该队列(发布者可以连接到任何兔子节点 .. 不影响结果)。
现在,发生了这种情况:每次我向该队列发布消息时,我发现消息以循环方式传递给工作人员/消费者,无论消费者或发布者连接到哪个节点,我总是得到同样的结果。
有人告诉我这是 Rabbitmq 的“prefetch_count”的效果,但我不明白这是怎么回事,甚至我也不知道这是否是正确的答案。