为什么我需要任何 Saga 存储？答案

【问题标题】：Why do I need any Saga storage?为什么我需要任何 Saga 存储？
【发布时间】：2017-04-28 12:47:34
【问题描述】：

我正在努力处理启动期间从 NServiceBus.Host 收到的错误消息，但不确定我哪里出错了。我最初在一个大型项目中遇到了这个问题，但我似乎能够从头开始重现这个问题。

在 VS2012 中，从一个新的 C# 类库项目开始，为 .NET 4.6.2 设置。然后添加 NuGet 包 - NServiceBus (6.0.0)、NServiceBus.Host (7.0.1) 和 NServiceBus.NHibernate (7.2.0)。

然后编辑EndpointConfiguration类如下：

using NServiceBus.Features;
using NServiceBus.Persistence;

namespace NSB6_Pure
{
  using NServiceBus;

  public class EndpointConfig : IConfigureThisEndpoint
  {
    public void Customize(EndpointConfiguration endpointConfiguration)
    {
      //TODO: NServiceBus provides multiple durable storage options, including SQL Server, RavenDB, and Azure Storage Persistence.
      // Refer to the documentation for more details on specific options.
      endpointConfiguration.UsePersistence<NHibernatePersistence, StorageType.Timeouts>();
      endpointConfiguration.DisableFeature<MessageDrivenSubscriptions>();
      endpointConfiguration.DisableFeature<Sagas>();
      // NServiceBus will move messages that fail repeatedly to a separate "error" queue. We recommend
      // that you start with a shared error queue for all your endpoints for easy integration with ServiceControl.
      endpointConfiguration.SendFailedMessagesTo("error");

      // NServiceBus will store a copy of each successfully process message in a separate "audit" queue. We recommend
      // that you start with a shared audit queue for all your endpoints for easy integration with ServiceControl.
      endpointConfiguration.AuditProcessedMessagesTo("audit");
    }
  }
}

然后编译（在本例中为调试版本），并从命令提示符尝试运行 bin\Debug 目录中的 NServiceBus.Host.exe。就我而言，我得到了这个输出，其中大部分是红色的：

2017-04-28 12:46:11.876 INFO  DefaultFactory Logging to 'C:\blah\bin\Debug\' with level Info
2017-04-28 12:46:13.446 FATAL NServiceBus.LicenseManager Your license has expire
d! You can renew it at https://particular.net/licensing.
2017-04-28 12:46:13.561 ERROR NServiceBus.GenericHost Exception when starting en
dpoint.
System.InvalidOperationException: In order to use NServiceBus with NHibernate yo
u need to provide at least one connection string. You can do it via (in order of
 precedence):
 * specifying 'NServiceBus/Persistence/NHibernate/Saga' connection string for th
e Saga persister
 * specifying 'NServiceBus/Persistence' connection string that applies to all pe
rsisters
 * specifying 'NServiceBus/Persistence/connection.connection_string' or 'NServic
eBus/Persistence/connection.connection_string_name' value in AppSettings or your
 NHibernate configuration file.
For most scenarios the 'NServiceBus/Persistence' connection string is the best o
ption.
   at NServiceBus.Persistence.NHibernate.NHibernateConfigurationBuilder.Validate
