enoent解决办法rabbitmq（rabbitmq channel queue）

编程日记 • 2025-03-22 18:57 • 阅读 7

整合时，消费端在处理失败时，如果需要进行重试，可以有如下几种重试机制：

当消费端在处理消息时抛出异常，那么默认会在当前线程的3次的Retry。该方法是默认的，可以通过修改配置文件，指定channel下的参数，例如：

其中：

当消息重试超过最大次数，如果未配置启用，消息将会被丢弃。该方法默认是无法设置重试的时间间隔的。

方法1是在当前线程进行重试，相当于阻塞了后面的消息，有时我们不想阻塞，则可以利用死信队列（Dead Letter Queue，缩写），进行异步重试。

先看一下的逻辑。

设置参数为true，将自动创建对应channel的，绑定死信交换机（Dead Letter Exchange，缩写）。默认该的名字就是其对应. 后追加，同时，该进入该的消息的即为原。

rabbitmq重启后会清除queues吗_python

按上面的配置，消息进入以后，因为没有任何的消费者，消息会一直存储于中，可以添加参数设置消息在中生存的时间，在无消费者的情况下，默认到期后会删除该消息。

如果想指定的名称，可以用参数指定。

重试的逻辑其实就是利用，给其设置一个默认的，在时间到期后，消息会再度转到指定的对应的中。

为了实现该逻辑，需要配置三个参数：

例如：

注意：
因为在配置中，设置了这个参数，当该参数使用时，默认rabbit的参数是启用的，即该channel的和是持久化的，应用退出后，不会自动清除，并且保存创建时的参数。所以当改变了channel的参数后，需要将queue删除，让其自动重建，否则新改的不会生效，则无法实现自动重试。

按照上面配置，删除旧后重新启动应用，创建信息如下：

rabbitmq重启后会清除queues吗_spring_02

消息重新投递后，在其里，会增加一些重试的信息，如下图所示：

rabbitmq重启后会清除queues吗_spring_03

但有时，我们想知道上一次错误的具体异常，此时可以增加参数，当设置为true时，会在消息头里增加详细的异常和异常堆栈信息。

rabbitmq重启后会清除queues吗_spring_04

注：
当设置为不同值时，的取值逻辑不同。当为false时，取的是头中第一个的值；当为true时，取得是这个Header的值。

此时，该消息将不断重复queue -> DLQ -> queue的循环（假设消费端一直拒绝或抛异常）。如果我们想设置重试次数大于3就不再重试，可以抛出这个异常，则该消息被丢弃，不再进入。

前面对于消息的拒绝，都是采用抛异常，但是这个异常不能乱抛。不同的异常，框架处理的方式不同：

有时候，我们不期望在生产的日志中出现重试的ERROR，可以考虑用下面的方案：