3

当追赶订阅重新连接时，事件存储似乎不一致。根据 google 组中的线程和实验，如果 SubscriptionDropReason 为 ，则似乎追赶订阅将自动重新连接ConnectionClosed。

但是，如果您随后尝试停止这些连接并指定超时，那么它们似乎永远不会真正停止并且总是超时。

我使用了这篇文章中的代码，但我认为这具有误导性，因为在我的实验中，在这种情况下收到多个事件的原因是，当事件存储重新联机时，事件存储会自动重新订阅 CatchupSubscriptions，只要你不重新订阅当原因是 ConnectionClosed 时，您将不会多次收到事件。如果我修改此代码以将超时添加到.Stop(timeout)方法中，那么它只会挂起并抛出。

当我在自动重新连接后收到对实时处理启动事件的调用时，该EventStoreCatchUpSubscription对象具有内部状态，这表明_isDropped=1，这对我来说也很奇怪，因为它没有被丢弃，它实际上正在处理事件。

所以我的问题是我应该如何处理 eventstore 自动重新连接并且我想断开连接并等待超时的情况？

4

1 回答 1

3

“subscriptionDropped”事件是处理连接问题的好地方。事件商店项目中仍有一个未解决的问题。

https://github.com/EventStore/EventStore/issues/929

https://github.com/EventStore/EventStore/issues/1127

eventStoreConnection.SubscribeToAllFrom(lastCheckpoint, catchUpSubscriptionSettings,
                eventAppeared(projection),
                liveProcessingStarted(projection),subscriptionDropped(projection),userCredentials );   



 private Action<EventStoreCatchUpSubscription, SubscriptionDropReason, Exception> subscriptionDropped(Projection projection)
            => async (eventStoreCatchUpSubscription, subscriptionDropReason, exception) =>
            {

                eventStoreCatchUpSubscription.Stop();

                switch (subscriptionDropReason)
                {
                    case SubscriptionDropReason.UserInitiated:
                        Console.WriteLine($"{projection} projection stopped by user.");
                        break;
                    case SubscriptionDropReason.SubscribingError:
                    case SubscriptionDropReason.ServerError:
                    case SubscriptionDropReason.ConnectionClosed:
                    case SubscriptionDropReason.CatchUpError:
                    case SubscriptionDropReason.ProcessingQueueOverflow:
                    case SubscriptionDropReason.EventHandlerException:
                        Console.WriteLine($"{projection} projection stopped because of a transient error ({subscriptionDropReason}). ");
                        Console.WriteLine($"Exception Detail:  {exception}");    
                        Console.WriteLine("Attempting to restart...");
                        // Re-build your subscription in here
                        Task.Run(() => StartProjection(projection));
                        break;
                    default:
                        Console.WriteLine("Your subscription gg");
                        Console.WriteLine($"Exception Detail:  {exception}");    
                        break;
                }
            };
于 2018-11-12T10:02:05.017 回答