c# beginreceive在哪处理接收到的数据 - 问答

在C#中，BeginReceive方法用于异步接收数据。当接收到数据时，需要在一个回调方法中处理这些数据。这个回调方法是在调用BeginReceive时指定的。以下是一个简单的示例，展示了如何使用BeginReceive处理接收到的数据：

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

class Program
{
    static void Main(string[] args)
    {
        // 创建一个TCP客户端
        TcpClient client = new TcpClient("example.com", 80);

        // 发送HTTP请求
        SendHttpRequest(client);

        // 开始异步接收数据
        client.BeginReceive(new byte[] { 0 }, 0, 0, new AsyncCallback(HandleReceive), client);
    }

    static void SendHttpRequest(TcpClient client)
    {
        NetworkStream stream = client.GetStream();
        string request = "GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n";
        byte[] requestBytes = Encoding.ASCII.GetBytes(request);
        stream.Write(requestBytes, 0, requestBytes.Length);
    }

    static void HandleReceive(IAsyncResult result)
    {
        // 获取客户端对象
        TcpClient client = (TcpClient)result.AsyncState;

        // 结束异步接收
        NetworkStream stream = client.GetStream();
        stream.EndReceive(result);

        // 读取接收到的数据
        byte[] buffer = new byte[1024];
        int bytesRead = stream.Read(buffer, 0, buffer.Length);
        string response = Encoding.ASCII.GetString(buffer, 0, bytesRead);

        // 处理接收到的数据（例如，输出到控制台）
        Console.WriteLine(response);

        // 继续接收数据
        client.BeginReceive(new byte[] { 0 }, 0, 0, new AsyncCallback(HandleReceive), client);
    }
}

在这个示例中，我们首先创建了一个TCP客户端并连接到服务器。然后，我们发送一个HTTP请求。接下来，我们使用BeginReceive开始异步接收数据，并将回调方法HandleReceive作为参数传递。

在HandleReceive方法中，我们首先从AsyncState属性中获取客户端对象。然后，我们使用EndReceive方法结束异步接收。接着，我们从网络流中读取接收到的数据，并将其转换为字符串。最后，我们可以处理接收到的数据（例如，输出到控制台），然后再次调用BeginReceive以继续接收数据。

0 赞

0 踩