CZMQ设置发送/接收HWM及缓冲区大小相关问题咨询

• 配置时机错误：ZMQ所有套接字参数都必须在绑定/连接操作之前设置，先调用zsock_bind/zsock_connect再设置HWM，配置会直接失效，这是最常见的错误原因。
• 未同步配置对端HWM：TCP、IPC等跨进程传输场景下，实际生效的HWM是发送端sndhwm和接收端rcvhwm的最小值，仅修改单端配置会出现不生效的错觉。
• 套接字类型特性影响：PUB、ROUTER这类多对等端的套接字，HWM是针对单个对等端单独计数的，并非全局待发送消息总量。例如PUB端设了20的HWM，同时有5个订阅者时，总待发送消息上限为100，容易被误认为HWM配置失效。
• 传输层规则差异：inproc进程内传输仅识别绑定端的HWM配置，连接端设置的HWM会被直接忽略；你测试用inproc场景符合规则所以生效，切换到TCP/IPC场景时如果不调整双端配置就会出现异常。
• 内核缓冲区限制：如果设置的HWM对应的总消息大小超过了套接字sndbuf/rcvbuf的大小，内核缓冲区会先触发限流，表现为HWM未生效。

配置顺序要求 #

必须严格按照「创建套接字→配置所有参数→绑定/连接」的顺序操作，示例如下：

#include <czmq.h>
#include <string>

int main(void) {
    // 1. 先创建空套接字
    zsock_t *sockout = zsock_new_pub(NULL);
    // 2. 配置参数，HWM单位为消息数，缓冲区单位为字节
    zsock_set_sndhwm(sockout, 20);
    zsock_set_sndbuf(sockout, 4096); // 根据单条消息大小*HWM调整，避免内核缓冲区不足
    // 3. 最后执行绑定/连接
    zsock_bind(sockout, "tcp://*:5555");

    std::string data2send;
    for (size_t i = 0; i < 1000; i++){
        data2send = "data" + std::to_string(i);
        zsock_send(sockout, "s", data2send.c_str() );
    }
    zsock_destroy(&sockout);
    return 0;
}

分场景配置规则 #

• 进程内inproc通信：仅在绑定套接字的一侧设置收发HWM即可，连接端无需重复配置。
• 跨进程TCP/IPC通信：发送端和接收端同步设置相同的HWM值，发送端配置sndhwm，接收端配置rcvhwm，避免取最小值导致配置不符合预期。
• 多对等端场景：如果使用PUB、ROUTER等多连接套接字，根据实际对等端数量计算总待发消息上限，调整HWM值到符合业务要求的范围。

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