asp-net core WebSocket 的使用
ASP.NET Core 中使用 WebSocket 可以實現雙向通信,以下是 ASP.NET Core WebSocket 的使用步驟:
創建 WebSocketMiddleware
創建一個自定義的 WebSocketMiddleware 來處理 WebSocket 請求,代碼如下所示:
public class WebSocketMiddleware
{
private readonly RequestDelegate _next;
public WebSocketMiddleware(RequestDelegate next)
{
_next = next;
}
public async Task Invoke(HttpContext context)
{
if (context.WebSockets.IsWebSocketRequest)
{
WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
await EchoAsync(context, webSocket);
}
else
{
await _next(context);
}
}
private async Task EchoAsync(HttpContext context, WebSocket webSocket)
{
var buffer = new byte[1024 * 4];
while (webSocket.State == WebSocketState.Open)
{
var result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
if (result.MessageType == WebSocketMessageType.Text)
{
var incomingMessage = Encoding.UTF8.GetString(buffer, 0, result.Count);
var outgoingMessage = "You sent " + incomingMessage + " at " + DateTime.Now.ToLongTimeString();
var outgoingBuffer = Encoding.UTF8.GetBytes(outgoingMessage);
await webSocket.SendAsync(new ArraySegment<byte>(outgoingBuffer, 0, outgoingBuffer.Length), result.MessageType, result.EndOfMessage, CancellationToken.None);
}
else if (result.MessageType == WebSocketMessageType.Close)
{
await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
}
}
}
}
註冊 WebSocketMiddleware
在 Startup.cs 文件的 Configure 方法中註冊 WebSocketMiddleware,代碼如下所示:
public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
app.UseRouting();
app.UseEndpoints(endpoints =>
{
endpoints.MapGet("/", async context =>
{
await context.Response.WriteAsync("Hello World!");
});
endpoints.MapMiddleware<WebSocketMiddleware>("/ws");
});
}
連接 WebSocket
使用 JavaScript 代碼連接 WebSocket,代碼如下所示:
var ws = new WebSocket("ws://" + location.host + "/ws");
ws.onopen = function () {
console.log("WebSocket connection opened.");
};
ws.onmessage = function (event) {
console.log("Received message: " + event.data);
};
ws.onclose = function () {
console.log("WebSocket connection closed.");
};
ws.send("Hello, WebSocket!");
以上是 ASP.NET Core 中使用 WebSocket 的簡單示例,通過 WebSocket 可以實現雙向通信,可以在實時通訊、在線遊戲等領域中得到廣泛應用。
本文由 Readfog 進行 AMP 轉碼,版權歸原作者所有。
來源:https://mp.weixin.qq.com/s/wWwUBGB8zQRzG9l8JBXSMw