C#中使用HttpWebRequest连续执行POST请求，如何避免超时异常？

需要按顺序连续执行一系列POST请求（POST 1 → POST 2 → POST 3 → …），核心要求如下：

1. 每个请求必须在前一个执行完成后再启动
2. 处理各类异常（尤其是http.GetRequestStream()处的超时异常）
3. 支持请求序列的中断操作

现有代码存在大量重复逻辑，异常处理过于笼统，且在获取请求流时偶尔触发超时，当前采用同步阻塞方式执行，效率和可维护性较差。

1. 重构复用请求逻辑 #

将重复的POST请求逻辑封装为独立方法，统一配置超时、Cookie容器等参数，避免代码冗余，提升可维护性。

2. 异步方式保证顺序执行 #

使用async/await替代同步阻塞（如Task.Delay().Wait()），既严格保证请求顺序，又不会阻塞主线程，异步API对超时和中断的处理更原生友好。

3. 细化异常处理 #

• 捕获具体异常类型（WebException、OperationCanceledException），而非笼统的Exception，便于精准定位问题
• 针对GetRequestStream()的超时，通过配置ReadWriteTimeout覆盖流读写阶段的超时控制
• 确保所有资源（请求流、响应流）通过using语句自动释放

4. 支持请求中断 #

引入CancellationToken，在需要中断请求序列时（如用户取消操作），可及时终止后续请求，避免无效执行。

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

public class SequentialPostHandler
{
    private readonly CookieContainer _cookieJar = new CookieContainer();
    private readonly string _targetUrl = "http://...../login.cgi";
    private const int ConnectionTimeout = 4000;
    private const int StreamTimeout = 4000;

    // 封装通用POST请求方法
    private async Task<bool> SendSinglePost(string postData, CancellationToken token = default)
    {
        try
        {
            var request = (HttpWebRequest)WebRequest.Create(_targetUrl);
            request.CookieContainer = _cookieJar;
            request.KeepAlive = false;
            request.Timeout = ConnectionTimeout;
            request.ReadWriteTimeout = StreamTimeout; // 控制流读写阶段超时
            request.ServicePoint.ConnectionLeaseTimeout = ConnectionTimeout;
            request.ServicePoint.MaxIdleTime = ConnectionTimeout;
            request.Method = "POST";
            request.ContentType = "application/x-www-form-urlencoded";

            byte[] dataBytes = Encoding.UTF8.GetBytes(postData);
            request.ContentLength = dataBytes.Length;

            // 提前检查是否已取消
            token.ThrowIfCancellationRequested();

            // 异步写入请求数据
            using (var postStream = await request.GetRequestStreamAsync(token))
            {
                await postStream.WriteAsync(dataBytes, 0, dataBytes.Length, token);
            }

            token.ThrowIfCancellationRequested();

            // 异步获取响应
            using (var response = (HttpWebResponse)await request.GetResponseAsync(token))
            {
                // 可根据业务需求校验响应状态码
                return response.StatusCode == HttpStatusCode.OK;
            }
        }
        catch (WebException ex)
        {
            if (ex.Status == WebExceptionStatus.Timeout)
            {
                Console.WriteLine("请求超时");
            }
            else
            {
                Console.WriteLine($"请求失败: {ex.Message}");
            }
            return false;
        }
        catch (OperationCanceledException)
        {
            Console.WriteLine("请求序列已中断");
            return false;
        }
        catch (Exception ex)
        {
            Console.WriteLine($"未知异常: {ex.Message}");
            return false;
        }
    }

    // 执行顺序请求序列
    public async Task<bool> RunSequentialPosts(CancellationToken token = default)
    {
        // 定义所有需要执行的POST数据
        var postDataList = new[]
        {
            "submit=ipv4",
            "some Data",
            // 可添加更多请求数据
        };

        foreach (var postData in postDataList)
        {
            token.ThrowIfCancellationRequested();

            bool isSuccess = await SendSinglePost(postData, token);
            if (!isSuccess)
            {
                // 可根据需求选择：失败则终止序列，或继续执行下一个
                // return false;
                Console.WriteLine($"当前请求失败，继续执行下一个");
            }

            // 异步等待3.5秒，不阻塞线程
            await Task.Delay(3500, token);
        }

        return true;
    }
}

// 使用示例
// var handler = new SequentialPostHandler();
// var cancellationSource = new CancellationTokenSource();
// // 如需中断请求，调用 cancellationSource.Cancel();
// await handler.RunSequentialPosts(cancellationSource.Token);

代码说明 #

• 复用性：SendSinglePost方法封装了所有POST请求的通用逻辑，修改配置或逻辑只需维护一处
• 超时控制：新增ReadWriteTimeout解决GetRequestStream()阶段的超时问题，覆盖连接和流读写全流程
• 中断支持：通过CancellationToken实现请求序列的主动中断，响应及时
• 资源安全：所有流资源通过using语句自动释放，避免资源泄漏
• 异常精准：区分不同异常类型，便于排查问题和针对性处理

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