• <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麻豆精品国产91久久久久久| 青青青国产精品国产精品久久久久| 久久精品国产国产精品四凭| 色婷婷综合久久久中文字幕| 国内精品久久久久久久亚洲| 欧洲成人午夜精品无码区久久| 国内精品久久久久久久影视麻豆 | 青青青青久久精品国产h久久精品五福影院1421 | 日韩欧美亚洲综合久久| 国内精品久久久久久野外| 久久免费香蕉视频| 久久超乳爆乳中文字幕| 要久久爱在线免费观看| 日韩精品国产自在久久现线拍| 亚洲中文字幕无码久久精品1| 久久精品国产一区二区| 亚洲伊人久久大香线蕉苏妲己| 性色欲网站人妻丰满中文久久不卡| 久久精品国产清自在天天线| 久久精品aⅴ无码中文字字幕重口| 综合久久一区二区三区 | 亚洲精品午夜国产VA久久成人| 欧美与黑人午夜性猛交久久久| 91久久精品国产91性色也| 国内精品久久久久影院一蜜桃| 影音先锋女人AV鲁色资源网久久 | 亚洲狠狠久久综合一区77777| 久久国产欧美日韩精品| 日产精品久久久久久久| 久久精品亚洲精品国产色婷| 欧美va久久久噜噜噜久久| 久久人人爽人人爽人人AV| 色婷婷综合久久久久中文一区二区 | 国产精品乱码久久久久久软件| 人妻少妇精品久久| 久久99热这里只频精品6| 久久精品国产乱子伦| 天堂久久天堂AV色综合| 亚洲国产精品无码久久一线|