ZMQ专题学习之一：初识ZeroMQ
ZeroMQ号称是“史上最快的消息队列”，基于c语言开发的。引用官方说明定义：“ZMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层，像框架一样的一个socket library，他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。
ZMQ的明确目标是“成为标准网络协议栈的一部分，之后进入Linux内核”。是极具前景的并且是人们更加需要的“传统”BSD套接字之上的一层封装。ZMQ让编写高性能网络应用程序极为简单和有趣。相比较它跟RabbitMQ、ActiveMQ之类的MQ，有着相当本质的区别，其原因在于ZeroMQ根本就不是一个消息队列服务器，更像是一组底层网络通讯库，对原有的Socket API加上一层封装，是我们操作更简便。使用时只需要引入相应的jar包即可。
ZeroMQ与其他MQ类似，也实现了三种
最基本的工作模式：发布-订阅、请求-应答、管道。
ZeroMQ特点
1.嵌入式消息组件
ZeroMQ就像是一个嵌入在操作系统内的一个组件，说白了ZeroMQ就是一组jar包，直接嵌入到项目中就可以运行，它不需要一台独立的服务器来承载整个消息系统。ZeroMQ关注的不是消息的可靠送达，而是着眼于端到端的发送，接收…它希望的是尽快完成任务，而不介意部分消息的丢失。但这也并不是说他完全没有持久化的功能，ZeroMQ是具有一定的本地持久化的功能的，但是能保存的数据量比较有限，而且是暂存于内存中的。
2. 高效的处理速度
由于ZeroMQ的定位以及对消息的处理方式。ZeroMQ对于消息的处理可以说除却请求-应答模式之外，基本就是不关注消息是否丢失，它只管发送。ZeroMQ的定位ZeroMQ融入到Linux内核中去。基于这两点，高效的处理速度就成了它必不可少的特点之一。
3.多核下的线程绑定
传统的多线程并发模式一般会采用锁、临界区、信号量等技术来控制，而ZeroMQ采取的策略是：在创建IO时不要超出CPU核数。当创建一个上下文时都会采用代码“Context context = ZMQ.context(1);”这里就指定了IO线程数。通常情况下一个线程足矣。但是如要创建多个IO线程，最好不要超出CPU核数，因为此时ZeroMQ会将工作线程其实就是那个Poller绑定到每一个核，避免了线程上下文切换带来的开销。
鉴于上面的特点，下面进行TPS、并发性、持久化、技术点以及扩展性这几个方面与其他MQ产品进行对比：
1.TPS
上图显示的是每秒钟发送和接受的消息数。整个过程共产生1百万条1K的消息，从测试数据可以看出，ZeroMQ的性能远远高于其它3个MQ。或者说ZeroMQ与其他3各MQ根本就不再一个量级上比较了。
2.持久化消息比较
ZeroMq原生是不支持持久化的，仅支持相当有限的本地缓存，如需要消息持久化需要自己进行扩展。
而ActiveMq和rabbitMq等MQ都支持。
3.并发性
虽然ZeroMQ在高并发环境下不会出问题，但是有可能会导致本地的缓存区被塞满而导致消息丢失的情况。所以不推荐在并发量较高的情境下使用ZeroMQ。而ActiveMQ在发送到queue的消息并发较多时，消费端只能接收一部分，比如100条消息在较短的时间内发入，总有10来条接收不到，存放在服务器上，而且这些消息一直不能主动发送出来，后面继续进入的消息都能正常处理，最终只有重新启动服务消费端才能接收到那部分剩下的消息。而RabbitMQ，从实现语言来看，它是并发性最好的，原因是它的实现语言是天生具备高并发高可用的erlang语言。
4.技术点以及扩展性
就扩展性而言，毫无疑问的是ZeroMQ最强，其余其中MQ都已经是成形的产品，已经是一款应用程序了。而ZeroMQ说白了就是一组库函数。基于这种情况，开发者可以按自己的需要实现IPollEvent以及ZObject来开发适合自己的Socket组件，至于它对于消息持久化的不支持，只是原生不支持，因为它的定位不是只保证可靠的消息传输。所以在可靠性这部分我们完全可以按自己的需求进行扩展。
一组lib的扩展度明显是宽于产品级的rabbitMQ之类的产品。技术上虽然ZeroMQ立志于成为Linux内核的消息组件，但是不得不说它的开源社区活跃度是远远不及RabbitMQ或者ActiveMQ。或许是处于它的可靠性考虑，它的应用场景比较受限制。
可靠性上虽然ActiveMQ也具备，只是性能上相比于RabbitMQ还是有一定差距，所以大部分的MQ选型都是RabbitMQ。
ZMQ专题学习之一：初识ZeroMQ ZeroMQ号称是“史上最快的消息队列”，基于c语言开发的。引用官方说明定义：“ZMQ(以下ZeroMQ简称ZMQ)是一个简单好用的传输层，像框架一样的一个socket library，他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。 ZMQ的明确目标是“成为标准网络协议...
sudo apt-get install -y lib
zmq
3-dev
2.安装php-
zmq
绑定
git clone https://github.com/mkoppanen/php-
zmq
.git
sh -c " cd php-
zmq
&& phpize && ./configure && make --silent && sudo make install "
echo " extension=
zmq
.so " >> ` php --ini | grep " Loaded Configuration " | sed -e " s|.*:\s*|| " `
3. 通过 Composer 需要
ZMQ
一个例子1.一个服务器负责生成天气相关数据（邮编、温度、湿度），然后将这些数据发布到所有需要知悉天气的客户端；
2.一个客户端需要时刻更新和获取最新的邮政编码，在没有获取之前可默认为纽约地区。特点：1.一个发布者，多个订阅者的关系，1：n；
2.当发布者数据变化时发布数据，所有订阅者均能够接收到数据并处理。
这就是发布/订阅模式。
ZeroMQ
的用户手册，适合C++、Java、Go、Python等通过MQ订阅消息的形式进行通信，低延迟，支持多语言SDK；手册内包含了
ZeroMQ
的基础入门知识，适合新手
学习
；介绍了
ZeroMQ
的集中模式包括高级请求-应答模式；
手册目录：
ZeroMQ
基础、
ZeroMQ
进阶、高级请求-应答模式、可靠的请求-应答模式、高级发布-订阅模式。
ZMQ
（ØMQ、
ZeroMQ
, 0MQ）看起来像是一套嵌入式的网络链接库，但工作起来更
像是一个并发式的框架。它提供的套接字可以在多种协议中传输消息，如线程
间、进程间、TCP、广播等。你可以使用套接字构建多对多的连接模式，如扇出、
发布-订阅、任务分发、请求-应答等。
ZMQ
的快速足以胜任集群应用产品。它
的异步 I/O 机制让你能够构建多核应用程序，完成异步消息处理任务。
ZMQ
有
着多语言支持，并能在几乎所有的操作系统上运行。
ZMQ
是 iMatix 公司的产品，
以 LGPL 开源协议发布。
从Go 1.14开始，在类似Unix的系统上，您会收到许多中断的信号调用。 请参阅软件包文档的顶部以获取修复程序。
这需要
ZeroMQ
版本4.0.1或更高版本。 要在4.2之前的版本中使用CURVE安全性，必须在启用下安装
ZeroMQ
。
zmq
4 draft的替代版本中提供了对
ZeroMQ
4.2 DRAFT的部分支持。 与此相关的API可能会更改。 要使用此功能：
import (
zmq
"github.com/pebbe/
zmq
4/draft"
对于
ZeroMQ
版本3，请参见： :
对于
ZeroMQ
版本2，请参见： :
包括所有示例。
关键字：
zmq
，
zeromq
，0mq，网络，分布式计算，消息传递，扇出，pubsub，管道，请求-答复
也可以看看
（
ZeroMQ
）的纯Go实现，版本4
— Go中语言绑定
本篇简单介绍
ZMQ
的使用。广泛应用于本公司的Android 主板 板间通讯、局域网通讯，
学习
一哈。
ZMQ
简介
ZMQ
被称为史上最快的消息队列,它处于会话层之上,应用层之下,使用后台异步线程完成消息的接受和发送,完美的封装了Socket API,大大简化了编程人员的复杂度。
ZMQ
发送和接受的是具有固定长度的二进制对象,
ZMQ
的消息包最大254个字节，前6个字节是协议，然后是数据包。
如果超过...
消息+队列(MessageQueue简称MQ)。本质上就是一个队列，FIFO先入先出，只不过是内容存放的是消息所以叫消息队列。
zeromq
不是一个独立的进程，其实本质上是一个库，需要引入到代码中使用
主要用途：不同的服务server，进程process，线程thread之间通信。
2 为何有MQ产品
在高并发常见下，主要是解决两端的处理速度不一致的问题，传统的就是采用在两端添加上队列缓存解决，而无法满足高并发的场景，故将做成中间件
3 使用场景
异步处理；流量控制；服务解耦；发布订阅；高并发
瞬时套接字和持久套接字
在传统网络编程中，套接字是一个API对象，它们的生命周期不会长过程序的生命周期。但仔细打量一下套接字，它会占用一项特定的资源——缓存，这时
ZMQ
的开发者可能会问：是否有办法在程序崩溃时让这些套接字缓存得以保留，稍后能够恢复？
这种特性应该会非常有用，虽然不能应对所有的危险，但至少可以挽回一部分损失，特别是多发布-订阅模式来说。让我们来讨论一下。
这里有两个套接字正在欢...
官网：https://
zeromq
.org/
ZeroMQ
（简称
ZMQ
）是一个基于消息队列的多线程网络库，其对套接字类型、连接处理、帧、甚至路由的底层细节进行抽象，提供跨越多种传输协议的套接字。
ZMQ
是网络通信中新的一层，介于应用层和传输层之间（按照TCP/IP划分），其是一个可伸缩层，可并行运行，分散在分布式系统间。
ZMQ
不是单独的服务，而是一个嵌入式库，它封装了网络
ZeroMQ
号称是“史上最快的消息队列”，基于c语言开发的，实时流处理sorm的task之间的通信就是用的
zeroMQ
。
引用官方说法，“
ZMQ
(以下
ZeroMQ
简称
ZMQ
)是一个简单好用的传输层，像框架一样的一个socket library，
他使得Socket编程更加简单、简洁和性能更高。是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。
ZMQ
的明确目标是“成为标准网络协议
ZMQ
与传统的TCP Socket最大的区别在于Socket连接不再是1:1的，而是1：N甚至N:N的，这意味
ZMQ
摒弃了每个后台请求处理线程都使用单独的一个Socket来返回用户请求的。同时，
ZMQ
又不允许多个线程共享Socket，所以
ZMQ
在使用一个Socket处理请求的过程中，会阻塞同一个端口的其他请求，显然这是无法满足需求的。
ZMQ
使用了信封的机制灵活的解决了这个问题。
正如上节介绍，Z
消息队列（message queue）本质就是个队列，先进先出FIFO。
利用FIFO先进先出的特性，可以保证消息的顺序性。主要用途：不同服务server、进程process、线程thread之间通信。2.1 消息可靠性处理
在实际应用中，我们可以通过以下要点的设计来确保消息的可靠性处理：2.2消息吞吐量
模式比较：
1）REQ-ACK模式（无法提高吞吐量）2）多次send，一次ack模式（可以提高吞吐量）2.3 消息队列—流量控制
流量控制也称为削峰。这也在消息队列设计的时候需要考虑的要素。
削峰，水位到
`
zmq
::send_flags::none` 是
ZeroMQ
(
ZMQ
) 库中的一个枚举常量，用于指定在发送消息时不使用任何标志。在
ZeroMQ
中，发送消息时可以使用不同的标志来控制发送行为，例如是否非阻塞发送、是否强制立即发送等。`
zmq
::send_flags::none` 表示不使用任何标志，即使用默认的发送行为。
使用 `
zmq
::send_flags::none` 标志发送消息的示例代码如下：
```cpp
zmq
::context_t context(1);
zmq
::socket_t socket(context,
zmq
::socket_type::req);
socket.connect("tcp://localhost:5555");
std::string message = "Hello, world!";
zmq
::message_t
zmq
Message(message.size());
memcpy(
zmq
Message.data(), message.data(), message.size());
socket.send(
zmq
Message,
zmq
::send_flags::none);
在上述示例中，我们创建了一个
ZeroMQ
的 `socket` 对象，并连接到本地主机的 5555 端口。然后，我们创建了一个包含消息内容的 `
zmq
::message_t` 对象，并使用 `
zmq
::send_flags::none` 标志将消息发送到 socket。
请注意，这只是一个简单的示例，实际使用中可能涉及更多的错误处理和其他逻辑。
