WebSocket框架有很多,现在经常用到Supersocket,现在要封装一个dll,里面用到WebSocket,但是如果dll里面引用第三方框架的话,引用自己封装的dll时还需要引用一堆额外的包,这就显得有点臃肿,因为只有一个客户端的WebSocket用原生的ClientWebSocket即可;
官方文档:https://docs.microsoft.com/zh-cn/dotnet/api/system.net.websockets.clientwebsocket?view=netframework-4.7.2&f1url=%3FappId%3DDev16IDEF1%26l%3DZH-CN%26k%3Dk(System.Net.WebSockets.ClientWebSocket);k(TargetFrameworkMoniker-.NETFramework,Version%253Dv4.7.2);k(DevLang-csharp)%26rd%3Dtrue
连接并发送消息:
public static ClientWebSocket clientWebSocket; public static Uri serverUri; public SocketClient(string ip, int port) {var webSocketUrl = $@"ws://{ip}:{port}"; clientWebSocket = new ClientWebSocket(); serverUri = new Uri(webSocketUrl); clientWebSocket.ConnectAsync(serverUri, CancellationToken.None).Wait(); } public async Task SendMessageAsync(string Msg) { if(clientWebSocket.State != WebSocketState.Open) { await clientWebSocket.ConnectAsync(serverUri, CancellationToken.None); } if (clientWebSocket.State == WebSocketState.Open) { ArraySegment<byte> bytesToSend = new ArraySegment<byte>(Encoding.UTF8.GetBytes(Msg)); await clientWebSocket.SendAsync(bytesToSend, WebSocketMessageType.Text, true, CancellationToken.None); } }
接收消息
ArraySegment<byte> bytesReceived = new ArraySegment<byte>(new byte[1024]); WebSocketReceiveResult result = await ws.ReceiveAsync(bytesReceived, CancellationToken.None); Console.WriteLine(Encoding.UTF8.GetString(bytesReceived.Array, 0, result.Count));
ClientWebSocket里面的方法都是异步的,如果同步方法调用异步:
1.不需要获取返回值的:
clientWebSocket.ConnectAsync(serverUri, CancellationToken.None).Wait();
2.需要获取返回值的
var result = clientWebSocket.ConnectAsync(serverUri, CancellationToken.None).GetAwaiter().GetResult();