ZMQCPP 使用 socket_t 作为类变量

Question

我正在创建一个类来处理我可以在多个不同项目中使用的 ZMQCPP。我想让 context_t 和 socket_t 成为一个类变量，所以我不必将它们作为参数传递给不同的函数（我目前所做的）。但我不断收到错误，不确定这是否可能。

我查看了 zmq.hpp 文件，没有看到 socket_t 类的“默认”空构造函数，而无需上下文和套接字类型。

任何意见或指导将不胜感激。

这是我目前的班级设置

#include "zmq_addon.hpp"
#include <zmq.h>

#define DEFAULT_IP "tcp://127.0.0.1:"
#define DEFAULT_PORT 5555

class zmqClientTCP {
    public:
        zmqClientTCP();                     // Default Constructor
        ~zmqClientTCP();                    // Deconstructor
        int setAddress(std::string);        // Changes the IP Address. 
        int setPortNumber(int);             // Change port number explicitly
        int setSocketType(int);             // Change the socket type
        int connect();                      // Connects 
        void disconnect();                  // Disconnects from active connection
        void sendMessage(std::string*);     // Send Message over connection. 

    private:
        std::string ipAddress = "";         // Holds the IP Address
        int portNum = -1;                   // Holds port number
        int sockType = ZMQ_SUB;             // Set socket type for ZMQ connection
        const zmq::context_t context;       // ZMQ Context for single thread
        zmq::socket_t socket;               // ZMQ Socket 
        bool isConnected = false;           // Bool for connection. 
};

类实现：（我想做的）

int zmqClientTCP::connect() {
    socket(context, sockType);
    socket.connect(ipAddress);

    // MONITOR IMPLEMENTATION HERE

    if(isConnected)return 1;

    return 0
}

void sendMessage(std::string msg){
    zmq::message_t zOut(msg);
    socket.send(zOut, zmq::send_flags::none);
}

void zmqClientTCP::disconnect() {
    socket.disconnect(ipAddress);
}

类实现（我目前所做的）：

int zmqClientTCP::connect() {
    zmq::context_t context;
    zmq::socket_t socket(context, sockType);
    socket.connect(ipAddress);
    std::string temp

    /*   MONITOR IS HERE TO TRIGGER isConnected BOOL */

    while(isConnected){
       temp.clear();
       std::getline(std::cin, temp);
       sendMessage(socket, temp);
    }

    disconnect(socket);

    return 1;
}

void sendMessage(zmq::socket_t &socket, std::string msg){
    zmq::message_t zOut(msg);
    socket.send(zOut, zmq::send_flags::none);
}

void zmqClientTCP::disconnect(zmq::socket_t &socket) {
    socket.disconnect(ipAddress);
}

Answer 1

对于遇到此问题的任何人；通过使用 ZMQ C++ API 功能，我能够实现我的愿望。你需要“zmq_addons.hpp”。

class zmqClientTCP {
public:
    zmqClientTCP();                     // Default Constructor
    ~zmqClientTCP();                    // Deconstructor
    void connect();                     // Connects to address
    void disconnect();                  // Disconnects from active connection
    void sendMessage(const std::string*);// Send string over connection. 
    void sendMessage(const char*);      // Send c style string over connection. 
    void recvMessage(std::string*);     // Recv message over connection. 

private:
    void* context;                      // ZMQ Context for single thread
    void* socket;                       // ZMQ Socket 
    char buffer[256];                   // Buffer for message receiving
};

这是伴随课程的基本功能。

void zmqClientTCP::connect() {
    context = zmq_ctx_new();
    socket = zmq_socket(context, ZMQ_REQ);
    zmq_connect(socket, ipAddress+PortNum);
}

void zmqClientTCP::sendMessage(const std::string* msg) {
    zmq_send(socket, _strdup(msg->c_str()), strlen(msg->c_str()), 0);
}

void zmqClientTCP::sendMessage(const char* msg) {
    zmq_send(socket, _strdup(msg), strlen(msg), 0);
}

void zmqClientTCP::recvMessage(std::string* msg) {
    // Clear buffer 
    memset(buffer, '\0', sizeof(buffer));
    // Recv message from zmq into the buffer 
    zmq_recv(socket, buffer, sizeof(buffer), 0);
    // Convert buffer to string
    std::string temp(buffer);
    // Assign temp string to inbound string parameter. 
    msg->assign(temp);
}

void zmqClientTCP::disconnect() {
    zmq_close(socket);
    zmq_term(context);

}

然后你可以像这样编写简单的类实现：

zmqClientTCP zmqClient;
zmqClient.connect();
std::string msgOut = "Hello World";
zmqClient.sendMessage(&msgOut);
std::string msgIn = "";
zmqClient.recvMessage(&msgIn);
zmqClient.disconnect();