对于核心业务，第一种方法显然不可接受，第二种方法如果代码有异常导致消费一直失败就会出现不断失败重新入队列的死循环问题，较好的方案是3，待消费失败问题修复后将消息从死信队列取出发回原队列重新消费。

实现

• rabbit版本

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-amqp</artifactId>
  <version>2.6.3</version>
</dependency>

• 配置死信交换机，路由，队列
  
  
• 配置延迟消息业务队列消费失败投递到死信队列

@Bean("orderCloseQueue")
    public Queue orderCloseQueue() {
        return QueueBuilder.durable(OrderRabbitConstants.ORDER\_CLOSE\_QUEUE)
            .deadLetterExchange(RabbitMqConstants.DEAD\_LETTER\_EXCHANGE)
            .deadLetterRoutingKey(RabbitMqConstants.DEAD\_LETTER\_ROUTING\_KEY)
            .build();
    }

• 配置手动返回ACK

@Bean(name = {"manualContainerFactory"})
public SimpleRabbitListenerContainerFactory manualContainerFactory(@Qualifier("connectionFactory") ConnectionFactory connectionFactory) {
	SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
	this.manualFactoryConfigurer.configure(factory, connectionFactory);
	factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
	factory.setDefaultRequeueRejected(this.enableRequeueRejected);
	if (this.enableConsumers) {
		factory.setConcurrentConsumers(this.concurrentConsumers);
		factory.setMaxConcurrentConsumers(this.maxConcurrentConsumers);
		factory.setPrefetchCount(this.prefetchCount);
	}
	return factory;
}

• 业务队列消息消费模拟失败

@RabbitListener(queues = OrderRabbitConstants.ORDER\_CLOSE\_QUEUE, containerFactory = "manualContainerFactory")
    public void consumerCloseOrder(Message message, Channel channel) throws IOException {
        String orderCode = new String(message.getBody(), CharsetUtil.UTF\_8);
        String messageId = message.getMessageProperties().getMessageId();
        log.info("收到MQ messageId[{}],订单号[{}]", messageId, orderCode);
        if (true) {
            channel.basicReject(message.getMessageProperties().getDeliveryTag(), false);
            return;
        }
    }

• 效果
  
  

自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数大数据工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年大数据全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友。

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上大数据开发知识点，真正体系化！

由于文件比较大，这里只是将部分目录大纲截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且后续会持续更新

如果你觉得这些内容对你有帮助，可以添加VX：vip204888 （备注大数据获取）

一个人可以走的很快，但一群人才能走的更远。不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人，都欢迎扫码加入我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习成长！

可以走的很快，但一群人才能走的更远。不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人，都欢迎扫码加入我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习成长！**