Skip to:
#include <zmq.h>
voidmain () {
void*context = zmq_ctx_new ();void*server_socket = zmq_socket (context, ZMQ_PUSH);void*client_socket = zmq_socket (context, ZMQ_PULL);const intdata_size = 1000000;void*data = new char [data_size];
zmq_bind (server_socket, "tcp://127.0.0.1:5555");zmq_connect (client_socket, "tcp://127.0.0.1:5555");
for (int i = 0; i < 100; i ++) {
zmq_send (server_socket, data, data_size, ZMQ_SNDMORE);}
zmq_send (server_socket, data, data_size, 0);
zmq_close (client_socket);zmq_close (server_socket); zmq_ctx_destroy (context);}
msvc 2010
#include <zmq.h>
void
main () {
void*
context = zmq_ctx_new ();
void*
server_socket = zmq_socket (context, ZMQ_PUSH);
void*
client_socket = zmq_socket (context, ZMQ_PULL);
const int
data_size = 1000000;
void*
data = new char [data_size];
zmq_bind (server_socket, "tcp://127.0.0.1:5555");
zmq_connect (client_socket, "tcp://127.0.0.1:5555");
for (int i = 0; i < 100; i ++) {
zmq_send (server_socket, data, data_size, ZMQ_SNDMORE);
}
zmq_send (server_socket, data, data_size, 0);
zmq_close (client_socket);
zmq_close (server_socket);
zmq_ctx_destroy (context);
}