Azure EventHub-EventHubClient.send（）结果为NullReferenceException

Question

这在99%的情况下都有效，但有时会导致NullReferenceException，留下以下StackTrace：

System.NullReferenceException: Object reference not set to an instance of an object.
    at Microsoft.ServiceBus.Messaging.MessageSender.RetrySenderEventDataAsyncResu
    lt.<>c.<.ctor>b__5_0(EventData e)
      at System.Linq.Enumerable.Any[TSource](IEnumerable`1 source, Func`2 predicate
    )
      at Microsoft.ServiceBus.Messaging.MessageSender.RetrySenderEventDataAsyncResu
    lt..ctor(MessageSender sender, TrackingContext trackingContext, IEnumerable`1 me
    ssages, TimeSpan timeout, AsyncCallback callback, Object state)
      at Microsoft.ServiceBus.Messaging.MessageSender.BeginSendEventData(TrackingCo
    ntext trackingContext, IEnumerable`1 eventDatas, TimeSpan timeout, AsyncCallback
    callback, Object state)
      at Microsoft.ServiceBus.Messaging.EventHubClient.SendBatch(IEnumerable`1 even
    tDataList)

我尝试实现一个重试策略，使用eventhubclient.retryPolicy=retryPolicy.default；和使用thread.sleep(n)手动执行递归方法调用，以便给出重新建立连接的时间。

有时连接在10秒后恢复，有时在60秒后恢复，通常永远不会恢复（或者直到我对方法的递归调用击中StackOverflowException，大约30分钟后，但取决于线程进入Hibernate状态的时间）。从逻辑上讲，我不能拥有我系统中这个不稳定的部分。

有人知道为什么会出现这个异常吗？如果是由于连接中断？

Answer 1

这里的答案原来是一个超载的EventHub。

对于每第100批，等待0.5秒。对于每个NullReferenceException，请等待2秒，然后再用相同的数据重试。在恢复连接之前，可能需要重试100次以上。我尝试了指数级的等待时间，但在我的情况下并不成功（最终等待了几个小时，仍然没有连接）。

当然，在C#中使用永恒的while循环而不是递归调用。这将防止StackOverflowException。（菜鸟错误）。

public bool SendMessageAsList(List<EventData list) 
{
while(true)
{
    var batchList = new List<EventData>();
    for (var i = 0; i < list.Count; i + 100)
    try
    {
        if (i % 10000)
            Thread.Sleep(500);
        batchList = list.Skip(i).Take(100).ToList();
        EventHubClient.SendBatch(batchList);
        // Gets here at success
        list = list.Skip(100).ToList();
        if (batchList.Count < 100)
            break;
    }
    catch (NullReferanceException e)
    {
        Console.WriteLine(e);
        Thread.Sleep(2000)
}
}