使用SendBatchAsync方法向服务总线发送1000条代理消息

Question

我有一个应用程序，从SQL数据库中获取数据并将其作为代理消息发送到服务总线。以下是步骤：

1. 以1000条为一批从数据库中获取数据
2. 将每行数据转换为代理消息，并添加到列表中。
3. 使用 SendBatchAsync 方法将包含1000个代理消息的列表发送到服务总线。

在第3步中，我遇到了问题。以下是该代码：

public async Task SendMessagesAsync(List<BrokeredMessage> brokeredMessageList)
        {
            try
            {
                var topicClient = CreateTopicClient();
                await topicClient.SendBatchAsync(brokeredMessageList);
            }
            catch(Exception ex)
            {
                throw ex;
            }
        }

当编译器到达SendBatchAsync方法时，会出现错误提示：与Service Bus通讯期间发生错误。请检查连接信息，然后重试。内部异常为：

Internal Server Error: The server did not provide a meaningful reply; this might be caused by a premature session shutdown. TrackingId:some guid here

然而，如果我尝试发送100条消息，它可以正常工作。有什么办法让它一次发送1000条消息？

注意：每条消息的大小为1445字节。

- nitinvertigo

Answer 1

很抱歉，因为您的总有效载荷大小约为1.4 MB（1445字节*1000），而批处理允许的最大大小为256 KB，所以您无法这样做。

参考：https://msdn.microsoft.com/en-us/library/microsoft.servicebus.messaging.topicclient.sendbatch.aspx（备注部分）

引用： 批处理的最大大小与单个消息的最大大小相同（目前为256 Kb）。

我猜您需要将批处理进一步拆分成更小的批次，以便不超过256K限制。

- Gaurav Mantri

---

是的，看起来是这样...感谢澄清。 - nitinvertigo

Answer 2

您可以在Azure Service Bus中使用高级命名空间。这允许消息达到1MB。尽管头仍然限制为64K。

提示：在使用高级命名空间之前，请检查定价。

更多信息->

https://blogs.msdn.microsoft.com/servicebus/2016/07/07/things-to-know-about-premium-messaging/

- lostintranslation