一、nanomq型号
nanomq是一个轻量级、多线程的消息队列系统,支持几乎所有的现代编程语言,并且可以快速部署和高效运行。nanomq有两种型号:nanomq和nanomq-experimental。nanomq是nanomq提供的标准型号,nanomq-experimental则是一些实验性的新特性,不太稳定,适合用于测试或者非关键业务的生产环境。
二、NANOMQS
nanomq实现了可插拔的协议栈,并提供了一些通用的协议栈。其中,NANOMQS(nanomq-stream)是其中一种连接多个点的方式。NANOMQS是基于TCP/IP协议的可靠消息协议,可用于可靠消息传输。在使用NANOMQS时,我们可以在服务器/客户端之间创建多个socket,以支持并发的收发消息。以下是在python中使用nanomq实现的NANOMQS示例:
import nanomq socket = nanomq.Socket(nanomq.REP) socket.bind('tcp://*:5555') while True: message = socket.recv() print("Received request: %s" % message) socket.send("World")
三、nanomsg使用
nanomsg是nanomq的前身,在不久的将来,nanomsg将被nanomq替换。nanomsg是一个高性能、低延迟的消息传递库,提供了多种消息模式,包括可靠性高的REQ/REP、PUB/SUB、和管道。以下是在python中使用nanomsg实现的发送和接收消息的示例:
import nanomsg # 发送消息 with nanomsg.Socket(nanomsg.PAIR) as sock: sock.bind('ipc://example.ipc') sock.send(b'Hello, nanomsg!') # 接收消息 with nanomsg.Socket(nanomsg.PAIR) as sock: sock.connect('ipc://example.ipc') msg = sock.recv() print(msg.decode())
四、NanoMsg介绍
NanoMsg是nanomq的前身,是一个高性能、低延迟的消息传递库,是nanomq和nanomsg的母体。它提供了多种可靠的、不可靠的和广播的消息模式,并支持异步事件通知。以下是NanoMsg支持的消息模式:
- PAIR:点对点
- PUB/SUB:发布/订阅
- REQ/REP:请求/应答
- PUSH/PULL:任务分发
- GLOBAL:多进程和多线程之间的全局广播
五、NanoMsg怎么读
NanoMsg的名字中,Nano表示“小型”,Msg则表示“消息”。因此NanoMsg的意思就是“小型的消息传递库”。同时,NanoMsg的创始人Martin Sustrik也将它定义为“一个简单、快速、可扩展的消息传递库”。