如何解决当配置更多时,MassTransit 仅批处理 10
我正在尝试配置 MassTransit 批处理,但在运行时一次只能批处理 10 个。
hostHandler = receiveEndpointConnector.ConnectReceiveEndpoint(queueName,(context,cfg) =>
{
cfg.TrySetPrefetchCount(2000);
cfg.Batch<T>(cfg =>
{
cfg.Consumer(() => consumer);
cfg.ConcurrencyLimit = 2;
cfg.MessageLimit = 1000;
cfg.TimeLimit = TimeSpan.FromSeconds(1);
});
cfg.UseMessageRetry(r => r.Immediate(2)));
});
await hostHandler.Ready;
解决方法
您也可以使用较新的批处理语法,但仍需要在 Consumer
调用之前指定:
var handle = receiveEndpointConnector.ConnectReceiveEndpoint(queueName,(context,cfg) =>
{
cfg.TrySetPrefetchCount(2000);
cfg.UseMessageRetry(r => r.Immediate(2)));
cfg.ConfigureConsumer<YourConsumer>(context,cons =>
{
cons.Options<BatchOptions>(options => options
.SetMessageLimit(1000)
.SetTimeLimit(1000)
.SetConcurrencyLimit(2));
});
});
await handle.Ready;
由于您使用的是接收端点连接器,因此您也可以将使用者定义中的批处理选项配置为 shown in the documentation。
,在我发布问题 5 分钟后,我尝试更改批处理配置的顺序,并将消费者作为最后一个语句,成功了。
hostHandler = receiveEndpointConnector.ConnectReceiveEndpoint(queueName,cfg) =>
{
cfg.TrySetPrefetchCount(2000);
cfg.Batch<T>(cfg =>
{
cfg.ConcurrencyLimit = 2;
cfg.MessageLimit = 1000;
cfg.TimeLimit = TimeSpan.FromSeconds(1);
cfg.Consumer(() => consumer);
});
cfg.UseMessageRetry(r => r.Immediate(2)));
});
await hostHandler.Ready;
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。