簡(jiǎn)介
引用官方說(shuō)法:ZMQ(以下 ZeroMQ 簡(jiǎn)稱(chēng) ZMQ)是一個(gè)簡(jiǎn)單好用的傳輸層,像框架一樣的一個(gè) socket library,他使得 Socket 編程更加簡(jiǎn)單、簡(jiǎn)潔和性能更高。
是一個(gè)消息處理隊(duì)列庫(kù),可在多個(gè)線程、內(nèi)核和主機(jī)盒之間彈性伸縮。
ZMQ 的明確目標(biāo)是“成為標(biāo)準(zhǔn)網(wǎng)絡(luò)協(xié)議棧的一部分,之后進(jìn)入 Linux 內(nèi)核”。現(xiàn)在還未看到它們的成功。但是,它無(wú)疑是極具前景的、并且是人們更加需要的“傳統(tǒng)” BSD 套接字之上的一 層封裝。ZMQ 讓編寫(xiě)高性能網(wǎng)絡(luò)應(yīng)用程序極為簡(jiǎn)單和有趣。
它跟 RabbitMQ,ActiveMQ 之類(lèi)有著相當(dāng)本質(zhì)的區(qū)別,ZeroMQ 根本就不是一個(gè)消息隊(duì)列服務(wù)器,更像是一組底層網(wǎng)絡(luò)通訊庫(kù),對(duì)原有的 Socket API 加上一層封裝,使我們操作更簡(jiǎn)便。
三種工作模式
Request-Reply 模式:
說(shuō)到“請(qǐng)求-應(yīng)答”模式,不得不說(shuō)的就是它的消息流動(dòng)模型。消息流動(dòng)模型指的是該模式下,必須嚴(yán)格遵守“一問(wèn)一答”的方式。
發(fā)出消息后,若沒(méi)有收到回復(fù),再發(fā)出第二條消息時(shí)就會(huì)拋出異常。同樣的,對(duì)于 Rep 也是,在沒(méi)有接收到消息前,不允許發(fā)出消息。
基于此構(gòu)成“一問(wèn)一答”的響應(yīng)模式。
server:
# -*- coding=utf-8 -*- import zmq context = zmq.Context() socket = context.socket(zmq.REP) socket.bind("tcp://*:5555") while True: message = socket.recv() print("Received: %s" % message) socket.send("I am OK!")
網(wǎng)站欄目:詳解Python實(shí)現(xiàn)ZeroMQ的三種基本工作模式-創(chuàng)新互聯(lián)
網(wǎng)頁(yè)地址:http://www.chinadenli.net/article36/ddcipg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站維護(hù)、網(wǎng)站設(shè)計(jì)、企業(yè)網(wǎng)站制作、自適應(yīng)網(wǎng)站、定制開(kāi)發(fā)、App開(kāi)發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容