2

我正在使用（客户端）REQ->ROUTER（路由器）<-ROUTER（工人）套接字方案。

我可以将客户端请求发送给特定的工作人员，但无法将响应发送回客户端，因为它是一个REQ套接字，因此客户端挂起等待响应。

尝试了很多但未能解决。

客户端.cpp

#include "zhelpers.hpp"
#include <string>

int main (int argc, char *argv[])
{
    zmq::context_t context(1);
    zmq::socket_t requester(context, ZMQ_REQ);
    requester.setsockopt(ZMQ_IDENTITY,"M");
    requester.connect("tcp://localhost:5559");

    for( int request = 0 ; request < 10 ; request++) {
        std::string cmd;
        std::cin>>cmd;
        s_sendmore (requester, "B");//addressing workers
        s_sendmore (requester, "");
        s_send (requester, cmd);
        s_dump(requester);
    }
}

路由器.cpp

#include "zhelpers.hpp"
int main(int argc, char *argv[]) {
    zmq::context_t context(1);
    zmq::socket_t frontend(context, ZMQ_ROUTER);
    frontend.setsockopt(ZMQ_ROUTER_MANDATORY, 1);

    frontend.bind("tcp://*:5559");

    zmq::pollitem_t items[] = {
            {frontend, 0, ZMQ_POLLIN, 0}
    };

    while (1) {
        zmq::message_t source;
        zmq::message_t empty1;
        zmq::message_t destination;
        zmq::message_t empty2;
        zmq::message_t message;
        int more;
        zmq::poll(&items[0], 1, -1);
        std::cout << "DEBUG MSGS NOT PRINTING";// Another issue
        if (items[0].revents & ZMQ_POLLIN) {
            while (1) {

                //  Process all parts of the message

                frontend.recv(&source);
                frontend.recv(&empty1);
                frontend.recv(&destination);
                frontend.recv(&empty2);
                frontend.recv(&message);
                size_t more_size = sizeof(more);
                frontend.getsockopt(ZMQ_RCVMORE, &more, &more_size);
                frontend.send(destination, ZMQ_SNDMORE);
                frontend.send(empty1, ZMQ_SNDMORE);
                frontend.send(source, ZMQ_SNDMORE);
                frontend.send(empty2, ZMQ_SNDMORE);
                frontend.send(message);
                if (!more)
                    break;
            }}}
    return 0;
}

中的cout语句router.cpp也不打印，原因未知？

工人.cpp

#include "zhelpers.hpp"
int main (int argc, char *argv[])
{
    zmq::context_t context(1);
    zmq::socket_t responder(context, ZMQ_ROUTER);
    responder.setsockopt(ZMQ_IDENTITY, "B", 1);
    responder.connect("tcp://localhost:5559");

    while(1)
    {
        s_dump(responder);  
        sleep (1);
        s_sendmore (responder, "B");
        s_sendmore (responder, "");
        s_sendmore (responder, "M");
        s_sendmore (responder, "");
        s_send (responder, "FromSlaveB");
    }}

我在 Ubuntu 16.04 上，当前 0MQ 版本是 4.0.5

4

1 回答 1

1

更简单的部分 - 为什么cout从不执行：

ZeroMQ API 规范的简要检查告诉您：

int zmq_poll (zmq_pollitem_t *items, int nitems,long timeout );
...
如果timeout的值为 -1，zmq_poll()则应无限期地阻塞，直到至少一个请求的事件发生zmq_pollitem_t。

因此，为此，检查 API 文档就足够了（Martin SUSTRIK 自 v2.1.x 的早期版本以来已经花费了一些时间）。

其余的在REQ-ROUTER-ROUTER

为了简单起见，首先使用一个标准的、有据可查的场景来启动和原型化任何软件——无论是REQ-REP( XREQ-XREP)== ROUTER-DEALER还是任何其他记录在案的可扩展正式通信模式原型，然后再进入更复杂的多套接字和多方复合阻塞和非阻塞高级消息传递和信令场景的混合，形成了一些理想的但高度高级的功能组合。

如果可能，请按照您的几个问题中的其他问题中的建议阅读整本书，然后再询问另一个未经测试或不受支持的设置，而不是在掌握这些琐碎的用例之前不要跳入内容，这本书有助于理解并以此为基础。

Post Festum：如果出现问题，cout则不打印

1）在下面测试这个
2）将观察到的输出作为另一个问题发布在 S/O 上#READYTOHELP：

router_a_proof_of_print.cpp

#include "zhelpers.hpp"
int main( int argc, char *argv[] ) {
    std::cout << "DEBUG: [PASS|FAIL] ON AN ATTEMPT TO PRINT"; // Another issue
    return 0;
}
于 2017-06-20T03:35:03.270 回答