• <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>

            牽著老婆滿街逛

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

            ZeroMQ的模式-Publish-Subscribe

            轉載自:http://www.kongch.com/2012/01/zeromq-pub-sub/

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

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

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

            ZMQ_PUB

            ZMQ_PUB主要用來讓消息發(fā)布者用來散發(fā)消息的。所有連接上的peer都能收到由它散發(fā)的消息。 zmq_recv(3) 這個API是不能用在這個socket上的,原因顯而易見。而zmq_send作用在該socket上時是永遠不會阻塞的,如果訂閱者異常,發(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時,必須顯式地調用zmq_setsockopt ,設置ZMQ_SUBSCRIBE和filter。如果不設置的話,是收不到任何消息的。

            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

            總結

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

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

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


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

            国产福利电影一区二区三区,免费久久久久久久精 | 日韩精品无码久久久久久| 一本大道加勒比久久综合| 香蕉久久av一区二区三区| 久久九九免费高清视频| 久久久av波多野一区二区| 亚洲国产成人久久综合碰| 久久99精品久久久久久久不卡 | 久久人人爽人人爽人人片AV麻豆| 久久精品国产精品亚洲精品| 国产精品99久久久久久董美香| 久久国产精品成人片免费| 麻豆精品久久久久久久99蜜桃| 久久综合久久性久99毛片| 一本久久a久久精品综合夜夜| av午夜福利一片免费看久久| 亚洲国产另类久久久精品| 99久久国产宗和精品1上映| 偷窥少妇久久久久久久久| 久久精品国产欧美日韩99热| 久久中文字幕视频、最近更新| 久久99热这里只有精品国产| 国产午夜精品久久久久九九| 大蕉久久伊人中文字幕| 久久精品国产清自在天天线| 久久99精品免费一区二区| 国产亚洲色婷婷久久99精品91 | 成人资源影音先锋久久资源网| 蜜臀久久99精品久久久久久小说| 久久香蕉超碰97国产精品| 精品国产乱码久久久久久1区2区| 波多野结衣中文字幕久久 | 伊人久久无码精品中文字幕| 亚洲国产综合久久天堂 | 丁香五月网久久综合| 国产精品美女久久福利网站| 久久婷婷五月综合97色直播| 亚洲综合伊人久久综合| 久久久久久午夜成人影院| 亚洲国产精品一区二区久久| 色综合久久88色综合天天 |