Skip to content

Instantly share code, notes, and snippets.

@Su-Shee
Created September 21, 2015 18:14
Show Gist options
  • Save Su-Shee/e0ec15df21619be1a9aa to your computer and use it in GitHub Desktop.
Save Su-Shee/e0ec15df21619be1a9aa to your computer and use it in GitHub Desktop.
#server
#!/usr/bin/env perl
use strict;
use warnings;
use feature 'say';
use ZMQ::LibZMQ4;
use ZMQ::Constants qw/:all/;
my $ctxt = zmq_init;
my $socket = zmq_socket( $ctxt, ZMQ_PUB);
zmq_bind( $socket, "tcp://127.0.0.1:9999" );
while (1) {
say "sending...";
my $howmuch = zmq_msg_send( "HELLO HELLO HELLO", $socket );
say "sent: $howmuch";
sleep(5);
}
#client
#!/usr/bin/env perl
use strict;
use warnings;
use feature 'say';
use ZMQ::LibZMQ4;
use ZMQ::Constants qw/:all/;
my $ctxt = zmq_init;
my $socket = zmq_socket( $ctxt, ZMQ_SUB);
zmq_connect( $socket, "tcp://127.0.0.1:9999" );
zmq_setsockopt( $socket, ZMQ_SUBSCRIBE, '' );
my $msg = zmq_msg_init();
say "receiving...";
say zmq_msg_recv( $msg, $socket );
say zmq_msg_data( $msg );
say "got it!";
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment