已经在群晖的 Docker 组件中，安装了 RabbitMQ（含 Delay 插件），安装方法见这里。
在 .NET Core 中，使用 RabbitMQ 的文章已经很多了，这里不再熬述。
本文主要是记录使用 EasyNetQ 建立 RabbitMQ 的延时队列的经历。
.NET Core 访问 RabbitMQ 的库很多（官方推荐的列表）
一般都使用 RabbitMQ .NET Client
在官方的推荐组件中，还有一个：EasyNetQ，看了下 Nuget 下载量和 Github 的情况，貌似很不错，就尝试用了。（EasyNetQ 官网）
注：还有一个组件，NServiceBus，也是很不错的，不过，该组件已经商业了，要收费，免费版有访问量限制，就放弃了。（NServiceBus 官网）
特别说明：EasyNetQ 的设计初衷，是共享业务实体类，如果不想共享业务实体类，可考虑在发送消息时，将业务实体序列化成字符串，再发送（不过，该方法也不是全部场景都可行，如果跨平台了，也会报错）。
额外说明：
- 要完美解决上述问题，应该是要继承
ITypeNameSerializer接口，实现相关方法，然后在创建 Bus 时，注册进去，应该可以解决，不过由于目前还没有细看，所以，暂时不能确定是否能解决。可以看看这些资料：资料一（中文）、资料二（中文）、资料三（英文）、资料四（英文）。 - 如果不想用自带的 Newtonsoft.Json，甚至，不想用 Json 作为消息传输的格式化方式，可自行继承
EasyNetQ.ISerializer接口，并实现里面的方法，然后在创建 Bus 时，注册进去即可，参考这里（英文）。
关于 RabbitMQ 的延时队列方案，总结起来，主要有三种，各方案的优劣，可自行百度。
总之，推荐：delayed_message_exchange 插件，该方案在大多数云服务商的消息队列产品中，均支持，兼容性好。
如果购买了阿里云的 RabbitMQ 版消息队列，除了上述三种方案，还提供了阿里云定制的方案，如下图所示：
阿里云的延时队列方案介绍，参考这里。
正式开始（平台：.NET Core 5.0）
EasyNetQ 的连接字符串，如下所示：
host=<IP 或域名>:<端口，默认“5672”>;virtualhost=<vHost名称，默认“/”>;username=<连接用户名>;password=<连接密码>
连接字符串各参数说明，参考这里。
- 建立两个 Console 项目：
- MsgProducer：消息生产者，用于发送消息到延时队列中
- MsgConsumer：消息消费者，用于消费延时队列中的消息
- MsgProducer 项目
主要逻辑：
- 创建延时 exchange
- 创建普通 exchange，并和延时 exchange 绑定
- 数据发送到延时 exchange 中
MsgProducer 主要代码如下（所有方法，可使用异步 Async）：
using EasyNetQ;
using EasyNetQ.Topology;
static void Main(string[] args)
{
// 通常建议单例该连接对象（比如在 StartUp.cs 中单例注入）
using var bus = RabbitHutch.CreateBus("<EasyNetQ 连接字符串>");
// 建立延时 exchange
var exDelay = bus.Advanced.ExchangeDeclare("<延时 exchange 名称>", cfg => cfg.AsDelayedExchange(ExchangeType.Direct));
// 建立普通 exchange
var exNormal = bus.Advanced.ExchangeDeclare("<普通 exchange 名称>", ExchangeType.Direct);
// 绑定两个 exchange，设置好 RoutingKey
bus.Advanced.Bind(exDelay, exNormal, "delay");
// 创建普通队列，并和普通 exchange 绑定，设置好 RoutingKey
var qNormal = bus.Advanced.QueueDeclare("<普通队列名称>");
bus.Advanced.Bind(exNormal, qNormal, "delay");
// 以下是测试发送消息的代码
string msg;
while ((msg = Console.ReadLine()) != "exit")
{
// 针对单个消息，设置延迟时间（毫秒）
var msgHeaders = new MessageProperties();
msgHeaders.Headers.Add("x-delay", new Random().Next(1000, 5000));
// 发送消息
bus.Advanced.Publish(exDelay, "delay", false, new Message<string>(msg, msgHeaders));
Console.WriteLine($"{DateTimeOffset.Now.ToUnixTimeMilliseconds()} 发送成功 {msg}");
}
}
在 EasyNetQ 的官方文档中，有关于 Delayed Message 插件的推荐使用说明，本人实在受不了 EasyNetQ 自动建立的 exchange 和 queue，就放弃了官方的方法，自己使用了 Advanced 模式。
关于 EasyNetQ 官方文档推荐的使用方式，参考这里（英文）。
- MsgConsumer 项目
主要逻辑
- 从普通队列中读取消息并处理
MsgConsumer 主要代码如下（所有方法，可使用异步 Async）：
using EasyNetQ;
static void Main(string[] args)
{
// 通常建议单例该连接对象（比如在 StartUp.cs 中单例注入）
using var bus = RabbitHutch.CreateBus(<EasyNetQ 连接字符串>);
// 创建普通队列，设置好 RoutingKey
// 和第二步 MsgProducer 项目中的普通队列名称一致！！！
var qNormal = bus.Advanced.QueueDeclare("<MsgProducer 的普通队列名称>");
bus.Advanced.Consume<string>(qNormal, MsgHandle); // MsgHandle 也可以用匿名方法
Console.WriteLine("等待中……（回车退出）");
Console.ReadLine();
}
static void MsgHandle(IMessage<string> msg, MessageReceivedInfo msgInfo)
{
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine($"{DateTimeOffset.Now.ToUnixTimeMilliseconds()} 收到消息：{msg.Body}");
Console.ResetColor();
}
至此，即可正常收发延时消息了。
