在C#中,可以使用System.Net.WebSockets
命名空间中的WebSocket
类来创建WebSocket连接并获取通信内容。
首先,需要使用ClientWebSocket
类创建WebSocket客户端实例,并使用ConnectAsync
方法连接到WebSocket服务器:
using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static async Task Main(string[] args)
{
using (ClientWebSocket clientWebSocket = new ClientWebSocket())
{
Uri serverUri = new Uri("wss://example.com/websocket");
await clientWebSocket.ConnectAsync(serverUri, CancellationToken.None);
// 连接成功后,可以发送和接收消息
}
}
}
连接成功后,可以使用SendAsync
方法发送消息,使用ReceiveAsync
方法接收消息:
using (ClientWebSocket clientWebSocket = new ClientWebSocket()) { // ... // 发送消息 string message = "Hello, WebSocket!"; byte[] messageBytes = Encoding.UTF8.GetBytes(message); await clientWebSocket.SendAsync(new ArraySegment(messageBytes), WebSocketMessageType.Text, true, CancellationToken.None); // 接收消息 byte[] receiveBuffer = new byte[1024]; while (true) { WebSocketReceiveResult receiveResult = await clientWebSocket.ReceiveAsync(new ArraySegment (receiveBuffer), CancellationToken.None); if (receiveResult.MessageType == WebSocketMessageType.Close) { await clientWebSocket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "", CancellationToken.None); break; } string receivedMessage = Encoding.UTF8.GetString(receiveBuffer, 0, receiveResult.Count); Console.WriteLine("Received: " + receivedMessage); } }
以上代码示例演示了如何发送和接收文本消息,如果需要发送二进制消息,可以将WebSocketMessageType.Text
参数替换为WebSocketMessageType.Binary
。
需要注意的是,WebSocket是一种双向通信协议,服务器也可以向客户端发送消息。在实际应用中,通常需要在不同的线程或任务中同时处理发送和接收消息,以避免阻塞。