溫馨提示×

C#如何獲取webscoket的通信內(nèi)容

c#
小億
157
2023-11-01 12:45:00
欄目: 編程語言

在C#中,可以使用System.Net.WebSockets命名空間中的WebSocket類來創(chuàng)建WebSocket連接并獲取通信內(nèi)容。

首先,需要使用ClientWebSocket類創(chuàng)建WebSocket客戶端實例,并使用ConnectAsync方法連接到WebSocket服務(wù)器:

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);
            
            // 連接成功后,可以發(fā)送和接收消息
        }
    }
}

連接成功后,可以使用SendAsync方法發(fā)送消息,使用ReceiveAsync方法接收消息:

using (ClientWebSocket clientWebSocket = new ClientWebSocket())
{
    // ...

    // 發(fā)送消息
    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);
    }
}

以上代碼示例演示了如何發(fā)送和接收文本消息,如果需要發(fā)送二進(jìn)制消息,可以將WebSocketMessageType.Text參數(shù)替換為WebSocketMessageType.Binary。

需要注意的是,WebSocket是一種雙向通信協(xié)議,服務(wù)器也可以向客戶端發(fā)送消息。在實際應(yīng)用中,通常需要在不同的線程或任務(wù)中同時處理發(fā)送和接收消息,以避免阻塞。

0