• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            牽著老婆滿街逛

            嚴(yán)以律己,寬以待人. 三思而后行.
            GMail/GTalk: yanglinbo#google.com;
            MSN/Email: tx7do#yahoo.com.cn;
            QQ: 3 0 3 3 9 6 9 2 0 .

            ZeroMQ的模式-Publish-Subscribe

            轉(zhuǎn)載自:http://www.kongch.com/2012/01/zeromq-pub-sub/

            Publish-subscribe Pattern:發(fā)布訂閱模式。

            現(xiàn)實中,并不是所有請求都期待答復(fù),而不期待答復(fù),自然就沒有了狀態(tài)。所以相對于REQ-REP,PUB-SUB模式容易理解也簡單得多。廣播聽過吧?收音機用過吧?就這個意思。

            相應(yīng)地,該模式下的socket也就兩種:ZMQ_PUB & ZMQ_SUB。 分別對應(yīng)電臺和收音機。

            ZMQ_PUB

            ZMQ_PUB主要用來讓消息發(fā)布者用來散發(fā)消息的。所有連接上的peer都能收到由它散發(fā)的消息。 zmq_recv(3) 這個API是不能用在這個socket上的,原因顯而易見。而zmq_send作用在該socket上時是永遠(yuǎn)不會阻塞的,如果訂閱者異常,發(fā)出的消息則會被丟棄。

            Summary of ZMQ_PUB characteristics
            Compatible peer sockets ZMQ_SUB
            Direction Unidirectional
            Send/receive pattern Send only
            Incoming routing strategy N/A
            Outgoing routing strategy Fan out
            ZMQ_HWM option action Drop

            ZMQ_SUB

            很明顯,訂閱者通過這個socket來接受發(fā)布者發(fā)布的消息。需要注意的是,在使用該socket時,必須顯式地調(diào)用zmq_setsockopt ,設(shè)置ZMQ_SUBSCRIBE和filter。如果不設(shè)置的話,是收不到任何消息的。

            Summary of ZMQ_SUB characteristics
            Compatible peer sockets ZMQ_PUB
            Direction Unidirectional
            Send/receive pattern Receive only
            Incoming routing strategy Fair-queued
            Outgoing routing strategy N/A
            ZMQ_HWM option action Drop

            總結(jié)

            PUB-SUB模式一般處理的都不是系統(tǒng)的關(guān)鍵數(shù)據(jù)。發(fā)布者不關(guān)注訂閱者是否收到發(fā)布的消息,訂閱者也不知道自己是否收到了發(fā)布者發(fā)出的所有消息。你也不知道訂閱者何時開始收到消息。因此邏輯上,它都不是可靠的。

            事實上,即便你先啟動訂閱者,再啟動發(fā)布者。訂閱者也不一定能收到所有的消息。原因在于:發(fā)布者已啟動就開始撒布消息,而這時訂閱者可能還沒有完成連接。如果一定需要保證,則需要做兩者的同步。最傻的方法就是讓發(fā)布者啟動之后sleep一會兒再開始發(fā)消息,不過這種方式就跟聽起來一樣不靠譜。

            一個訂閱者可以訂閱多個發(fā)布者。同時訂閱者通過filter來過濾自己需要的消息,需要注意的時,filter是在訂閱端起作用的。也就是說所有消息是會到達(dá)所有訂閱者處,訂閱者根據(jù)filter丟掉自己不需要的消息。


            posted on 2013-02-26 21:15 楊粼波 閱讀(7809) 評論(0)  編輯 收藏 引用


            只有注冊用戶登錄后才能發(fā)表評論。
            網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


            91久久国产视频| 精品国产99久久久久久麻豆| 久久久久亚洲AV无码麻豆| 久久久久99精品成人片试看| 99久久伊人精品综合观看| 亚洲国产精品综合久久网络| 久久婷婷国产综合精品| 久久精品国产亚洲一区二区三区| 久久精品国产99国产精品亚洲| 久久久久久a亚洲欧洲aⅴ| 亚洲国产日韩综合久久精品| 青青热久久综合网伊人| 久久婷婷五月综合97色直播| 亚洲国产精品久久久久婷婷软件 | 久久中文字幕无码专区| 青草国产精品久久久久久| 美女久久久久久| 久久久久久综合一区中文字幕| 久久无码高潮喷水| 久久天天躁狠狠躁夜夜2020| 2022年国产精品久久久久| 2021国产精品久久精品| 亚洲AV伊人久久青青草原| 色成年激情久久综合| 国产三级久久久精品麻豆三级 | 久久91精品国产91久| 精品熟女少妇aⅴ免费久久| 精品无码久久久久久午夜| 久久婷婷人人澡人人爽人人爱| 亚洲乱码日产精品a级毛片久久| 国内精品久久九九国产精品| 久久婷婷五月综合色奶水99啪| 无码任你躁久久久久久| 久久久久国产一级毛片高清板| 99精品伊人久久久大香线蕉| 国内精品九九久久久精品| 久久亚洲私人国产精品vA| 久久精品无码专区免费东京热| 久久久久久精品免费看SSS| 久久久久久亚洲精品影院| 97香蕉久久夜色精品国产|