C#并发Web异步请求问题求助：无法正确传递请求数据

嘿，我看了你的代码，发现几个关键问题导致了异常，咱们一步步来梳理和修复：

你代码里的核心问题 #

1. 字节数组生成错误：Encoding.ASCII.GetBytes()调用没有传入要转换的字符串data，这会生成一个空的字节数组，请求内容长度为0，不符合POST接口的参数要求。
2. POST请求未写入数据：异步POST请求需要先获取请求流并写入参数数据，但你直接调用了BeginGetResponse，跳过了写入请求体的步骤，服务器无法获取到参数，自然会返回错误。
3. 未处理请求异常：当请求失败（比如返回4xx/5xx状态码）时，EndGetResponse会抛出WebException，你没有捕获这个异常，导致程序崩溃。
4. 异步请求的资源管理：没有正确关闭响应流，可能会导致资源泄漏。

修复后的完整代码 #

using System;
using System.IO;
using System.Net;
using System.Text;

class Program
{
    static void Main(string[] args)
    {
        string data = "Login=Max";
        byte[] dataStream = Encoding.ASCII.GetBytes(data); // 修复：传入data参数生成字节数组

        for (int i = 0; i < 5; i++)
        {
            var req = WebRequest.Create("http://172.25.110.64:8082/auth/login/");
            req.Method = "POST";
            req.ContentType = "application/x-www-form-urlencoded";
            req.ContentLength = dataStream.Length;

            // 修复：先异步获取请求流，写入数据后再发起请求
            req.BeginGetRequestStream(new AsyncCallback(EndGetRequestStreamCallback), 
                new RequestState { Request = req, Data = dataStream });
        }

        // 等待所有异步请求完成（简单处理，实际项目可使用ManualResetEvent等）
        Console.ReadLine();
    }

    // 用于传递请求和数据的状态类
    private class RequestState
    {
        public WebRequest Request { get; set; }
        public byte[] Data { get; set; }
    }

    static void EndGetRequestStreamCallback(IAsyncResult result)
    {
        RequestState state = (RequestState)result.AsyncState;
        WebRequest req = state.Request;

        // 写入请求数据
        using (Stream postStream = req.EndGetRequestStream(result))
        {
            postStream.Write(state.Data, 0, state.Data.Length);
        }

        // 写入数据后，异步获取响应
        req.BeginGetResponse(new AsyncCallback(EndGetResponseCallback), req);
    }

    static void EndGetResponseCallback(IAsyncResult result)
    {
        WebRequest req = (WebRequest)result.AsyncState;
        HttpWebResponse response = null;

        try
        {
            response = (HttpWebResponse)req.EndGetResponse(result);
            
            // 读取响应内容（可选，根据需要处理）
            using (StreamReader reader = new StreamReader(response.GetResponseStream()))
            {
                string responseText = reader.ReadToEnd();
                Console.WriteLine($"请求成功，响应内容：{responseText}");
            }
            
            Console.WriteLine($"响应状态码：{response.StatusCode}");
        }
        catch (WebException ex)
        {
            // 处理请求异常，比如服务器返回错误状态码
            if (ex.Response is HttpWebResponse errorResponse)
            {
                Console.WriteLine($"请求失败，状态码：{errorResponse.StatusCode}");
                using (StreamReader reader = new StreamReader(errorResponse.GetResponseStream()))
                {
                    string errorText = reader.ReadToEnd();
                    Console.WriteLine($"错误详情：{errorText}");
                }
            }
            else
            {
                Console.WriteLine($"请求发生异常：{ex.Message}");
            }
        }
        finally
        {
            response?.Close(); // 关闭响应，释放资源
        }
    }
}

关键修改说明 #

• 添加了RequestState类：用来在异步回调之间传递WebRequest和要发送的数据，因为异步回调无法直接访问外部变量。
• 修正了字节数组生成：正确传入data参数生成包含请求参数的字节数组。
• 先写入请求流再获取响应：通过BeginGetRequestStream异步获取请求流，写入数据后再调用BeginGetResponse发起请求。
• 添加异常处理：捕获WebException，处理服务器返回的错误状态码，避免程序崩溃。
• 资源管理：使用using语句和finally块确保流和响应被正确关闭，防止资源泄漏。

如果你的接口有其他特殊要求（比如需要设置超时、请求头），可以在创建WebRequest后额外配置。

内容的提问来源于stack exchange，提问作者Madeck FromEarth