c++ - ZMQ导致主线程卡住(或类似..？)

我有以下一段c++代码，它们打开ZMQ-subscriber-socket并在无限循环中接收消息。
listener.cc :(代码应该可以工作，并使用g++ -lzmq listener.cc进行编译)

#include <iostream>
#include <zmq.hpp>

class Listener {
public:
    Listener() {
        std::cout << "constructor call" << std::endl;

        // Not working:
//        zmq::context_t context(1);
//        sck = new zmq::socket_t(context, ZMQ_SUB);
//        sck->connect("tcp://127.0.0.1:9999");
//        sck->setsockopt( ZMQ_SUBSCRIBE, "", 0);

        std::cout << "constructor end" << std::endl;
    }

    void run() {
        // Ok:
        zmq::context_t context(1);
        sck = new zmq::socket_t(context, ZMQ_SUB);
        sck->connect("tcp://127.0.0.1:9999");
        sck->setsockopt(ZMQ_SUBSCRIBE, "", 0);

        while (1) { // Receive messages, not interesting:
            std::cout << "listening..." << std::endl;
            zmq::message_t message;
            sck->recv(&message);
            std::cout << "received something" << std::endl;
        }
    }
    zmq::socket_t *sck;
};

int main(int argc, char *argv[]) {
    Listener listener;
    std::cout << "foo" << std::endl;
    listener.run();
    return 0;
}

到目前为止，该代码可以按预期工作:

$ g++ -lzmq listener.cc
$ ./a.out
constructor call
constructor end
foo
listening...

但是，我想将zmq-context/socket的初始化移到类的构造函数中(被注释掉的部分)。但是然后代码根本不会从构造函数调用中返回，构造函数内部的所有语句都将被执行，但是main的第二行未执行，并且程序将卡住。输出为:

$ g++ -lzmq listener.cc
$ ./a.out
constructor call
constructor end

我唯一想到的是主线程由于某种原因而停止执行。谁能解释一下并提供解决方案？

干杯

最佳答案

谁能解释一下并提供解决方案？双方都同意...

ZeroMQ在引擎盖下将每个Context( nIOthreads = 1 )实例用作功能强大的引擎，因此必须格外小心，这样资源管理过程就不会感到惊讶(因为阻塞/冻结就是这种情况)。

如果存在一些活跃使用的套接字实例(在Context()-instance的幕后进行管理)，则可能会出现这样的情况，即在进入析构函数处理阶段之前，或者如果进行了某种操作，并非所有传输都已完成手动尝试执行类似的步骤，以尝试对此类套接字实例进行.close()和/或对Context-instance进行.term()。

人们有意无意地闯入了很多次。

ZeroMQ native API文档在此主题上非常清楚，并警告存在风险，即尚未完成的低级事务可能使一个人的代码无限期地等待外部事件(远程代理操作)，该事件永远不会出现。这种不了解的代码看起来像是冻结/挂起的故障，但是由于人们未能意识到这种风险并且没有采取适当的预防措施而陷入了确定性的情况。

尽管较新的API版本已更改了一些默认设置，但我主张所有用户明确设置安全配置，即使较新的默认设置可以避免手动执行此操作的需要。但是，这种做法有助于提高人们对在distributed-system设计实践中应考虑哪种碰撞的认识。

解决方案？始终为.setsockopt( ZMQ_LINGER, 0 );


如上所述，这是每个套接字实例的经验法则。

class Listener {
   // zmq::context_t aClassLocalCONTEXT;              // MAY GET SET LOCAL CTX BY VALUE
   // zmq::socket_t  aClassLocalSOCKET;               // MAY GET SET LOCAL SCK BY VALUE EITHER
      zmq::socket_t  *sck;

public:
    Listener() {
        std::cout << "constructor call" << std::endl;

     // zmq::context_t context(1);                    // not a best practice here
     // ---------------------------------------------------
     // sck = new zmq::socket_t( aClassLocalCONTEXT, ZMQ_SUB );
        sck = new zmq::socket_t( context, ZMQ_SUB );
        sck->setsockopt( ZMQ_LINGER, 0 );             // ALWAYS, best before .bind()/.connect()
        sck->connect(   "tcp://127.0.0.1:9999" );
        sck->setsockopt( ZMQ_SUBSCRIBE, "", 0 );
     // ----------------------------------------------// IF SETUP BY AN INSTANTIATION CALL INTERFACE
     // aClassLocalSOCKET->setsockopt( ZMQ_LINGER, 0 );
     // aClassLocalSOCKET->connect(    ... );
     // aClassLocalSOCKET->setsockopt( ZMQ_SUBSCRIBE, "", 0 );
     // ---------------------------------------------------
        std::cout << "constructor end" << std::endl;
    }
   ~Listener() {
        sck->close();                                 // A GOOD PRACTICE
     // ----------------------------------------------// IF SETUP BY AN INSTANTIATION CALL INTERFACE
     // aClassLocalSOCKET->close();
    }
    void run() {
        while (1) {                                   // recv()-messages, not interesting:
            std::cout << "listening..." << std::endl;
            zmq::message_t message;
            sck->recv(&message);
            std::cout << "received something" << std::endl;
            zmq::zmq_msg_close(&message);             // A GOOD PLACE TO DISCARD A NEVER MORE USED RESOURCE
        }
    }
};


int main(int argc, char *argv[]) {
    zmq::context_t context(1);                        // GLOBAL CTX
    Listener listener;
    std::cout << "foo" << std::endl;
    listener.run();
    return 0;
}

高效的资源减少了管理费用

资源的智能处理非常重要，因为每个实例化和销毁都会在[TIME] -domain和[SPACE] -domain中承担成本(内存分配/解除分配成本，又是及时的)，而且这两种都不便宜。

再加上一个应该遵循ZeroMQ Zen的零-不共享任何内容(嗯，有时共享Context()实例是一种方法，但是...如果您认真地考虑distributed-system设计，最好阅读一本伟大的Pieter HINTJENS的书，“已连接的代码:第1卷”，绝对值得您付出时间和精力。