我是ZeroMQ的新手。我想创建多个发布者,其中每个发布者发布特定数据,例如:

1. Publisher 1:发布图像数据
2. Publisher 2:发布音频数据
3. Publisher 3:发布文本数据

基本上,我的要求是从多个发布者发布数据,并在另一侧使用多个接收器接收。

请参见下面的示例代码:

data_发布者。清洁石油产品

//  Prepare our context and all publishers
zmq::context_t context(1);
zmq::socket_t publisher1(context, ZMQ_PUB);
zmq::socket_t publisher2(context, ZMQ_PUB);
zmq::socket_t publisher3(context, ZMQ_PUB);
zmq::socket_t publisher4(context, ZMQ_PUB);

publisher1.bind("tcp://*:5556");
publisher2.bind("tcp://*:5557");
publisher3.bind("tcp://*:5558");
publisher4.bind("tcp://*:5559");

//  Initialize random number generator
srandom((unsigned)time(NULL));
while (1) {
    // sample data
    int zipcode1 = within(100000);
    int zipcode2 = within(100000);
    int zipcode3 = within(100000);
    int zipcode4 = within(100000);

    int temperature1 = within(215) - 80;
    int temperature2 = within(215) - 80;
    int temperature3 = within(215) - 80;
    int temperature4 = within(215) - 80;

    int relhumidity1 = within(50) + 10;
    int relhumidity2 = within(50) + 10;
    int relhumidity3 = within(50) + 10;
    int relhumidity4 = within(50) + 10;

    zmq::message_t message1(20);
    zmq::message_t message2(20);
    zmq::message_t message3(20);
    zmq::message_t message4(20);

    snprintf((char*)message1.data(), 20, "%05d %d %d", zipcode1, temperature1, relhumidity1);
    snprintf((char*)message2.data(), 20, "%05d %d %d", zipcode2, temperature2, relhumidity2);
    snprintf((char*)message3.data(), 20, "%05d %d %d", zipcode3, temperature3, relhumidity3);
    snprintf((char*)message4.data(), 20, "%05d %d %d", zipcode4, temperature4, relhumidity4);

    publisher1.send(message1);
    publisher2.send(message2);
    publisher3.send(message3);
    publisher4.send(message4);
}

data_接收器。清洁石油产品

zmq::context_t context(1);

//  Socket to talk to server
zmq::socket_t subscriber1(context, ZMQ_SUB);
zmq::socket_t subscriber2(context, ZMQ_SUB);
zmq::socket_t subscriber3(context, ZMQ_SUB);
zmq::socket_t subscriber4(context, ZMQ_SUB);

subscriber1.connect("tcp://localhost:5556");
subscriber2.connect("tcp://localhost:5557");
subscriber3.connect("tcp://localhost:5558");
subscriber4.connect("tcp://localhost:5559");

const char* filter = (argc > 1) ? argv[1] : "10001 ";
subscriber1.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter));
subscriber2.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter));
subscriber3.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter));
subscriber4.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter));

//  Process 100 updates
int update_nbr;
long total_temp1 = 0;
long total_temp2 = 0;
long total_temp3 = 0;
long total_temp4 = 0;

for (update_nbr = 0; update_nbr < 100; update_nbr++)
{
    zmq::message_t update1;
    zmq::message_t update2;
    zmq::message_t update3;
    zmq::message_t update4;
    int zipcode1, temperature1, relhumidity1;
    int zipcode2, temperature2, relhumidity2;
    int zipcode3, temperature3, relhumidity3;
    int zipcode4, temperature4, relhumidity4;

    subscriber1.recv(&update1);
    subscriber2.recv(&update2);
    subscriber3.recv(&update3);
    subscriber4.recv(&update4);

    std::istringstream iss1(static_cast<char*>(update1.data()));
    std::istringstream iss2(static_cast<char*>(update2.data()));
    std::istringstream iss3(static_cast<char*>(update3.data()));
    std::istringstream iss4(static_cast<char*>(update4.data()));

    iss1 >> zipcode1 >> temperature1 >> relhumidity1;
    iss2 >> zipcode2 >> temperature2 >> relhumidity2;
    iss3 >> zipcode3 >> temperature3 >> relhumidity3;
    iss4 >> zipcode4 >> temperature4 >> relhumidity4;

    total_temp1 += temperature1;
    total_temp2 += temperature2;
    total_temp3 += temperature3;
    total_temp4 += temperature4;
}

std::cout << "Average temperature for zipcode '" << filter << "' was "
          << (int)(total_temp1 / update_nbr) << "F" << std::endl;
std::cout << "Average temperature for zipcode '" << filter << "' was "
          << (int)(total_temp2 / update_nbr) << "F" << std::endl;
std::cout << "Average temperature for zipcode '" << filter << "' was "
          << (int)(total_temp3 / update_nbr) << "F" << std::endl;
std::cout << "Average temperature for zipcode '" << filter << "' was "
          << (int)(total_temp4 / update_nbr) << "F" << std::endl;

请注意,以上代码是获取建议/建议的示例代码。

我想知道它是否如上面的示例代码所示是一个好的选择?