ConfigurationViaConfigFile(Configuration configuration, String configPrefix) in
C:\BuildAgent\work\5135de308b2f3016\src\NServiceBus.NHibernate\Internal\NHiberna
teConfigurationBuilder.cs:line 130
   at NServiceBus.Features.NHibernateStorageSession.Setup(FeatureConfigurationCo
ntext context) in C:\BuildAgent\work\5135de308b2f3016\src\NServiceBus.NHibernate
\SynchronizedStorage\NHibernateStorageSession.cs:line 45
   at NServiceBus.Features.FeatureActivator.ActivateFeature(FeatureInfo featureI
nfo, List`1 featuresToActivate, IConfigureComponents container, PipelineSettings
 pipelineSettings) in C:\Build\src\NServiceBus.Core\Features\FeatureActivator.cs
:line 194
   at NServiceBus.Features.FeatureActivator.SetupFeatures(IConfigureComponents c
ontainer, PipelineSettings pipelineSettings) in C:\Build\src\NServiceBus.Core\Fe
atures\FeatureActivator.cs:line 57
   at NServiceBus.InitializableEndpoint.<Initialize>d__1.MoveNext() in C:\Build\
src\NServiceBus.Core\InitializableEndpoint.cs:line 50
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNot
ification(Task task)
   at NServiceBus.GenericHost.<Start>d__1.MoveNext() in C:\BuildAgent\work\fc89e
968acb99302\src\NServiceBus.Hosting.Windows\GenericHost.cs:line 48
2017-04-28 12:46:13.582 ERROR NServiceBus.Hosting.Windows.WindowsHost Start fail
ure
System.InvalidOperationException: In order to use NServiceBus with NHibernate yo
u need to provide at least one connection string. You can do it via (in order of
 precedence):
 * specifying 'NServiceBus/Persistence/NHibernate/Saga' connection string for th
e Saga persister
 * specifying 'NServiceBus/Persistence' connection string that applies to all pe
rsisters
 * specifying 'NServiceBus/Persistence/connection.connection_string' or 'NServic
eBus/Persistence/connection.connection_string_name' value in AppSettings or your
 NHibernate configuration file.
For most scenarios the 'NServiceBus/Persistence' connection string is the best o
ption.
   at NServiceBus.Persistence.NHibernate.NHibernateConfigurationBuilder.Validate
ConfigurationViaConfigFile(Configuration configuration, String configPrefix) in
C:\BuildAgent\work\5135de308b2f3016\src\NServiceBus.NHibernate\Internal\NHiberna
teConfigurationBuilder.cs:line 130
   at NServiceBus.Features.NHibernateStorageSession.Setup(FeatureConfigurationCo
ntext context) in C:\BuildAgent\work\5135de308b2f3016\src\NServiceBus.NHibernate
\SynchronizedStorage\NHibernateStorageSession.cs:line 45
   at NServiceBus.Features.FeatureActivator.ActivateFeature(FeatureInfo featureI
nfo, List`1 featuresToActivate, IConfigureComponents container, PipelineSettings
 pipelineSettings) in C:\Build\src\NServiceBus.Core\Features\FeatureActivator.cs
:line 194
   at NServiceBus.Features.FeatureActivator.SetupFeatures(IConfigureComponents c
ontainer, PipelineSettings pipelineSettings) in C:\Build\src\NServiceBus.Core\Fe
atures\FeatureActivator.cs:line 57
   at NServiceBus.InitializableEndpoint.<Initialize>d__1.MoveNext() in C:\Build\
src\NServiceBus.Core\InitializableEndpoint.cs:line 50
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNot
ification(Task task)
   at NServiceBus.GenericHost.<Start>d__1.MoveNext() in C:\BuildAgent\work\fc89e
968acb99302\src\NServiceBus.Hosting.Windows\GenericHost.cs:line 54
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNot
ification(Task task)
   at NServiceBus.Hosting.Windows.WindowsHost.Start() in C:\BuildAgent\work\fc89
e968acb99302\src\NServiceBus.Hosting.Windows\WindowsHost.cs:line 33

我关注的一点是：

为了将 NServiceBus 与 NHibernate 一起使用，您需要提供至少一个连接字符串。您可以通过（按优先顺序）：

为 Saga 持久化程序指定“NServiceBus/Persistence/NHibernate/Saga”连接字符串

我检查了 NServiceBus 代码 - 这不是通用消息。如果问题是 Timeouts¹ 缺少配置，我相信它会谈论它而不是 Saga，因为错误消息的那部分是参数化的。

但我不想在这个特定项目中使用 Sagas。我原以为DisableFeature<Sagas> 足以向 NServiceBus 表明我不想在这里使用 sagas，但显然不是。

那么为什么 NServiceBus 试图配置 Saga 存储，更重要的是，我该如何阻止它这样做呢？

¹当然，我预计会发生这样的错误，因为我还没有做任何事情，例如向类库添加app.config。因此，即使 Saga 问题得到解决，我预计此代码仍会产生错误。只是希望我能自己解决问题。

（我想要避免配置任何存储背后的基本原理是，真正要做的工作是升级一些现有端点，这些端点为每个功能（超时/订阅/传奇）提供专用数据库，尽管我一直建议使用虽然我们应该合并这些数据库，因此可以为每个端点配置一个 NServiceBus/Persistence 数据库，但尚未获得批准。但我不愿意为其中一些端点添加 另一个 数据库他们目前只使用超时）

【问题讨论】：

