RabbitMQ上的Nack和reject
我想处理使用者从队列中获得的不成功消息，并将它们重新排队。
想象一下我有这样的情况：
P => | foo | bar | baz | => C
我想请求它,但要将它发送回队列的开头：
P => | baz | foo | bar | => C
我用我的应用程序上的几行代码解决了问题，但我想知道是否存在更好的解决方案，也许直接使用RabbitMQ的某些功能。
共有1个答案
您可以查看一下死信队列（DLQ）：https://www.rabbitmq.com/dlx.html
-
我从RabbitMq服务器收到此错误 服务器关闭通道:406(前提条件-失败)，并显示消息“前提条件_失败-未知交付标签80” 发生这种情况是因为在消费者任务期间连接丢失，最后，当消息被确认/nack时，我收到此错误，因为我无法在与我接收它的通道不同的通道上确认消息。 这是 RabbitMq 连接的代码 如您所见，连接建立后会创建一个通道，在我收到连接问题后，通道设置为NULL，1秒钟后连接重试，
-
我有一个将数据推送到kafka的endpoint。现在，我想分别在kafka写入成功或失败的情况下使用近似的状态代码2xx或5xx响应调用。代码片段是 现在的问题是，在执行ack或nack回调之前，endpoint正在使用状态代码进行响应。还尝试了的方法，但该方法返回void。因此，无法知道该消息是已确认还是未确认。
-
RabbitMQ使用AMQP协议（而是实现AMQP协议） Java客户端需要使用AMQP协议客户端库来连接/使用RabbitMQ JMS API在这里的作用是什么？JMS API应使用AMQP客户端库连接到RabbitMQ？ 通常我们使用JMS来连接RabbitMQ、ActiveMQ等消息代理。那么这里使用的默认协议是什么，而不是AMQP？ 上面的一些可能是哑巴。：-）但我想把头缠在上面。
-
最后，尝试编辑，如下所示：Web调度插件rabbitmq。
-
rabbitMQ教程部分中的hello world示例只要求使用不同机器的ip更改主机名。但这对我不起作用。我已尝试将外部IP地址绑定到Rabbit MQ服务器 但这不起作用。我还需要对配置文件或代码执行其他操作吗？ 这是发送代码 还有我在另一台机器上运行的接收代码 我得到的错误是 我感谢你们花时间帮助我。
-
RabbitMQ 说明 MQ 全称为 Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。 RabbitMQ 是一个在 AMQP 基础上完整的，可复用的企业消息系统。他遵循 Mozilla Public License 开源协议。 RabbitMQ WIKI：https://zh.w