.NET Core Web应用中使用BackgroundService监听WebSocket是否可行？

一、BackgroundService完全适合你的场景 #

文档中提到的“应避免在ExecuteAsync中执行长时间阻塞的初始化工作”，核心是指同步阻塞操作（比如Thread.Sleep()、同步IO调用）这类会占用线程池线程且无法释放的操作。而你代码中使用的await ReceiveAsync()是异步等待，不会阻塞线程，线程可以在等待期间去处理其他任务，完全符合BackgroundService的设计初衷——它就是专门用来承载后台长期运行的异步任务的，保持WebSocket长连接正是典型的适用场景。

二、现有代码的几个问题及优化建议 #

你的当前实现存在几个需要调整的点，否则无法正常维护多个WebSocket连接：

1. DbContext生命周期问题
   你在循环外创建了DbContext，会导致上下文被长时间持有，可能引发数据跟踪异常或资源泄漏。应该把DbContext的创建放到循环内部，每次重试时重新获取：

   protected override async Task ExecuteAsync(CancellationToken stoppingToken)
   {
       while (!stoppingToken.IsCancellationRequested)
       {
           // 每次循环重新创建DbContext
           using var dbContext = KrzContextFactory.GetContext<StoroDashboardDbContext>(true);
           var credentials = dbContext.Branches.AsNoTracking().ToList();
           // ... 后续逻辑
       }
   }
   

2. 串行处理多个连接的问题
   当前的foreach会串行处理每个凭证的WebSocket连接：第一个连接的OpenWebSocketConnectionAsync如果是长期阻塞（循环接收消息），后续的凭证永远不会被处理。你需要为每个连接单独启动异步任务，让它们并行运行：

   // 替换原有的foreach逻辑
   var connectionTasks = new List<Task>();
   foreach (var credential in credentials)
   {
       var service = _knxServiceFactory.Create(credential.Store365SiteCode, credential.Url, credential.Username, credential.Password);
       // 每个连接单独启动任务，不等待完成，避免串行阻塞
       connectionTasks.Add(RunWebSocketConnection(service, stoppingToken));
   }
   // 等待所有连接任务完成（如果所有连接都断开的话）
   await Task.WhenAll(connectionTasks);
   

   然后单独实现RunWebSocketConnection方法，负责单个连接的重试逻辑：

   private async Task RunWebSocketConnection(IKNXService service, CancellationToken stoppingToken)
   {
       while (!stoppingToken.IsCancellationRequested)
       {
           try
           {
               await service.OpenWebSocketConnectionAsync(stoppingToken);
           }
           catch (Exception ex)
           {
               KrzApp.Log.Exception(ex);
               await Task.Delay(TimeSpan.FromSeconds(RetryDelayInSeconds), stoppingToken);
           }
       }
   }
   

   这样每个连接的断开、重试都不会影响其他连接。

3. 全局重试逻辑的问题
   原代码的全局重试会在任何一个连接出错时，重新获取所有凭证并重新创建所有连接，这可能导致正常的连接被重复创建。把重试逻辑放到单个连接的任务中，只会重试出错的那个连接，更合理。

三、备选方案（非必要） #

如果出于某些原因不想使用BackgroundService，你可以直接实现IHostedService接口，手动管理后台任务的启动和停止，但BackgroundService已经封装了大部分通用逻辑，实现起来更简洁，没有必要舍近求远。

内容的提问来源于stack exchange，提问作者stickfigure4