当Rebus超时时，我们如何避免多个Rebus消息的出现？

Question

当Rebus超时时，我们如何避免多个Rebus消息的出现？

c#.netmessage-queuerebus

5

我们正在使用Rebus作为与Sql Server配合的队列系统。我们有几个不同类型消息的接收者。每个消息可以由某些特定类型的多个工作者处理。

每条消息应该只被一个工作者处理/处理（第一个拉取它的工作者）。如果某个工作者由于某种原因无法完成任务，则会使用超时服务将其推迟。

如果我理解正确，它将成为一个TimeoutRequest并放入超时表中。当重新运行时，它变成一个TimeoutReply，然后再次作为原始消息重新引入队列。

我们遇到的问题是，当它变成TimeoutReply时，所有工作者都会拿起它并创建原始消息。当超时时，一个原始消息会变成多个消息（数量与工作者一样多）。

我们的Rebus设置如下：

“服务器端”：

        var adapter = new BuiltinContainerAdapter();
        Configure.With(adapter)
            .Logging(l => l.Log4Net())
            .Transport(t => t.UseSqlServerInOneWayClientMode(connectionString).EnsureTableIsCreated())
            .CreateBus()
            .Start();

        return adapter;

"Worker side"：

“工作端”：

        _adapter = new BuiltinContainerAdapter();
        Configure.With(_adapter)
            .Logging(l => l.Log4Net())
            .Transport(t => t.UseSqlServer(_connectionString, _inputQueue, "error")
                .EnsureTableIsCreated())
            .Events(x => x.AfterMessage += ((bus, exception, message) => SendWorkerFinishedJob(exception, message)))
            .Events(x => x.BeforeMessage += (bus, message) => SignalWorkerStartedJob(message))
            .Behavior(x => x.SetMaxRetriesFor<Exception>(0))
            .Timeouts(x => x.StoreInSqlServer(_connectionString, "timeouts").EnsureTableIsCreated())
            .CreateBus().Start(numberOfWorkers);

非常感谢您的帮助解决问题或提供理解！

- jopa

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- mookid8000 · Accepted Answer

我能想到的唯一原因是每个工作进程都充当一个超时管理器，并且它们似乎共享相同的存储，所以你可能会遇到多个超时回复。这样，由于查询到期超时时超时管理器不使用任何锁定或其他东西，它们可能会抓取相同的到期超时，从而导致多个超时回复 - 即有竞态条件，但由于this SQL没有注意到是否实际删除了行，所以这种情况不会被注意到。

我建议您要么为工作进程使用单独的超时表（例如_inputQueue + ".timeouts"），要么让所有工作进程使用外部超时管理器（即省略Timeouts(x => ...)并启动一个独立的专用超时管理器）。

在您的情况下，我认为（a）是最简单的方法，因为它与您现在拥有的东西非常接近。

不过，我自己更喜欢（b），通常每台托管Rebus端点的机器都有一个超时管理器。

请让我知道是否解决了您的问题。

此外，我很好奇你对SQL传输的运作情况如何 :)