问题标签 [node-amqp]

我在 Node.js 中使用 amqplib，我不清楚我的代码中的最佳实践。

基本上，我当前的代码amqp.connect()在节点服务器启动时调用，然后为每个生产者和每个消费者使用不同的通道，从不真正关闭它们中的任何一个。我想知道这是否有意义，或者我应该在每次我想发布消息时创建频道、发布并关闭它。那么连接呢？连接一次，然后在我的服务器的整个生命周期内保持打开状态是一种“好习惯”吗？
在消费者方面 - 我可以使用单个连接和单个通道来侦听多个队列吗？

感谢您的任何澄清

我正在使用 senecajs 开发一个 node.js 社交网络应用程序，并且需要实现一个生产者可以向多个消费者发送相同消息的场景。我发现一篇文章似乎说明了使用 senecajs 完成此操作的示例代码。问题是我正在尝试将其转换为我的场景，这是本文中的示例（https://github.com/senecajs/seneca-amqp-transport/issues/27）：

我有 1 个客户端向 2 个听众发布事件。

客户：

听众：

有几个项目令人困惑：

1. 对于客户端设置，似乎名称最终会成为“development:events”或“production:events”。我的这种想法正确吗？

2. 对于exchange对象外的监听器的name字段，这个字段的作用是什么？

3. 当我调用 add 方法时，我需要传入一个名称，该名称映射到侦听器收到消息时进行的函数调用，我是否会将“incomingMessage：*”传递给 add 调用？

4. 这段代码真的会使用 senecajs 有效地提供扇出功能吗？

从队列中消费消息时，我想检索用于将该队列绑定到交换的绑定键（带通配符）。

这有可能吗？

谢谢

我正在尝试使用 rabbitMQ 设置任务队列，并与 Node.js 和 React.js 耦合。我无法理解任务管理的实际工作原理，而且我在网上找不到一个很好的例子。

我正在尝试发送一个任务（例如在用户单击时生成大量图像）并将其发送到队列，这样它就不会阻止用户导航。任何人都可以尝试指导我完成整个过程吗？

我的 rabbitMQ 服务器启动并运行，并且能够发送/接收消息。我只是无法将其转换为任务管理工具（例如发送/接收与任务相关的数据）。欢迎任何帮助/示例！

问候伙计们。
你能帮我异步输入node.js吗？

这个问题：

我正在使用amqplib 模块与RabbitMQ一起工作，这里有方法consume，它从 RabbitMQ 提供消息，但该方法首先返回关于他开始的承诺，在这个承诺开始后，他调用回调从 RabbitMQ 获取数据，我不知道如何捕捉所有消息何时发送到我的节点 js 应用程序。

更多解释，这里是我的代码和最后的代码，我写了我想要的：

如何在 nodejs 中将 amqplib 的预取计数设置为 1？ 链接到 git 上的 Lib

期望的结果是消费者只从队列中获取一条消息处理它，并在完成后获取一条新消息。我有一个设置，其中一些消息需要很长时间才能处理，而另一些则需要很短的时间。因此，我不只是想在所有消费者身上平等地分享消息。

我使用nodejs amqplib 模块连接rabbitmq。我发现consume函数变成了一个闭包函数，但我不明白为什么。我没有使用闭包。

我的代码如下。我发现returnOK中的corr仍然获得了第一次值。当我第二次触发此功能时。corr 仍然是第一次的值。我认为这很奇怪。有人可以解释一下吗？

我正在尝试在发布消息后如何关闭基于承诺的连接。

我试图推断出我的发送者和接收者的共享代码，所以我有一个这样的连接文件：

连接器.js

然后我的发布者/发件人看起来像这样：

发布者.js

但如前所述，我无法弄清楚如何在调用publish().

我正在使用amqplib在我的 node.js 服务器中传输消息。

这是我在队列上监听的代码：

现在，我想更新消费者来监听同一个队列

像这样：

我尝试 unbindQueue 或 deleteQueue 但不知道为什么Unhandled rejection IllegalOperationError: Channel closing会抛出错误

假设我喜欢我的 rabbitmq 队列上的 100000 个事件，那么限制系统串联处理它们而不是尝试一次消耗所有事件的最佳方法是什么？

我正在尝试几个选项，但是，机器冻结试图一次处理它们。