如何在调度时间前接收Azure Service Bus Topic的已调度消息？

我有一个API会调用Azure Topic来调度消息，是否有办法在调度时间之前接收该消息？例如在以下代码中，我将消息调度到Azure Topic，设置了60分钟的延迟，能否在1小时前接收这条消息？

string queueName = "topic";
var client = new ServiceBusClient("", new ServiceBusClientOptions()
{
    TransportType = ServiceBusTransportType.AmqpWebSockets
});

// 创建发送者
ServiceBusSender sender = client.CreateSender(queueName);

// 创建要发送的消息，传入字符串时默认使用UTF-8编码
ServiceBusMessage message = new ServiceBusMessage($"Hello world cancel 13 {DateTime.Now}");

// 设置60分钟延迟
long seq = await sender.ScheduleMessageAsync(message, DateTimeOffset.Now.AddMinutes(60));

解答 #

默认情况下，通过ScheduleMessageAsync调度的延迟消息，在到达设定的调度时间前是无法被消费者接收的——这条消息会被Azure Service Bus暂存，直到调度时间到期才会进入Topic的活跃队列，供订阅者拉取消费。

如果有提前获取或使用这条消息的需求，可以通过以下两种方式实现：

• 取消调度并重发：若需要让消费者立即接收消息，可以先调用CancelScheduledMessageAsync方法，传入调度时返回的序列号seq取消延迟消息，再重新发送一条无延迟的消息。示例代码：

// 取消已调度的延迟消息
await sender.CancelScheduledMessageAsync(seq);
// 发送无延迟的即时消息
ServiceBusMessage immediateMessage = new ServiceBusMessage($"Hello world cancel 13 {DateTime.Now}");
await sender.SendMessageAsync(immediateMessage);

• 存储消息副本：在调度延迟消息的同时，将消息内容同步存储到外部介质（如Azure Blob Storage、SQL数据库）。如果仅需要查看消息内容，直接从外部存储读取即可，这种方式不会影响原调度消息的执行流程。

注意：取消调度操作仅对未到达调度时间的消息有效，一旦消息进入活跃队列，取消操作将失效。

内容的提问来源于stack exchange，提问作者ramdev