我有一个应用程序,从SQL数据库中获取数据并将其作为代理消息发送到服务总线。以下是步骤:
当编译器到达SendBatchAsync方法时,会出现错误提示:与Service Bus通讯期间发生错误。请检查连接信息,然后重试。内部异常为:
然而,如果我尝试发送100条消息,它可以正常工作。有什么办法让它一次发送1000条消息?
注意:每条消息的大小为1445字节。
- 以1000条为一批从数据库中获取数据
- 将每行数据转换为代理消息,并添加到列表中。
- 使用 SendBatchAsync 方法将包含1000个代理消息的列表发送到服务总线。
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字节。