但是不超时存储还是需要连接字符串吗？
@Evk - 即使添加了超时存储配置，示例仍然抱怨缺少 Saga 存储。因为它无论如何都会抱怨，所以我决定不让这个例子复杂化，因为它还需要一个特定的配置文件。
尝试做endpointConfiguration.DisableFeature<NHibernateStorageSession>();，这应该可以帮助您解决此错误，但我不确定它是否适合您的情况（您可以在禁用此功能的情况下做您想做的事）。
即使您无法禁用该功能（NHibernateStorageSessio‌n），您至少应该知道此功能是导致此问题的原因，并且在此功能的设置中，它确实是硬编码以查找 Saga连接字符串，不检查 Sagas 功能是否禁用。
@Evk - 现在重新开始工作，我可以确认禁用存储会话使我能够取得进一步的进展，并且仍然支持我需要超时的场景（例如延迟交付）。想写出来吗？

标签： c# visual-studio-2012 nhibernate nservicebus

【解决方案1】：

我是 NServiceBus 制造商 Particular Software 的开发人员 Dennis van der Stelt。我已经回复了您的支持案例，但也想更新此问题，以便其他人也可以找到此问题。 Evk 已经提到了大部分，我只想提一下 GH 问题和完整代码。

以下代码配置确保它不会抱怨 saga 连接字符串。

    endpointConfiguration.DisableFeature<NHibernateStorageSession>();
    endpointConfiguration.DisableFeature<MessageDrivenSubscriptions>();
    endpointConfiguration.DisableFeature<Sagas>();
    endpointConfiguration.UsePersistence<NHibernatePersistence, StorageType.Timeouts>();

然后只为超时提供一个连接字符串

<add name="NServiceBus/Persistence/NHibernate/Timeout" connectionString="server=.\sqlexpress;database=nservicebus; Trusted_Connection=True;" />

这将使它按预期正常工作。

之所以需要禁用 NHibernateStorageSession 是因为它是持久化器内部启用的一项功能。更多信息可以在我基于这个案例创建的 GitHub 问题中找到，which can be found here。

【讨论】：

【解决方案2】：

我必须承认我对 NServiceBus 知之甚少，当他们提出问题时，我只是觉得有义务尝试帮助那些享有盛誉的人 :) 所以我没有解释为什么它会这样工作，只是在它失败的地方.在堆栈跟踪中，您可以看到NHibernateStorageSession.Setup，NHibernateStorageSession 是其中一项功能。因此，在尝试激活该功能时它会失败。 Setup 开头是这样的：

protected override void Setup(FeatureConfigurationContext context)
{
  NHibernateConfiguration config = new NHibernateConfigurationBuilder(context.Settings, "Saga", new string[1]
  {
    "StorageConfiguration"
  }).Build();
  // the rest
}

其中第二个参数是连接字符串后缀。在这种情况下，它被硬编码为“Saga”，如您所见 - 没有检查 Sagas 功能是否启用。 NHibernateConfigurationBuilder 然后尝试查找 saga 的连接字符串（或任何更通用的连接字符串），但没有找到您观察到的异常消息。

如此简单的解决方案是通过禁用该功能

endpointConfiguration.DisableFeature<NHibernateStorageSessio‌n>();

但是，您当然应该注意并确保您需要的功能不依赖于该功能。对我来说，这个功能的用途并不完全清楚，我也没有找到任何关于它的文档（当然它的名字告诉我们一些关于它的用途）。

【讨论】：

我已经向 Particular 提出了一个事件，看看他们是否将此（以及我后来发现的另一个问题）归类为实际错误以及是否会得到解决。配置系统的意图似乎是您可以应用细粒度配置，并且只为您想要使用的功能“付费”，但实际情况似乎有些不同。

【解决方案3】：

您可以通过（按优先顺序）：

这只是意味着如果您需要设置 Saga，则第一个点将优先于另一个点，否则只需执行其他点之一：

指定适用于所有持久化器的“NServiceBus/Persistence”连接字符串

在 AppSettings 或您的 NHibernate 配置文件中指定“NServiceBus/Persistence/connection.connection_string”或“NServiceBus/Persistence/connection.connection_string_name”值。

对于大多数情况，“NServiceBus/Persistence”连接字符串是最佳选择。

所以你不需要设置 Saga，但看起来你不会避免在某处设置连接字符串。

【讨论】：

但是即使我设置了超时存储，这是我唯一想要的，我仍然会继续收到此错误。无论我做什么，似乎都决心建立 Saga 存储。正如我所说，我明确拒绝NServiceBus/Persistence，因为我目前无法得到上级的支持来整合数据库。
如果您拒绝此服务为其设置提出的所有选项，它看起来就像一个死胡同。我将最后一点解释为您可能会告诉 NHibernate 它的数据库直接在其自己的配置文件中的位置。您是否将超时连接字符串放在那里进行测试？在我看来，这个系统会检查很多地方，但不是特定于超时的地方。所以你必须选择它检查连接字符串的地方之一。