超时管理器立即返回超时

Question

我有一个非常简单的调度程序 saga，它应该每天发送一条特定消息。它被实现为请求超时的传奇。处理超时后，将执行操作（发送消息）并在第二天请求新的超时。

我以前做过完全相同的事情并成功，但现在超时似乎立即触发，所以无论请求什么 DateTime。

端点是自托管的，并配置为使用 InMemoryPersistence。 NServiceBus 版本为 6.4.3.

传奇实现如下。我已经删除了所有逻辑，但仍然立即无限地收到超时消息。

public class SchedulerSaga: Saga<SchedulerState>,
    IAmStartedByMessages<StartSchedulerSagaCommand>,
    IHandleTimeouts<SchedulerTimeout>
{
    private readonly IConfigurationProvider _config;

    public SchedulerSaga(IConfigurationProvider config)
    {
        _config = config;
    }

    protected override void ConfigureHowToFindSaga(SagaPropertyMapper<SchedulerState> mapper)
    {
        mapper.ConfigureMapping<StartSchedulerSagaCommand>(_ => _.SchedulerName).ToSaga(_ => _.SchedulerName);
    }

    public async Task Handle(StartSchedulerSagaCommand message, IMessageHandlerContext context)
    {
        Data.SchedulerName = message.SchedulerName;
        await StartProcessAndScheduleNewTimeout(context);
    }

    public async Task Timeout(SchedulerTimeout state, IMessageHandlerContext context)
    {
        Data.Counter++;
        await StartProcessAndScheduleNewTimeout(context);
    }

    private async Task StartProcessAndScheduleNewTimeout(IMessageHandlerContext context)
    {
        await RequestTimeout(context, new DateTime(2018, 9, 16, 0, 0, 0, DateTimeKind.Utc), new SchedulerTimeout { Counter = Data.Counter });
    }
}

端点配置如下：

    public static EndpointConfiguration ConfigureMsmqEndpoint(IWindsorContainer container)
    {
        var endpointConfiguration = new EndpointConfiguration(MsmqEndpointName);

        ConfigureRouting(endpointConfiguration);

        endpointConfiguration.UsePersistence<InMemoryPersistence>();

        endpointConfiguration.SendFailedMessagesTo($"{MsmqEndpointName}.error");
        endpointConfiguration.AssemblyScanner().ExcludeAssemblies("tools");
        endpointConfiguration.EnableInstallers();

        ConfigureUnobtrusiveMessageConvention(endpointConfiguration);

        endpointConfiguration.Recoverability().Delayed(DelayedSettings);

        endpointConfiguration.UseContainer<WindsorBuilder>(c => c.ExistingContainer(container));

        return endpointConfiguration;
    }

我也尝试使用内置的调度机制，同样的事情发生了，每秒都会触发数百次超时。

await endpointInstance.ScheduleEvery(
        timeSpan: TimeSpan.FromMinutes(5),
        task: context=> context.SendLocal(new SomeMessage())
    )
.ConfigureAwait(false);

更新： 添加代码重现问题的 repo。

https://github.com/spinakr/nsb-scheduling-msmq

只有在项目中引用包"NServiceBus.Azure.Transports.WindowsAzureStorageQueues"时才会出现问题，即使没有使用！

正在审核的应用程序在同一进程中托管了两个端点。使用来自 MSMQ 和 Azure 存储队列的消息。在 repo 中，只有在添加 azure 存储队列传输包时问题才开始出现。

Answer 1

我假设您所描述的端点正在使用 MSMQ 作为传输（基于方法和字段的名称）并且 saga 在该端点上运行。

MSMQ 依靠超时管理器来支持延迟传递。另一方面，Azure 存储队列传输似乎以不同的方式解决延迟交付问题。它实际上有一个 feature，默认情况下启用，可以防止延迟的消息被路由到超时管理器。如果您的 MSMQ 端点要扫描 NServiceBus.Azure.Transports.WindowsAzureStorageQueues 程序集，您的延迟消息将不会到达超时管理器。

此问题的一个解决方案是在您的 MSMQ 端点中配置程序集扫描程序以排除该程序集：

endpointConfiguration.AssemblyScanner().ExcludeAssemblies(
    "NServiceBus.Azure.Transports.WindowsAzureStorageQueues.dll");

Answer 2

在同一进程中共同托管多个端点时的另一个考虑因素 - 共享您的处理程序。您可能想查看 Endpoints multi hosting 示例，其中提到了如何使用带黑名单的程序集扫描来避免不需要的程序集加载。

超时管理器立即返回超时

Timeout manager retuning timout immediately

.net

nservicebus

nservicebus6