服务器端C# Websocket,如何在监听取消令牌时运行循环?

在我的 Vue/.NET Core 2.3 项目中,我开始用 Websockets 替换标准 AJAX 调用,其中我正在实现一个股票定价流服务,以便在股票价格实时更新时更新前端。之前的价格更新用于每 5 秒从 FE 发送一个间隔请求,以从方法获取新价格StockProcess().GetStockPricing(symbol)


下面的新 Websocket 实现现在使用相同的后端 GetStockPricing() 代码,但是检查循环现在位于后端,因此当客户端连接时,该方法将继续发送回价格。


作为一个原则,实现工作得很好,如果价格发生变化,该方法会将更新发送给客户端,完美。


API控制器.cs


[HttpGet("GetStockPricingAsync", Name = "GetStockPricingAsync")]

public async Task GetStockPricingAsync(string symbol)

{

    var isSocketRequest = ControllerContext.HttpContext.WebSockets.IsWebSocketRequest;

    if (isSocketRequest)

    {

        WebSocket webSocket = await ControllerContext.HttpContext.WebSockets.AcceptWebSocketAsync();

        await _mainController.GetStockPricingAsync(ControllerContext.HttpContext, webSocket, symbol);

    }

    else

    {

        ControllerContext.HttpContext.Response.StatusCode = 400;

    }

}

问题是我无法取消正在运行的GetStockPricing循环:


问题是行WebSocketReceiveResult result = await webSocket.ReceiveAsync(requestBuffer, CancellationToken.None);不会被执行,因为循环总是在运行,如果我将此行移到循环之前执行,那么循环也不会被触发,所以我无法同时运行循环和 ReceiveAsync 监听取消令牌。有办法实现这一点吗?在监听取消令牌的同时运行循环?


跃然一笑
浏览 128回答 1
1回答

动漫人物

尝试使用 System.Threading.Tasks.Task Run中的循环来监听它Task.Run(() => CancellationTokenFunc(...), ...);static void CancellationTokenFunc(){  while(true){             //check for cancel    }}在 webSocket.State 循环之前执行此操作
打开App,查看更多内容
随时随地看视频慕课网APP