c++ - ZeroMQ——尝试在 C++ 中运行 asyncsrv 时为 "Socket operation on non-socket"

Question

我一直在尝试使用 C++(使用 cppzmq 绑定(bind))使用 ZeroMQ 运行异步服务器。我的文件编译正常，但我在 zmq::error_t 类型的运行时出现错误:“非套接字上的套接字操作”。

Here's the file that's apparently giving the error.我在 asyncsrv example 之后建模来自“ZeroMQ:指南”，修复了示例中的一些错误(例如出于某种原因尝试 std::bind 到 vector )。

如果需要，这是我的 class definitions for the related source file .

代码拷贝:

#include "worker.hpp"

void SkidooshBrokerTask::run() {
    frontend.bind("tcp://*:20401");
    backend.bind("inproc://backend");

    std::vector<SkidooshBrokerWorker *> workers;
    std::vector<std::thread *> worker_threads;

    for (int i=0; i<kMaxThread; ++i) {
        workers.push_back(new SkidooshBrokerWorker(ctx,ZMQ_DEALER));
        worker_threads.push_back(new std::thread(std::bind(&SkidooshBrokerWorker::work, workers[workers.size()-1])));
        worker_threads[worker_threads.size()-1]->detach();
    }

    try {
        zmq::proxy(&frontend,&backend,nullptr);
    } catch (std::exception &e) {

    }

    for (int i=0;i<kMaxThread; ++i) {
        delete workers[i];
        delete worker_threads[i];
    }
}

void SkidooshBrokerWorker::work() {
    wk_sck.connect("inproc://backend");        
    try {
        while (true) {
            zmq::message_t identity;
            zmq::message_t msg;
            zmq::message_t copied_id;
            zmq::message_t copied_msg;
            std::string rq_str;
            wk_sck.recv(&identity);
            wk_sck.recv(&msg);

            rq_str = std::string(static_cast<char *>(msg.data()),msg.size());
            copied_id.copy(&identity);
            copied_msg.copy(&msg);
        }
    } catch (std::exception &e) {}
}

Answer 1

我知道这是一个迟到的答案。但是我在使用 zmq::poll() 时出现了同样的错误。

你可以尝试改变

try 
{
    zmq::proxy(&frontend,&backend,nullptr);
} catch (std::exception &e) {}

到

try 
{
    zmq::proxy((void*)(&frontend),(void*)(&backend),nullptr);
} catch (std::exception &e) {}

引用:更多详情请查看this线程。