RabbitMQ 重试机制

it2025-01-21  11

spring.rabbitmq.listener.simple.acknowledge-mode=auto spring.rabbitmq.listener.simple.default-requeue-rejected=true spring.rabbitmq.listener.simple.concurrency=1 spring.rabbitmq.listener.simple.max-concurrency=5 spring.rabbitmq.listener.simple.prefetch=5 spring.rabbitmq.listener.simple.retry.enabled=true ##重试间隔时间 单位毫秒 spring.rabbitmq.listener.simple.retry.initial-interval=300000 ##重试间隔时间乘积 spring.rabbitmq.listener.simple.retry.multiplier=2 ##最大间隔时间 单位毫秒 spring.rabbitmq.listener.simple.retry.max-interval=3600000 ##一共会执行的次数 spring.rabbitmq.listener.simple.retry.maxAttempts=3

最大间隔时间默认值是 10000毫秒

/** * Maximum duration between attempts. */ private Duration maxInterval = Duration.ofMillis(10000);

如果你的间隔时间大于了10秒 一定要设置最大间隔时间

##默认值是3 代表一共执行的次数 spring.rabbitmq.listener.simple.retry.maxAttempts=4

 

 

 

 

最新回复(0)