.NET Core Worker Service(BackgroundService) 依赖注入 RabbitMQ 接收器

如何解决.NET Core Worker Service(BackgroundService) 依赖注入 RabbitMQ 接收器

在我的 ASP.Net Core Web API 中，我有一个 RabbitMQ Producer，而在另一个类库中，我有一个从 BackgroundService 继承并为 RabbitMQ 实现消费者的工作类 我的生产者向消费者发送一个项目，消费者负责将项目设置到我的数据库中

我的问题： 每当我的消费者尝试调用 db_context 时，我都会收到此异常

System.ObjectdisposedException: 'Cannot access a disposed context instance. A common cause of this error is disposing a context instance that was resolved from dependency injection and then later trying to use the same context instance elsewhere in your application. This may occur if you are calling 'dispose' on the context instance,or wrapping it in a using statement. If you are using dependency injection,you should let the dependency injection container take care of disposing context instances.
Object name: 'LogisticsDBContext'.'

我知道我的 db_context 是有范围的，并且在调用端点后它会被处理掉 但我需要为它找到最佳解决方案

worker/program.cs

services.AddHostedService<Worker>();
services.AddScoped<ICityVillageRepositoryBase,CityVillageRepositoryRepositoryBase>();

制作人

   public void Publish(CityVillage message)
        {
            System.Console.WriteLine("sent");
            byte[] body = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(message));
            Channel.Basicpublish(exchange: "",routingKey: QueueName,basicProperties: null,body: body);
        }
    }

消费者

using (IServiceScope scope = scopeFactory.CreateScope())
            {
                ICityVillageRepositoryBase cityVillageRepositoryBase =scope.ServiceProvider.GetrequiredService<ICityVillageRepositoryBase>();
                Channel = _connection.CreateModel();
                Channel.QueueDeclare(queue: LoggerQueue,durable: false,exclusive: false,autoDelete: false,arguments: null);

                EventingBasicConsumer consumer = new EventingBasicConsumer(Channel);

                consumer.Received += (model,ea) =>
                {
                    byte[] body = ea.Body.ToArray();
                    string message = Encoding.UTF8.GetString(body);
                    CityVillage cityVillage = JsonConvert.DeserializeObject<CityVillage>(message);
                    cityVillageRepositoryBase.GetFirstOrDefault();
                    Console.WriteLine("Received \b\b "+ message);

                };

               // cityVillageManagerBase.IniCityVillageAsync();
                Channel.BasicConsume(queue: LoggerQueue,autoAck: true,consumer: consumer);

            }

我仍然是初级开发人员，如果我需要发布任何其他源代码，请告诉我 提前致谢！