Почему не запускается микросервис?

Question

[vanixachatryan]

Имеется сервис реализующий IHostedService, IDisposable:

private GamesContext _db;

        private readonly IServiceScopeFactory _scopeService;
        private Timer _timer;

        public CrashService(IServiceScopeFactory scopeService)
        {
            _scopeService = scopeService;
        }
        

        public Task StartAsync(CancellationToken cancellationToken)
        {
            DoWork();

            return Task.CompletedTask;
        }

public async void DoWork()
        {
            using (var scope = _scopeService.CreateScope())
            {
                _db = scope.ServiceProvider.GetRequiredService<GamesContext>();
                _hubContext = scope.ServiceProvider.GetRequiredService<IHubContext<CrashHub>>();
            }

            Random rand = new Random();
            endCoef = (float)(rand.Next(150) + rand.NextDouble());
            CrashGame game = new CrashGame()
            {
                Status = "wait",
                EndValue = endCoef,
                WinnerId = 0
            };

            _db.CrashGames.Add(game);

            await _db.SaveChangesAsync();

            Task timer = Task.Run(async () => {
                for (int i = interval; interval >= 0; i--)
                {
                    await _hubContext.Clients.All.SendAsync("wait", i);
                    await Task.Delay(1000);
                }
            });

            game.Status = "playing";

            _db.CrashGames.Update(game);

            await _db.SaveChangesAsync();

            bool gameStatus = await UpdateCoefAsync();

            if (gameStatus)
            {
                game.Status = "ended";
                _db.CrashGames.Update(game);

                await _db.SaveChangesAsync();
            }
        }

Вылетает ошибка при запуске проекта:

System.ObjectDisposedException: "Cannot access a disposed object. A common cause of this error is disposing a context 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, or wrapping the context in a using statement. If you are using dependency injection, you should let the dependency injection container take care of disposing context instances."

на строчке _db.CrashGames.Add(game);

Как исправить?

Answer 1

[Александр Юдаков]

Судя по всему, область действия блока "using (var scope..." следует расширить до конца метода.
Т.е. перенести закрывающую скобку в самый низ.

Comments

[vanixachatryan]

using (var scope = _scopeService.CreateScope())
            {
                GamesContext db = scope.ServiceProvider.GetRequiredService<GamesContext>();
                _hubContext = scope.ServiceProvider.GetRequiredService<IHubContext<CrashHub>>();
            

                Random rand = new Random();
                endCoef = (float)(rand.Next(150) + rand.NextDouble());
                CrashGame game = new CrashGame()
                {
                    Status = "wait",
                    EndValue = endCoef,
                    WinnerId = 0
                };

                db.CrashGames.Add(game);

                await db.SaveChangesAsync();

                Task timer = Task.Run(async () => {
                    for (int i = interval; interval >= 0; i--)
                    {
                        await _hubContext.Clients.All.SendAsync("wait", i);
                        await Task.Delay(1000);
                    }
                });

                game.Status = "playing";

                db.CrashGames.Update(game);

                await db.SaveChangesAsync();

                bool gameStatus = await UpdateCoefAsync();

                if (gameStatus)
                {
                    game.Status = "ended";
                    db.CrashGames.Update(game);

                    await db.SaveChangesAsync();
                }
            }

Стек перегружен? как исправить ?

Программа "[4528] dotnet.exe" завершилась с кодом -1073741819 (0xc0000005) 'Access violation'.

[vanixachatryan]

vanixachatryan, решил проблему с бд так

services.AddSingleton<IHostedService, CrashService>(s => new CrashService(new GamesContext(null, connection)));

, но теперь незнаю как передать IhubContext через ConfigureServices? Это вообще возможно?

[lam0x86]

vanixachatryan, попробуйте вставить "await timer;" перед последней скобкой. А то у вас остаётся подвисший таск, который использует переменные из скоупа, который уже задиспоужен.

[vanixachatryan]

lam0x86, Проблему решил, база работает, но почему то игнорируется отправка сообщение через SignalR

Answer 2

[lam0x86]

Я пока не очень понял смысл приведенного кода. game.Status = "playing" должен выставиться сразу, или сначала нужно послать несколько сообщений пользователям с интервалом в 1 секунду, и уже потом игра переходит в состояние playing? Предположу, что второе.
Навскидку, вижу несколько ошибок в коде. Во-первых, метод DoWork должен возвращать Task, а не void. Тогда метод StartAsync будет выглядеть так:

public async Task StartAsync(CancellationToken cancellationToken)
{
    // Хорошим тоном считается использовать CancellationToken, если он есть. 
    // Иначе задачу невозможно будет отменить.
    await DoWork(cancellationToken); 
}

Далее, вы зачем-то отправляете сообщения клиентам в отдельном таске, хотя логичнее было бы сделать это тут же (если моё предположение верно, и нам надо перевести игру в playing только после отправки всех сообщений).
Ну и как сказали выше, using нужно расширить до конца метода.

Comments

[vanixachatryan]

Решил передавать контексты так:

var provider = services.BuildServiceProvider();
            using (var scope = provider.CreateScope())
            {
                IHubContext<CrashHub> crashHub = (IHubContext<CrashHub>)scope.ServiceProvider.GetService(typeof(IHubContext<CrashHub>));
                GamesContext сrashService = new GamesContext(connection);
                services.AddSingleton<IHostedService, CrashService>(s => new CrashService(crashHub, сrashService));
            }

с базой все ок, но контекст хаба не передается, ошибок нет. А отправка сообщений клиенту просто игнорируются

[lam0x86]

А откуда берется services? По идее, метод BuildServiceProvider() вообще не надо вызывать из кода. Когда внутри вашего CrashService вы вызываете

scope.ServiceProvider.GetRequiredService<IHubContext<CrashHub>>()

, должен резолвиться контекст. Как у вас написаны метод ConfigureServices и Configure в классе Startup?

[vanixachatryan]

lam0x86, это у меня прописано в ConfigureServices.
А вот конструктор сервиса

public CrashService(IHubContext<CrashHub> hubContext, GamesContext db)
        {
            _db = db;
            _hubContext = hubContext;
        }

Внутри сервиса не вызываю уже

scope.ServiceProvider.GetRequiredService<IHubContext<CrashHub>>()

, перенес это в ConfigureServices

[lam0x86]

vanixachatryan, похоже, чтобы разобраться что к чему, нужен полный код, например, на гитхабе. Пока ничего непонятно.

[vanixachatryan]

lam0x86, ссылка здесь описано по понятней