TCP 流服务：裸字节世界的三个回调

本章导读

23.1 引入

HTTP 的价值是"约定了请求长什么样"；TCP 的价值是"什么都没约定"。于是宿主对 TCP 的职责收缩到三件事：建流、给数据、报告终态——协议设计权完整地留给你。TLS（tcps）只是把流的加密层接上，回调面完全一致。

23.2 视图与回调

/* XS_StreamConn：tcp 与 tls 二选一非空（tcps 下禁止绕过 tls 直写）*/
static void EventOpen(XS_HostInfo* pHost, XS_StreamConn* pConn);
static void EventData(XS_HostInfo* pHost, XS_StreamConn* pConn, xnetbuf* pBuffer);
static void EventClose(XS_HostInfo* pHost, XS_StreamConn* pConn,
    xnetresult iResult, const xerror* pError);

• EventOpen：连接建立——发欢迎横幅、建会话上下文的时机
• EventData：数据到达。pBuffer 是零拷贝缓冲链（回调内借用）：尺寸 xrtNetBufSize(pBuffer)，数据经 xrt 缓冲迭代 API 消费——它不是一块连续内存，别当 char* 用
• EventClose：终态——iResult 给网络层结论，pError 给错误详情（可为 NULL）
• 发送：xrtNetStreamSend(pConn->tcp, ...) / xrtTlsStreamSend(pConn->tls, ...) 按非空一侧

23.3 横幅与 echo

static void EventOpen(XS_HostInfo* pHost, XS_StreamConn* pConn)
{
    if ( pConn->tcp != NULL )
        (void)xrtNetStreamSend(pConn->tcp, "hello\n", 6);
    /* tcps：改判 pConn->tls + xrtTlsStreamSend（查 written）*/
}

static void EventData(XS_HostInfo* pHost, XS_StreamConn* pConn, xnetbuf* pBuffer)
{
    /* echo：把收到的数据原路发回。
     * 真实实现：遍历缓冲链的每个 block 逐段 Send；
     * 尺寸查询：xrtNetBufSize(pBuffer) */
}

$ telnet 127.0.0.1 9000
hello
（你输入的每行被原样回显）

刚才发生了什么：连接即横幅是很多文本协议（SMTP/FTP/IRC）的惯例；echo 是流服务的"hello world"。真实协议（帧头 + 长度 + 体）在此之上加一个状态机——ch33 的 XTP2 就是现成的帧库。

23.4 生命周期与限额

• 连接生命周期宿主持有：Accept 接管 → 注册表 → Close 时析构——应用不 Destroy 连接（与 custom 类"一切手动"的区别）
• SNI：tcps 下 host 级证书构建 SNI 表，每连接按 SNI 出证书
• idle_timeout：空闲到点服务端主动关闭（func_test 有 4.5s 关闭的实测用例）
• recv_limit：小于默认读块时同步收缩读尺寸（避免配置引发泛化失败）
• 会话上下文：与 WS 同构——自建注册表（连接 → 上下文），Open 建、Close 删

23.5 契约

• 借用线：pConn/pBuffer/pError 回调内有效；缓冲链数据当帧消费，不当持久存储。
• 方向线：tcps 下禁止绕过 tls 直写 tcp——明文字节会被对端当作 TLS 记录噪音。
• 生命周期线：连接归宿主；你的会话上下文归你，Close 终态清理。

常见错误

编程练习