Boost TCP Socket调用write_some阻塞问题及超时方案咨询

我来帮你梳理下这个问题，结合Boost.Asio的使用经验给你几个解决方案：

你的write_some阻塞核心原因是TCP滑动窗口机制导致的：接收端死锁后无法处理已接收的数据，TCP接收窗口会逐渐被占满，最终发送端的发送缓冲区耗尽，write_some就会阻塞等待对方的ACK或窗口更新。即使重启发送端，若旧连接状态未彻底清理（比如处于FIN_WAIT1），或新连接再次遭遇接收端死锁，阻塞问题仍会重现。

当然可以设置超时来触发连接重启，这里有两种实用思路：

1. 异步操作配合deadline_timer（推荐） #

这是Boost.Asio中处理超时最优雅的方式，通过异步写+定时器组合，超时后主动关闭socket触发错误回调，在回调中执行重连逻辑。

推荐用async_write替代async_write_some，因为它会自动处理部分发送的情况，保证数据全部发送完成：

void SendDataWithTimeout(const char* pData, size_t nLength) {
    std::vector<char> send_buffer(pData, pData + nLength);
    
    // 创建5秒超时的写定时器
    auto write_timer = std::make_shared<boost::asio::deadline_timer>(socket->get_io_service());
    write_timer->expires_from_now(boost::posix_time::seconds(5));
    write_timer->async_wait([this, socket, write_timer](const boost::system::error_code& ec) {
        if (!ec) {
            // 超时触发，关闭socket以终止异步写操作
            boost::system::error_code ignore_ec;
            socket->close(ignore_ec);
        }
    });
    
    // 发起异步写操作
    boost::asio::async_write(*socket, boost::asio::buffer(send_buffer),
        [this, socket, write_timer](const boost::system::error_code& ec, std::size_t bytes_sent) {
            // 无论写操作成功或失败，先取消定时器
            write_timer->cancel();
            
            if (ec) {
                // 写失败（含超时导致的关闭），执行重连逻辑
                std::cout << "Write failed, reconnecting: " << ec.message() << std::endl;
                ReconnectToServer();
                return;
            }
            
            // 数据发送成功，处理后续业务
            std::cout << "Sent " << bytes_sent << " bytes successfully" << std::endl;
        });
    
    // 运行IO服务处理异步事件
    socket->get_io_service().run_one();
}

2. 同步操作+非阻塞模式+poll/select #

如果坚持使用同步write_some，可以将socket设为非阻塞模式，通过poll或select等待写就绪并设置超时：

boost::system::error_code ec;
// 将socket设置为非阻塞模式
socket->non_blocking(true, ec);
if (ec) {
    // 处理模式设置失败逻辑
    return;
}

const char* pData = /* 你的数据指针 */;
size_t nLength = /* 数据长度 */;
std::size_t bytes_written = socket->write_some(boost::asio::buffer(pData, nLength), ec);

if (ec == boost::asio::error::would_block) {
    // 准备pollfd结构
    pollfd pfd;
    pfd.fd = socket->native_handle();
    pfd.events = POLLOUT;
    
    // 等待5秒超时
    int poll_ret = poll(&pfd, 1, 5000);
    if (poll_ret == -1) {
        perror("poll failed");
        ReconnectToServer();
    } else if (poll_ret == 0) {
        // 超时触发，关闭socket并重连
        socket->close(ec);
        ReconnectToServer();
    } else {
        // 可写状态，再次尝试发送
        bytes_written = socket->write_some(boost::asio::buffer(pData, nLength), ec);
        if (ec) {
            ReconnectToServer();
        }
    }
} else if (ec) {
    // 其他错误触发重连
    ReconnectToServer();
}

// 按需恢复阻塞模式
socket->non_blocking(false, ec);

async_write_some本身是异步操作，不会阻塞调用线程，能直接避免当前的阻塞问题，但它有个关键局限性：仅保证发起一次写操作，可能只发送部分数据（比如发送缓冲区剩余空间不足时），你需要在回调中检查发送字节数，循环调用async_write_some直到全部数据发送完成。

相比之下，Boost.Asio提供的async_write高层操作会自动处理部分发送的情况，持续发起写操作直到整个缓冲区数据发送完成，能减少手动处理的复杂度，更推荐使用。

另外，无论用async_write_some还是async_write，都必须配合deadline_timer实现超时逻辑，否则若接收端一直死锁，异步写操作会一直处于pending状态，无法主动触发重连。

1. 接收端死锁是根源问题，发送端的超时重连只是治标不治本，建议优先修复接收端的死锁问题，从根本上解决TCP窗口耗尽的情况。
2. 你提到重启发送端后仍卡在同一行，可能是旧连接资源未彻底释放，或新连接快速遭遇接收端死锁，超时重连逻辑能帮你自动从这种状态中恢复。

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