日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后,達者為師

網站首頁 編程語言 正文

在Asp.net?core中實現websocket通信_實用技巧

作者:天方 ? 更新時間: 2022-08-23 編程語言

今天小試了一下在Asp.net core中使用websocket,這里記錄一下:

在 Startup 類的 Configure 方法中添加 WebSocket 中間件。

app.UseWebSockets();

它也可以傳入一些參數

app.UseWebSockets(new WebSocketOptions()
{
    KeepAliveInterval = TimeSpan.FromSeconds(120),
    ReceiveBufferSize = 4 * 1024
});

添加WebSocket中間件的處理函數:

async Task WebSocketMiddleware(HttpContext context, Func<Task> next)
{
    //這里監聽的是 /ws 作為地址
    if (context.Request.Path != "/ws")
    {
        await next();
        return;
    }
                                                                                        
    if (!context.WebSockets.IsWebSocketRequest)
    {
        context.Response.StatusCode = 400;
        return;
    }

    WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
    await Echo(context, webSocket);
}

在Startup 類的 Configure函數中應用該中間件。?

app.Use(WebSocketMiddleware);

最后再來完成我們的WebScoket功能函數Echo

async Task Echo(HttpContext context, WebSocket webSocket)
{
    var buffer = new byte[1024 * 4];
    WebSocketReceiveResult result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
    while (!result.CloseStatus.HasValue)
    {
        await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), 
          result.MessageType, result.EndOfMessage, CancellationToken.None);
        result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
    }
    await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
}

到此一個簡單的websocket應用就完成了,我們可以隨便找一個測試webscoket的程序或在線網頁測試一下了。

最后需要說明一下的時,本身asp.net core的websocket是可以在win7下跑的(來自于Kestrel內核的支持),但win7下的iis是不支持websocket反向代理的,因此如果在win7下開發或測試的時候,不要用iis來反向代理asp.net core程序。

原文鏈接:https://www.cnblogs.com/TianFang/p/8436790.html

欄目分類
最近更新