方槍槍的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)  編輯  收藏


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


          網站導航:
           
          主站蜘蛛池模板: 东平县| 手游| 南昌市| 南郑县| 临江市| 鄢陵县| 朝阳市| 鲁甸县| 南昌市| 恩平市| 类乌齐县| 乐平市| 商丘市| 西乡县| 白河县| 尉犁县| 佛教| 板桥市| 靖州| 禄丰县| 内乡县| 原阳县| 连云港市| 客服| 炉霍县| 当阳市| 台安县| 延川县| 寿光市| 板桥市| 宁南县| 湘阴县| 图木舒克市| 高雄市| 寿光市| 临沧市| 阿合奇县| 阳朔县| 玛沁县| 太原市| 句容市|