azure - Azure 上的公共(public)交通 MaxConcurrentCalls 设置被忽略

Question

我在 Azure 上使用 MassTransit 并在总线上配置 MaxConcurrentCalls 时遇到问题。我有一个进程要求一次执行 1 条消息，但我无法使用总线配置来实现这一点。例如，在总线配置期间，我设置了以下内容

busConfigurator.MaxConcurrentCalls = 1;
busConfigurator.PrefetchCount = 0;

注册消费者后，我立即向端点发送 3 条消息，并立即创建 3 个消费者实例并开始处理。下面是来自 Log4Net 的日志片段。

我想知道是否有其他人遇到过这个问题以及他们如何解决它，或者知道我可能做错了什么。从下面的日志可以看出，这些消息立即开始执行，尽管每条消息都需要大约 10-15 秒的时间来处理。

[2017-02-03 16:48:18,410]   [DEBUG] [13]    [svcbus.Consumers.SellerPageConsumer]   [Consume]   []  [Loading page https://....... ]     
[2017-02-03 16:48:18,410]   [DEBUG] [14]    [svcbus.Consumers.SellerPageConsumer]   [Consume]   []  [Loading page https://....... ]     
[2017-02-03 16:48:18,420]   [DEBUG] [23]    [svcbus.Consumers.SellerPageConsumer]   [Consume]   []  [Loading page https://....... ]     

Answer 1

更新
我查看了 Azure 配置属性。
配置接收端点时，您可以在那里设置 MaxConcurrentCalls 和 PrefechCount。
这应该可以工作

configurator.ReceiveEndpoint(host,"QueueName", re =>
{
    re.MaxConcurrentCalls = 1;
    re.PrefetchCount = 1;
    //configure consumers & other stuff here ...
});

旧答案
不是特定于azure的，但是在RabbitMQ上，我通过在配置器对象上调用UseConcurrencyLimit来设置最大并发消费者例如

bus = MassTransit.Bus.Factory.CreateUsingRabbitMq(configurator =>
{
    configurator.UseConcurrencyLimit(options.MaxConcurrentConsumers);
    . . .
}

Azure 配置器上有类似的东西吗？