《rabbitmq》专题

我为RabbitMQ制作了一个消费者，作为一个用C#.NET编写的控制台应用程序。它被编程为永久监听队列，每当它在队列中发现消息时，它就处理它。使用者平均每秒处理35条消息。使用者被安排在系统启动时在任务计划程序中运行。消费者运行良好的3-4天。但是，它们继续运行，但不处理任何消息，尽管队列中有消息。当使用者停止并再次启动时，它再次开始正确处理消息。但是，当您手动重新启动时，数以百万计的消息排在队

使用RabbitMQ，有没有一种方法可以将消息从队列“推送”给使用者，而不是让使用者从队列“轮询并拉出”消息？ 这也是我目前正在进行的一个项目引起一些争论的原因。一个方面的论点是，让使用者（即windows服务）“轮询”队列直到新消息到达，与将消息从队列自动“推送”到订户/使用者的想法相比，这种想法有些低效，也不太理想。 我似乎只能找到支持消费者从队列中“轮询并拉出”消息的信息（例如，使用wind

我将不折不扣地学习以下教程：https://www.rabbitmq.com/tutorials/tutorial-two-java.html。 我以这样的方式启动RabbitMQ服务器： 我生成了两个消费者，当我Ctrl+C其中一个时，另一个正在运行的消费者不会接收到最初发往前一个消费者的消息。如何在Ctrl+C'ing从一个消费者中重新传递消息？ 编辑：我现在正在通过'brew'安装Rabbi

我想处理使用者从队列中获得的不成功消息，并将它们重新排队。 想象一下我有这样的情况： 我想请求它,但要将它发送回队列的开头： 我用我的应用程序上的几行代码解决了问题，但我想知道是否存在更好的解决方案，也许直接使用RabbitMQ的某些功能。

我想创建一个可以从不同线程调用的RabbitMQ发布服务器。 基于RabbitMQ最佳实践，我不应该允许在不同线程中使用同一通道，因此在发布服务器的多个实例中共享此通道将会导致问题。 我能想到的唯一解决方案是拥有一个具有内部队列的管理器线程，该队列实现一个内部生产者-消费者，而单个消费者仅存在于该线程中。 有没有更简单的方法？由于显而易见的原因，希望尽可能避免同步，但此解决方案不允许这样做。

一种方法是声明队列并将消息发布到该队列，并让所有使用者从该队列中消费。这将在不同的消费者之间分发消息。 我不清楚，如果上面的操作是正确的，或者最佳实践是将消息传递到Exchange而不是直接发布到队列。使用Exchange时，我必须确保在生产者创建Exchange之后声明队列，然后才开始发布消息。否则，没有队列接收到消息，并且消息将丢失。

null 结果：队列已从RabbitMQ GUI中删除，但当我试图通过已删除的RabbitMQ队列发送消息时，连接仍然有效。(con.isConnected()==true)我需要找到一种方法来侦听队列，如果它被删除，我不应该向已删除的队列发送任何消息。 注意：删除队列后，我不会重新启动RabbitMQ。 渠道创建： 正在发送消息：

我希望对RabbitMQ中的队列有这样的约束： 编辑（澄清）：将有许多消费者都试图从所有队列中获取工作，由于他们无法从一个队列中获取工作，该队列中处理的事件未被加密，所以有序处理将被维护。

我希望通过RabbitMQ获得以下模式以“顺序”接收消息。我使用Node.js框架作为消费者。 假设队列中有3条消息,我需要这样的模式： 我的队列是持久的，需要ACK。我是不是缺了什么？ 请救命！

在使用ACK时，有没有一种简单的方法实现类似于“锁定”的东西来防止RabbitMQ队列中的竞争条件？ 我有以下问题--我有几个客户机使用ACK使用队列。每当客户端收到消息时，他就会确认并处理消息。但是，如果由于某种原因处理失败，我希望消息返回到队列。

null

假设我希望实现与在spring-amqp函数周围使用时基本相同的功能： 在Rabbit绑定器中使用Spring Cloud Stream时，是否必须手动将消息访问到RabbitMQ？ 如果是，如何实现？

使用spring cloud stream和RabbitMQ的配置： Exchange改为和队列改为。怎么修？