---
title: "TCP 配置与进阶使用"
---

> Documentation Index
> Fetch the complete documentation index at: https://openarkstudio.github.io/arknet/llms.txt
> Use this file to discover all available pages before exploring further.

# TCP 配置与进阶使用

[客户端](/arknet/zh/features/tcp/client)与[服务端](/arknet/zh/features/tcp/server)示例提供完整的启动、收发与关闭程序。以下配置在相应对象启动前应用，除非另有说明。

## 选择接收策略

行协议可在两端接收器启动时传入 `'\n'`，发送时自行携带终止符：

```cpp
server.start("127.0.0.1", 7000, '\n');
client.start("127.0.0.1", 7000, '\n');
client.async_send(std::string("command\n"));
```

回调数据包含 `\n`。还可以传入多字节分隔符或自定义 Asio 匹配条件。分隔符只控制读取，`async_send` 不会自动补上分隔符。不传接收策略时，应在应用缓冲区中累积字节，解析所有完整消息，并保留未完成的尾部。使用 `use_dgram` 时，无需自行添加长度前缀。

通过 `tcp_client(initial_bytes, maximum_bytes, workers)` 或对应的服务端构造函数设置接收缓冲区上限。应限制始终不完成一条消息的对端所能占用的缓冲区，并通过 `set_silence_timeout` 设置 session 空闲超时。

## 发送、重连与错误

在 `start` 前配置监听回调和容量限制。

使用客户端 `async_start(host, port, options...)` 可发起连接而不等待。返回值只表示发起结果；在 `bind_connect` 中通过 `get_last_error()` 读取最终结果，成功后再发送。

以下代码放在客户端启动之前：

```cpp
client.set_connect_timeout(std::chrono::seconds(10));
client.set_auto_reconnect(true, std::chrono::seconds(1));
client.set_max_send_buffer_size(1024 * 1024);
client.bind_disconnect([]
{
    std::cerr << arknet::get_last_error().message() << '\n';
});
```

```cpp
client.async_send(std::string("request"),
    [](const arknet::error_code& error, std::size_t bytes)
    {
        if (error)
            std::cerr << error.message() << '\n';
        else
            std::cout << "written: " << bytes << '\n';
    });
```

完成回调也可使用 `(bytes)` 或 `()` 签名，但这两种签名不提供错误参数。传入 `asio::use_future` 会返回 `std::future<std::pair<arknet::error_code, std::size_t>>`；只能在 IO 回调之外等待。立即拒绝时，完成回调可能在 `async_send` 返回前就在提交线程执行。被接受的操作在对象的 IO 通道完成。优先读取完成回调的错误参数；`get_last_error()` 是线程局部状态。

每个对象默认最多排队 16 MiB 负载和 1024 个操作。超出容量时返回 `no_buffer_space`。通过 `get_queued_send_buffer_size()` 观察排队字节数，在队列满时暂停生产者，避免在 IO 回调中循环重试。重连不会重放旧发送；需要重试业务请求时，应设计请求 ID 和应答确认机制。

## 自定义 session 与外部 IO

```cpp
class peer_session : public arknet::tcp_session_t<peer_session>
{
public:
    using arknet::tcp_session_t<peer_session>::tcp_session_t;
    std::string user_id;
};

arknet::tcp_server_t<peer_session> server;
```

在 session 的 IO 通道访问业务状态，跨通道访问时进行同步。需要保存接收数据或提交到 CPU executor 时，应先复制 view。在接收回调内调用 `async_send(bytes)` 时，被接受的发送操作已经持有负载。

使用外部调度器时，将 `asio::io_context&` 传给客户端或服务端构造函数。阻塞式 `start` 前，应启动 context 的运行线程并保留 work guard。只传入一个 context 的服务端共享一个执行通道。`std::vector<asio::io_context*>` 中的多个条目提供独立串行通道，即使条目指向同一个 context。完整规则见 [IO 模型](/arknet/zh/concepts/io-models)。

在外部 context 仍运行时，由所有者线程调用 `stop()` 或 `wait_stopped()`。IO 回调内使用 `request_stop()`，随后由所有者线程等待完成。`wait_stopped()` 会拒绝 IO 工作线程内的调用。先停止并销毁网络对象，再释放 work guard、等待运行线程退出。

另见[生命周期测试](https://github.com/OpenArkStudio/arknet/blob/main/tests/lifecycle.cpp)、[TCP 测试](https://github.com/OpenArkStudio/arknet/blob/main/tests/tcp.cpp)及[性能](/arknet/zh/features/tcp/performance)。

Source: https://openarkstudio.github.io/arknet/zh/features/tcp/configuration/index.mdx