C# Invoke方法与WebSocket事件驱动的整合

在C#中，Invoke方法通常用于在UI线程上执行代码。WebSocket是一种网络通信协议，允许在客户端和服务器之间进行全双工通信。事件驱动编程是一种编程范式，其中程序的组件通过响应事件来通信。

将C#的Invoke方法与WebSocket事件驱动的整合，通常意味着在WebSocket客户端接收到消息时，使用Invoke方法在UI线程上处理这些消息。以下是一个简单的示例，展示了如何在C#中使用Invoke方法与WebSocket事件驱动的整合：

1. 首先，确保已经安装了System.Net.WebSockets包，以便使用WebSocket功能。

dotnet add package System.Net.WebSockets

2. 创建一个简单的WebSocket客户端类，该类使用System.Net.WebSockets命名空间中的类来处理WebSocket连接和消息。

using System;
using System.Net.WebSockets;
using System.Text;
using System.Threading.Tasks;

public class WebSocketClient
{
    private readonly ClientWebSocket _webSocket;
    private readonly Action<string> _messageHandler;

    public WebSocketClient(Uri serverUri, Action<string> messageHandler)
    {
        _webSocket = new ClientWebSocket();
        _messageHandler = messageHandler;
    }

    public async Task ConnectAsync()
    {
        await _webSocket.ConnectAsync(serverUri, CancellationToken.None);
    }

    public async Task CloseAsync()
    {
        await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "Closed", CancellationToken.None);
    }

    public async Task SendAsync(string message)
    {
        byte[] buffer = Encoding.UTF8.GetBytes(message);
        await _webSocket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, CancellationToken.None);
    }

    public event EventHandler<string> MessageReceived;

    private async Task OnMessageReceivedAsync(string message)
    {
        if (_messageHandler != null)
        {
            await WindowsFormsApplication1.InvokeAsync(() => _messageHandler(message));
        }
        MessageReceived?.Invoke(this, message);
    }

    public async Task StartListeningAsync()
    {
        _webSocket.MessageReceived += OnMessageReceivedAsync;
        while (true)
        {
            byte[] buffer = new byte[1024 * 4];
            WebSocketReceiveResult result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
            if (result.CloseStatus != WebSocketCloseStatus.NormalClosure)
            {
                break;
            }
            string message = Encoding.UTF8.GetString(buffer, 0, result.Count);
            await OnMessageReceivedAsync(message);
        }
    }
}

在这个示例中，WebSocketClient类包含一个MessageReceived事件，当从WebSocket服务器接收到消息时，会触发此事件。OnMessageReceivedAsync方法使用InvokeAsync方法将消息处理委托给UI线程。

3. 在Windows Forms应用程序中使用WebSocketClient类。

using System;
using System.Net.WebSockets;
using System.Windows.Forms;

public class MainForm : Form
{
    private readonly WebSocketClient _webSocketClient;

    public MainForm()
    {
        _webSocketClient = new WebSocketClient(new Uri("ws://example.com"), OnMessageReceived);
        _webSocketClient.MessageReceived += OnMessageReceived;
    }

    private async void MainForm_Load(object sender, EventArgs e)
    {
        await _webSocketClient.ConnectAsync();
        await _webSocketClient.StartListeningAsync();
    }

    private async void OnMessageReceived(object sender, string message)
    {
        MessageBox.Show($"Received message: {message}");
    }

    protected override void OnFormClosing(FormClosingEventArgs e)
    {
        await _webSocketClient.CloseAsync();
        base.OnFormClosing(e);
    }
}

在这个示例中，MainForm类包含一个_webSocketClient实例，它连接到WebSocket服务器并启动消息监听。OnMessageReceived方法将在接收到消息时显示一个消息框。

这样，我们就将C#的Invoke方法与WebSocket事件驱动的整合在一起，当WebSocket客户端接收到消息时，使用Invoke方法在UI线程上处理这些消息。