技术求助:Supervisor停止时无法创建新作用域的报错排查
刚碰到过一模一样的问题,先把你的错误信息贴出来方便大家参考:
Supervisor正在停止,无法创建额外作用域。错误详情如下:
System.OperationCanceledException: Supervisor正在停止,无法创建额外作用域
at MassTransit.Util.TaskSupervisor.CreateScope(String tag)
at MassTransit.Util.TaskScope.MassTransit.Util.ITaskSupervisor.CreateScope(String tag)
at MassTransit.Util.TaskSupervisorExtensions.CreateScope(ITaskSupervisor supervisor, String tag, Func`1 afterStopped)
at MassTransit.RabbitMqTransport.Integration.RabbitMqModelCache.ModelScope..ctor(ITaskScope supervisor)
at Mass...
错误原因分析
这个问题的核心是:MassTransit的TaskSupervisor已经进入停止流程了,但你的代码还在尝试创建新的任务作用域。通常发生在应用关闭阶段——比如程序正在退出,RabbitMQ的连接池还被请求创建新的ModelScope,这时候就会触发这个取消异常。
具体解决办法
我整理了几个亲测有效的方案,按优先级排序:
先停业务请求,再停MassTransit
如果是ASP.NET Core应用,建议注入IHostApplicationLifetime,设置一个全局的"应用是否正在停止"标志。在所有发送/消费消息的业务代码里先检查这个标志,避免在应用停止阶段发起新的消息操作。比如:private readonly IHostApplicationLifetime _appLifetime; private bool _isStopping => _appLifetime.ApplicationStopping.IsCancellationRequested; public async Task SendMessage(MyMessage message) { if (_isStopping) { _logger.LogWarning("应用正在停止,跳过消息发送"); return; } await _bus.Publish(message); }调整MassTransit主机的停止顺序
控制台应用里要注意,调用Host.StopAsync()之前,一定要确保所有后台消息任务都已经完成;ASP.NET Core里框架会自动处理,但如果有自定义的后台服务,要让这些服务先于MassTransit停止——可以通过IHostedService的StopAsync顺序来控制(依赖注入时设置合适的启动顺序)。优化RabbitMQ模型缓存配置
有时候是模型缓存的回收不及时导致的,你可以在配置RabbitMQ主机时调整缓存的参数,比如限制缓存大小和超时时间,让缓存更快释放:cfg.Host(new Uri("rabbitmq://localhost"), h => { h.Username("guest"); h.Password("guest"); // 设置缓存最大10个模型,5分钟超时回收 h.UseModelCache(10, TimeSpan.FromMinutes(5)); });捕获停止阶段的异常
最后兜底的办法是在消息操作的代码块里捕获OperationCanceledException,优雅处理而不是让程序崩溃:try { await _bus.Publish(message); } catch (OperationCanceledException ex) { _logger.LogWarning(ex, "应用停止期间无法创建消息作用域,已跳过该操作"); }
内容的提问来源于stack exchange,提问作者BERTON.L

