zeromq - sockets on steroids!
TRANSCRIPT
AGENDAOverview
Message OrientedDisconnectedAsyncBindings / Platforms
PatternsRequest / ReplyAsync Req /RepPub / SubPipelinePairing
OVERVIEW
C++ Implementation In-memory queueAtomic MessagesAPI for ZMTP Protocol
Zero copyMultipart messages support
OVERVIEWDisconnected Sockets
Background I/O to send/receiveQueues at sender and receiverAutomatic ReconnectMessage size limited by memory size
OVERVIEWProtocol Support with i nterchangeability
inproc: in memoryipc: inter processtcppgm/epgm: multicast
OVERVIEWWhat you will not have out of the box
Message Persistency (Pirate pattern)Data serialisation: use what ever you desire
msgpackjsonprotobuff...
Data compressionMessage encryptionSecurity Protocol
Include in the next version of ZMTP
APISocket Types
REQ: RequestREP: ReplyDEALER: Async Request/ReplyROUTER: RoutingPUB: PublisherSUB: SubscriberPUSH: Pipeline writerPULL: Pipeline consumer
API - NODE JS$ npm install zmq
$ node var zmq = require( 'zmq'); var socket = zmq.socket( 'rep'); socket.bind( 'inproc://queue'); // server socket.connect(<span style= "font-family: monospace; font-size: 19.274375915527344px; font-style: italic; font-variant: normal;" socket. on('message', function(frame1, frame2){}); socket. on('error',function(error){}); socket.send( 'something'); socket.send([ 'multipart1', 'multipart2']);<br>socket.close();
LINKS0MQ Guide
http://zguide.zeromq.org/page:all
0MQ Guide Examples
git clone --depth=1 git://github.com/imatix/zguide.git
PEDRO JANUÁRIO
THANKS!!!
http://shared-mind.tumblr.comhttps://www.linkedin.com/in/pjanuariohttps://twitter.com/prnjanuariohttps://github.com/pjanuario
COMING NEXT
ZMQ SOA SERVICE SUITE
http://pjanuario.github.io/zmq-service-suite-specs/