1

我有一个代理使用 saga 来跟踪给定类型的传入消息，直到收到超时消息。在超时处理程序中，我有以下内容：

public override void Timeout(object state)
        {
            // If Data.IsNull: Do nothing!!! Report to log only.
            Logger.Debug("=========================================================================");
            Logger.Debug(string.Format("Timeout message received. State: {0}.", state.ToString()));

            QuickBatch qbBuilder = new QuickBatch();
            // Create new message and publish it
            BankRequestBatchClosed eventMessage = Bus.CreateInstance<BankRequestBatchClosed>();

            eventMessage.UniqueBatchIdentifier = qbBuilder.GenerateUniqueBatchIdentifier(QuickBatch.QB_BATCHTYPE_CC);
            eventMessage.ScheduleBatchID = this.Data.ScheduleBatchID;
            eventMessage.EventDate = DateTime.Now;
            eventMessage.EventID = Guid.NewGuid();
            eventMessage.TransactionItems = this.Data.PaymentRequestedTransactionItems;

            Logger.Debug("=========================================================================");
            Logger.Debug(string.Format("Timeout method about to send BankRequestBatchClosed message. UniqueBatchIdentifier: {0}",eventMessage.UniqueBatchIdentifier));

            Bus.Publish(eventMessage);
            Complete();
        }

TransactionItems 是一个 ICollection

这是 TransactionDetail 类：

   [Serializable]
    public class TransactionDetail
    {
        // Guid needed for NHibernate to store it in database. All
        // member variables are virtual for the same reason.
        public virtual Guid Id { get; set; }
        public virtual Int32 ScheduleBatchID { get; set; }
        public virtual Int32 PseudoSagaID { get; set; }
        public virtual String CreditCardNumber { get; set; }
        public virtual String ExpiryDate { get; set; }

        public virtual String AccountNumber { get; set; }
        public virtual String BSB { get; set; }

        public virtual Decimal Amount { get; set; }
        public virtual Int32 Firm_fk { get; set; }
        public virtual String FirmName { get; set; }
        public virtual TransactionType PaymentType { get; set; }
        // transaction number, max 15 chars, to use one of the following:
        public virtual int ApplicationPaymentInfo_fk { get; set; }
        public virtual BankRequestResponseSagaBase Parent { get; set; }
    }

如果我没有任何订阅，则 Bus.Publish() 调用会正常进行。如果我订阅了其他服务，我会收到以下错误消息：

mscorlib.dll 中出现“System.StackOverflowException”类型的未处理异常

除此以外没有关于溢出的更多信息：{Cannot evaluate expression because the current thread is in a stack overflow state.}

我有自己的 SagaPersister、Profile 和 SagaRegistry，但不确定它们是否与此问题相关，但如果需要可以提供。

4

2 回答 2

2

堆栈溢出通常是由可重入代码（可能是间接调用自身的方法）引起的。每次调用一个方法时，它都会占用更多的堆栈空间，因此如果它调用自身，它会创建一个无限循环，用完所有堆栈）。

.net 中可能存在错误，但更有可能是您的 TimeOut 事件处理程序正在调用导致另一个调用 Timeout 的东西，而它仍在处理第一个调用，这会导致另一个调用，依此类推，导致无限环形。您是否在输出日志中收到大量“收到超时”文本？

避免这种情况的方法是：

  • 不要进行导致重入的调用
  • 在事件处理程序执行任何工作之前删除事件订阅（并可能在从处理程序退出时重新订阅它）
  • 使用 bool 变量或其他互锁来检测重入调用
于 2012-01-09T07:04:43.267 回答
2

这里看起来有点可疑的一件事是 TransactionDetail 对象上的 BankRequestResponseSagaBase Parent 属性。可能是您的引用中有一个循环导致您的 saga 持久性爆炸。

于 2012-01-09T12:56:38.143 回答