在我的 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 监听取消令牌。有办法实现这一点吗?在监听取消令牌的同时运行循环?
动漫人物
相关分类