Guest User

ZMQ PUSH SUB client

a guest
May 20th, 2018
311
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
C++ 1.12 KB | None | 0 0
  1. #include <zmq.hpp>
  2. #include <zmq.h>
  3. #include <iostream>
  4. #include "zhelpers.hpp"
  5.  
  6. using namespace std;
  7.  
  8. int main(int argc, char *argv[])
  9. {
  10.     zmq::context_t context(1);
  11.     /*
  12.     std::cout << "Sending message to NM Server…\n" << std::endl; */
  13.  
  14.     zmq::socket_t subscriber(context, ZMQ_SUB);
  15.     subscriber.connect("tcp://localhost:5557");
  16.     subscriber.setsockopt(ZMQ_SUBSCRIBE, "", 0);
  17.  
  18.     zmq::socket_t sender(context, ZMQ_PUSH);
  19.     sender.connect("tcp://localhost:5558");
  20.  
  21.     string firstMessage = "Hola, soy el cliente 1";
  22.  
  23.     while (1)
  24.     {
  25.         //  Wait for next request from client
  26.         std::string string = s_recv(subscriber);
  27.  
  28.         std::cout << "Received request: " << string << std::endl;
  29.  
  30.         // Do some 'work'
  31.         // sleep(1);
  32.  
  33.         //  Send reply back to client
  34.         // zmq::message_t message(firstMessage.size() + 1);
  35.        
  36.         // Cualquiera de los dos se puede
  37.         // memcpy(message.data(), firstMessage.c_str(), firstMessage.size() + 1);
  38.         // s_send(sender, "Hola soy un responder 1");
  39.        
  40.         // sender.send(message);
  41.     }
  42. }
Advertisement
Add Comment
Please, Sign In to add comment