在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<byte>(messageBytes), WebSocketMessageType.Text, true, CancellationToken.None);
// 接收消息
byte[] receiveBuffer = new byte[1024];
while (true)
{
WebSocketReceiveResult receiveResult = await clientWebSocket.ReceiveAsync(new ArraySegment<byte>(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是一種雙向通信協議,服務器也可以向客戶端發送消息。在實際應用中,通常需要在不同的線程或任務中同時處理發送和接收消息,以避免阻塞。