c# - SignalR 上的自定义横向扩展总线导致异常

Question

我为 SignalR 构建了一个自定义 ScaleoutMessageBus 子类，以通过我的 RabbitMQ 总线传递消息。但是，我从 SignalR 收到以下异常:

System.ArgumentOutOfRangeException: Index was out of range. Must be non-negative and less than the size of the collection.
Parameter name: index
   at System.SZArrayHelper.get_Item[T](Int32 index)
   at Microsoft.AspNet.SignalR.Messaging.ScaleoutMessageBus.OnReceivedCore(Int32 streamIndex, UInt64 id, ScaleoutMessage scaleoutMessage)
   at Microsoft.AspNet.SignalR.Messaging.ScaleoutStreamManager.OnReceived(Int32 streamIndex, UInt64 id, ScaleoutMessage message)
   at System.Threading.Tasks.Task.Execute()

什么会导致此异常发生？

Answer 1

事实证明，我需要覆盖 StreamCount 以提供我正在使用的额外流编号。