为什么我的 C++ ZeroMQ 订阅者收不到任何数据？

Question

我的（Python）发布者：

import zmq
import time

context = zmq.Context()
socket = context.socket(zmq.PUB)
connectStr = "tcp://*:%d" % 5563
socket.bind(connectStr)

messageNum = 0
while True:
    ++messageNum
    message = "Testing %d"%messageNum
    print("Sending.. '%s'"%message)
    socket.send_string(message)
    time.sleep(1)
    messageNum += 1

我的 (C++) 订阅者（运行ning 在 GTest 中）：

TEST(ZeroMqPubSubTest, SubscribeGetsData)
{

    // Set up the subscriber we'll use to receive the message.
    zmq::context_t context;
    zmq::socket_t subscriber(context, ZMQ_SUB);
    // Connect to the publisher
    subscriber.connect("tcp://127.0.0.1:5563");
    subscriber.setsockopt(ZMQ_SUBSCRIBE, ""); // Set the filter blank so we receive everything

    zmq::message_t response(0);
    EXPECT_TRUE(subscriber.recv(&response));
}

我先启动发布者，然后再启动订阅者。后者从来没有returns。

如果我运行一个 Python 订阅者在做（我认为）完全相同的事情..

import zmq

context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect ("tcp://127.0.0.1:5563")
socket.setsockopt_string(zmq.SUBSCRIBE, "")

print ("Waiting for data...")
while True:
    message = socket.recv()
    print ("Got some data:",message)

..它工作正常：

Waiting for data...

Got some data: b'Testing 8'

Got some data: b'Testing 9'

Answer 1

在zmq.hpp中定义了两个setsockopt的重载：

 template<typename T> void setsockopt(int option_, T const& optval)
 {
     setsockopt(option_, &optval, sizeof(T) );
 }

 inline void setsockopt (int option_, const void *optval_, size_t optvallen_)
 {
     int rc = zmq_setsockopt (ptr, option_, optval_, optvallen_);
     if (rc != 0)
         throw error_t ();
 }

通过仅提供两个参数，您隐含地使用了第一个重载，它假定值长度为 sizeof(T)。这解析为一个，因为 "" 是一个 zero-terminated 字符数组。要传入空字符串，您需要使用第二个重载并指定长度为 0:

subscriber.setsockopt(ZMQ_SUBSCRIBE, "", 0);

或者，使用零大小数据类型：

char none[0];
subscriber.setsockopt(ZMQ_SUBSCRIBE, none);

为什么我的 C++ ZeroMQ 订阅者收不到任何数据？

Why does my C++ ZeroMQ subscriber not receive any data?

python

c++

zeromq