无法使NServiceBus不引发异常（MessageQueueException、SqlException、TimeoutPersisterReceiver）

Question

我有一个非常令人沮丧的NServiceBus问题，我似乎无法解决。我希望你们能对局势有所了解。

我目前正在使用NServiceBus。核心版本5。0和N服务总线。主机v6。0并以不引人注目的模式运行它。

看来，无论我使用什么配置，我总是得到某种错误。我将从产生最少问题的配置开始：

案例1-使用自定义组件扫描：

public void Customize(BusConfiguration configuration)
    {
        var endpointName = typeof(EndpointConfig).Namespace;
        configuration.SetUniqueHostId(endpointName);

        configuration.UseSerialization<JsonSerializer>();
        configuration.UsePersistence<NHibernatePersistence, StorageType.Outbox>();

        configuration.AssembliesToScan(new List<Assembly>
        {
            GetType().Assembly,
            typeof(ICustomCommand).Assembly
        });

        configuration.Conventions()
            .DefiningCommandsAs(type => typeof(ICustomCommand).IsAssignableFrom(type));

        configuration.EnableDurableMessages();
        configuration.EnableInstallers();

        var container = ContainerInitializer.Container;
        configuration.UseContainer<AutofacBuilder>(c => c.ExistingLifetimeScope(container));
    }

我注意到的问题如下：

>

当启动NServiceBus主机应用程序并且数据库暂留SQL还不存在时，不会抛出异常说找不到数据库（在情况2中是这样）。

我一直得到以下例外：

NServiceBus.超时。主机。窗户。从超时存储中获取超时失败

这最终导致应用程序崩溃，因为当这个错误发生太多次时，ServiceBus决定适可而止，并抛出一个致命的异常。

现在，这个有点难：

案例2-使用默认程序集扫描：

public void Customize(BusConfiguration configuration)
    {
        var endpointName = typeof(EndpointConfig).Namespace;
        configuration.SetUniqueHostId(endpointName);

        configuration.UseSerialization<JsonSerializer>();
        configuration.UsePersistence<NHibernatePersistence, StorageType.Outbox>();

        // !! DISABLED !!
        // configuration.AssembliesToScan(new List<Assembly>
        // {
        //    GetType().Assembly,
        //    typeof(ICustomCommand).Assembly
        // });

        configuration.Conventions()
            .DefiningCommandsAs(type => typeof(ICustomCommand).IsAssignableFrom(type));

        configuration.EnableDurableMessages();
        configuration.EnableInstallers();

        var container = ContainerInitializer.Container;
        configuration.UseContainer<AutofacBuilder>(c => c.ExistingLifetimeScope(container));
    }

在这种情况下，会出现以下问题：

当持久性SQL数据库尚不存在时：

1. 启动NServiceBus主机应用程序且SQL数据库不存在时，会出现异常抛出-预期行为（这是肯定的）

创建持久性SQL数据库后：

>

引发异常：“系统。信息。系统中的MessageQueueException。信息。dll附加信息：外部组件引发了异常。

2017-09-15 16:25:45.6743警告服务巴士。单播。信息。MessageMetadataRegistry |消息头'SharedTemp。接口。ICUSTOMCOMAND“”已映射到类型“SharedTemp”。接口。ICUSTOMCOMAND'，但在消息注册表中找不到该类型[…]

引发异常：“系统。NServiceBus中的“异常”。果心dll其他信息：找不到“Newtonsoft”的元数据。Json。林克。JObject’。

现在，例外情况3和4特别奇怪（并非双关语），因为NServiceBus文档说明：

默认情况下，将扫描endpoint bin目录中的所有程序集，以查找实现其接口的类型，以便可以自动配置它们。

和“牛顿软”。Json"和我的"SharedTemp dll's"确实在BIN文件夹中，但是NServiceBus似乎没有找到它们。至于第1点：NServiceBus不会为我创建那个队列，但它会创建我需要的所有其他队列。

最后是始终请求的应用程序。配置文件：

    <?html" target="_blank">xml version="1.0" encoding="utf-8"?>
