Zeromq Sockets,messages,patterns

socket 概念
message
- IO Thread
- 4 message patterns

socket 概念

zmq_socket()
zmq_close()

zmq_setsockopt()
zmq_getsockopt()

zmq_bind()
zmq_connect()

zero mq 的 socket 不同与 raw socket 的 socket,可理解为 socket 的本质是一个实现了异步的消息队列抽象实体,它的特点:

socket 底下可以维持多个 ougoing or incoming connections.

no zmq_accpet() method

client 可以先与 server 建立;

Clients and servers can connect and bind at any time, can go and come back, and it remains transparent to applications.

尽管模糊了 server 与 client,但是 server 仍然是固定 addr 的一方，client 仍然是动态变化的一方.

基本网络类型有: inproc, ipc,tcp,pgm,egpm

socket 类型决定了它是怎么 routing,queueing messages 的.

对于 inporc, server 必须先 bind.

a socket 可以 bind 多个不用的网络类型,但是同一类型的 port 不能绑定多次，只有 ipc 是例外.

zmq_bind (socket, "tcp://*:5555");
zmq_bind (socket, "tcp://*:9999");
zmq_bind (socket, "inproc://somename");

zmq_bind (socket, "ipc://s1");
//表示如果前面的s1挂掉，后面的s1作为备份.
zmq_bind (socket, "ipc://s1");
// bind后也可以connect
zmq_connect (socket, "ipc://s2");

message

socket 的传输的基本类型是 message frame,不再是 raw binary.

zeromq 可以理解在 tcp 上的封装,和 http 一个级别，再封装下可以实现任何协议.

具体的 ZMTP 内容

IO Thread

messages 在收发两端的 buffer io 都是做好的. 每个 socket 有一个 IO Thread 处理 IO.,就是最开始的 zmq_ctx_new()创造出来的.比如 send,不是 send 结束就发送完毕了，可能正在 io 缓冲中.

定义多个 IO thread:

int io_threads = 4;
void *context = zmq_ctx_new ();
zmq_ctx_set (context, ZMQ_IO_THREADS, io_threads);
assert (zmq_ctx_get (context, ZMQ_IO_THREADS) == io_threads);