paulwong

          EVEN DRIVEN - SPRING CLOUD STREAM - SPRING CLOUD微服務的EVEN DRIVEN框架

          通常微服務應用之間的通信是通過HTTP調用,吞吐性不建都高,高并發的場景建議使用EVENT DRIVEN的框架,即使用MESSAGE通信。

          即A微服務應用將數據發送到MESSAGE BROKER中的某個DESTINATION,此DESTINATION是廣播型,非點對點型。B微服務應用訂閱此DESTINATION,當有新MESSAGE到達此DESTINATION時,MESSAGE BROKER會將此MESSAGE推送給B應用。所有對此MESSAGE有需要的應用均可訂閱,從而收到此MESSAGE。

          SPRING CLOUD 中EVENT DRIVEN的框架就是SPRING CLOUD STREAM。其底層是使用SPRING INTEGRATION實現。

          SPRING CLOUD STREAM有以下新名詞:

          • BINDER:
          是對MESSAGE BROKER操作方法的抽象,即應用通過此BINDER操作MESSAGE BROKER。目前只實現了RABITMQ和KAFKA。
          • CHANNEL
          MESSAGE從SPRING CLOUD STREAM傳給應用或相反是通過CHANNEL傳遞的,這點和SPRING INTEGRATION是一樣的。
          • SOURCE
          MESSAGE從應用傳給SPRING CLOUD STREAM的CHANNEL,叫@INPUT,包含這種CHANNEL的接口叫SOURCE。
          • SINK
          MESSAGE從SPRING CLOUD STREAM傳給應用的CHANNEL,叫@OUPUT,包含這種CHANNEL的接口叫SINK。
          • BIDDING
          綁定哪個@INPUT或哪個@OUPUT與哪個DESTINATION發送或接收關系的MAPPING。
          • EnableBinding
          應用啟動時就會建立EnableBinding指定的接口中的CHANNEL
          • 消費者群組
          默認下如果同一個應用部署了多個實例,則每個實例都會收到MESSAGE,這時如果設置了消費者群組名稱,則同一個名稱下的多個實例,只有一個能收到MESSAGE。
          • PARTITION
          如果為MESSAGE指定規則,如MESSAGE某個字段值以A開頭為一個規則,以B開頭為一個規則,那么以A開頭的MESSAGE會放到同一個分區中。

          這樣使用就很簡單了,只要取得OUTPUT CHANNEL,就可以發送MESSAGE,將代碼關聯到INPUT CHANNEL,就能在收到MESSAGE時,相關代碼就會被執行。

          posted on 2021-11-05 14:58 paulwong 閱讀(210) 評論(0)  編輯  收藏 所屬分類: SPRING CLOUDEVEN DRIVEN ARCHITECT

          主站蜘蛛池模板: 巴彦县| 宾阳县| 邵阳县| 临高县| 体育| 阜新市| 佳木斯市| 昆山市| 怀远县| 磐石市| 峨眉山市| 诏安县| 涪陵区| 滦平县| 新乡县| 渭源县| 霍山县| 肥西县| 故城县| 抚远县| 武义县| 和平区| 万全县| 广宗县| 双城市| 永德县| 通许县| 娱乐| 湘潭县| 余干县| 泸西县| 吴江市| 台湾省| 虞城县| 霍邱县| 怀化市| 双柏县| 潼关县| 肇东市| 七台河市| 信丰县|