<configuration>
  <configSections>
    <section name="MasterNodeConfig" type="NServiceBus.Config.MasterNodeConfig, NServiceBus.Core"/>
    <section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core"/>
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core"/>
    <section name="AuditConfig" type="NServiceBus.Config.AuditConfig, NServiceBus.Core"/>
  </configSections>
  <appSettings>
    <add key="NServiceBus/Persistence/NHibernate/dialect" value="NHibernate.Dialect.MsSql2012Dialect"/>
    <add key="NServiceBus/Outbox" value="true"/>
  </appSettings>
  <MessageForwardingInCaseOfFaultConfig ErrorQueue="error"/>
  <UnicastBusConfig>
    <MessageEndpointMappings />
  </UnicastBusConfig>
  <AuditConfig QueueName="audit"/>
  <connectionStrings>
    <add name="NServiceBus/Persistence" connectionString="Server=(LocalDB)\v11.0;Initial Catalog=NServiceBus;Integrated Security=true"/>
  </connectionStrings>
  <system.web>
    <membership defaultProvider="ClientAuthenticationMembershipProvider">
      <providers>
        <add name="ClientAuthenticationMembershipProvider" type="System.Web.ClientServices.Providers.ClientFormsAuthenticationMembershipProvider, System.Web.Extensions, Version=4.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35" serviceUri=""/>
      </providers>
    </membership>
    <roleManager defaultProvider="ClientRoleProvider" enabled="true">
      <providers>
        <add name="ClientRoleProvider" type="System.Web.ClientServices.Providers.ClientRoleProvider, System.Web.Extensions, Version=4.0.0.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35" serviceUri="" cacheTimeout="86400"/>
      </providers>
    </roleManager>
  </system.web>
  <startup>
    <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2"/>
  </startup>
  <MasterNodeConfig Node="localhost"/>
</configuration>

有人知道这些吗？

Answer 1

经过多次搜索，我终于找到了问题！

首先，我使用了一个内部NuGet包，该包应该可以帮助我配置NServiceBus。这个包在其他项目中运行良好，但在我的项目中运行不太好，因为我使用的是JsonSerialization，而不是默认的XML序列化。

这个包的第一个问题是它使用了“INeed初始化”接口来配置NServiceBus。然后，在我的代码中，我将调用“IConfigreThisEndpoint”来启用JsonSeriize。这里的问题是，当启动NServiceBus主机时，它将无法找到NewtonSoft。Json图书馆。如果我随后将自定义程序集扫描添加到我自己的配置代码中，它将不会触发“INeed初始化”，从而导致不完整/不正确的配置。

我想它无法加载NewtonSoft。Json库，因为在包的代码/命名空间中触发了扫描？也许@Sean Farmer可以回答这个问题？

该软件包的第二个问题是，它会向应用程序添加连接字符串。配置，一个用于“NServiceBus/Persistence”，另一个用于“NServiceBus/Persistence/NHibernate/Saga”。我没有使用Saga，因此不需要它的连接字符串。最初这不是一个问题，因为我第一次看到它，但在重新安装软件包后，我完全忘记了它。再次删除此项似乎也会使NServiceBus更快乐。

那么，什么最终奏效了？我删除了这个包，并自己进行了配置，结果如下：

public void Customize(BusConfiguration configuration)
    {
        var endpointName = typeof(EndpointConfig).Namespace;
        configuration.UniquelyIdentifyRunningInstance().UsingCustomIdentifier(endpointName);

        configuration.EnableOutbox();
        configuration.UsePersistence<NHibernatePersistence>();
        configuration.Transactions().DefaultTimeout(TimeSpan.FromMinutes(5.0));

        configuration.UseSerialization<JsonSerializer>();

        configuration.Conventions()
            .DefiningCommandsAs(type => typeof(ICustomCommand).IsAssignableFrom(type));

        configuration.EnableDurableMessages();
        configuration.EnableInstallers();

        var container = ContainerInitializer.Container;
        configuration.UseContainer<AutofacBuilder>(c => c.ExistingLifetimeScope(container));
    }

@肖恩：谢谢你让我联系你。幸运的是没必要

@迈克：谢谢你的意见