一、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也將它定義為「一個簡單、快速、可擴展的消息傳遞庫」。
原創文章,作者:小藍,如若轉載,請註明出處:https://www.506064.com/zh-tw/n/279160.html