方槍槍的java世界

          不要因為風雨飄落就停止了你的腳步,真正的得失就在你的心中。 做喜歡做的事,不輕言放棄!

          企業框架設計-事件處理平臺

          基于MQ的事件處理框架
          1、事件定義()
             <EventDef name=”addDabmzd ”status=”active”
                       Type=”custom” topic=”HighLevelTopic”>
             事件產生方式有兩種:
                攔截服務方法發生前后、異常發生后,框架調用事件平臺api產生事件
                業務編碼調用事件平臺api產生事件
          2、消費者注冊(注冊訂閱關系)  
             <EventConsumer id=”c1” name=””>
                <Service name="Service2" onEvent=””/>
                <Service name="Service3" onEvent=””/>
                <Events>
                  <Event name="Topic1/Event1" topic=”HighLevelTopic”/>
                </Events>
             </EventConsumer> 
            
             每臺機器向MQ注冊訂閱關系,MQ最終注冊信息:  
                 c1:topic1/tag(event1),c2:topic2/tag(event2)     
             管理控制臺增加一個訂閱關系 sevice2-》topic3/event3,
             訂閱信息廣播給所有consumer,每個consumer會檢查是否有service2
             (系統中每個consumer默認會訂閱一個系統級topic,用于群發消息)
          3、事件發送到Mq消息隊列,保證消息處理性能和可靠性,消息不丟失
          4、事件接收處理(訂閱相關主題的事件消息)

          posted on 2016-12-03 16:21 做強大的自己 閱讀(89) 評論(0)  編輯  收藏


          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          主站蜘蛛池模板: 定结县| 谷城县| 子洲县| 寿阳县| 泽州县| 扶绥县| 三门县| 靖边县| 佛教| 托克托县| 白银市| 集安市| 鹿邑县| 红河县| 云龙县| 玛多县| 晋宁县| 武冈市| 日照市| 偃师市| 金乡县| 万年县| 林口县| 丰县| 崇信县| 崇左市| 开鲁县| 黄大仙区| 华宁县| 霍山县| 荔波县| 曲沃县| 巧家县| 镇赉县| 潍坊市| 郸城县| 临夏市| 宣武区| 微山县| 莱西市| 苍南县|