[ Nosql与大数据 ] [守望者大数据]ZeroMQ（ØMQ/ZMQ）网络库

2014-10-12 22:59| 发布者: watchmen | 查看: 1926 | 收藏

摘要: zeromq是一个快速的通讯库。“它提供一些跨多种传输协议（如进程内通讯、IPC、TCP和广播）的套接字供你使用。你可使用多种方式实现N对N的套接字连接，譬如：扇出、发布订阅、任务分发以及请求响应。”建立在 socket ...

zeromq是一个快速的通讯库。“它提供一些跨多种传输协议（如进程内通讯、IPC、TCP和广播）的套接字供你使用。你可使用多种方式实现N对N的套接字连接，譬如：扇出、发布订阅、任务分发以及请求响应。”建立在 socket 之上的 light-weight message queue。不再需要自己管理 tcp 分包。简单、实用。来自 iMatix 的一个库，iMatix 主要面向金融行业。（业务逻辑决定设计）

主要特点如下：

1) ZeroMQ交互是面向消息的。它将人们每天为应用程序周而复始地进行的例行消息处理封装起来。这意味着如果当客户端套接字发送一条150KB大小的消息时，服务端套接字无需显式处理任何缓存（buffer）或组帧，即能接接收到一条完整而相同的消息。

2) ZeroMQ套接字与传输协议无关：对于任何协议，只有单一且统一的发送消息和接收消息API。缺省情况下支持进程内通讯、IPC、广播和TCP。此外，协议间切换非常简单，仅需更改连接字符串的前缀即可。

3) ZeroMQ套接字能感知路由和网络拓扑。因为我们不再需要显示地管理点对点的连接状态——在上面我们已经看到，所有这些都已经由ZeroMQ库封装好——所以单个ZeroMQ套接字可以绑定两个独立的端口并监听他们的入站请求消息；也可使用一个API调用向两个独立的套接字发送数据。

4) 缺省情况下，ZeroMQ中所有的交互都是异步的。这种异步处理模型使得ZeroMQ能够将建立连接、销毁连接、重新连接的过程封装起来，同时又能实现消息传输延迟的最小化：非阻塞的含义是，应用中一般的消息处理都是并行进行的，如消息的发送、传输以及（在发送端或接收端）排队。当然，你也可以控制ZeroMQ的排队行为，只需要设定内存范围即可，甚至你还可以为每个套接字设定交换区域。所以，如果需要的话，你完全可以模拟阻塞式API，但是异步I/O是缺省的行为。