如何将.NET Core与RabbitMQ结合实现限制循环消费的长尾？

本文共计3069个文字，预计阅读时间需要13分钟。

目录+前言+循环场景+解决方案+一次消费+消息不重复入队+限定重试次数+消息头设置次数+存储重试次数+列表使用Quorum类型+列表消息过期+参考资料+前言+消费端接收消息处理业务时

目录

• 前言
• 循环场景
• 解决方案
• 一次消费
• 消息不重入队列
• 限定重试次数
• 消息头设定次数
• 存储重试次数
• 队列使用Quorum类型
• 队列消息过期
• 参考资料

前言

当消费者端接收消息处理业务时，如果出现异常或是拒收消息将消息又变更为等待投递再次推送给消费者，这样一来，则形成循环的条件。

循环场景

生产者发送100条消息到RabbitMQ中，消费者设定读取到第50条消息时，设置拒收，同时设定是否还留存在当前队列中(当requeue为false时，设置了死信队列则进入死信队列，否则移除消息)。