<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    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 閱讀(207) 評論(0)  編輯  收藏 所屬分類: SPRING CLOUDEVEN DRIVEN ARCHITECT

    主站蜘蛛池模板: 亚洲中文字幕久久精品无码2021| 美女羞羞喷液视频免费| 久久精品网站免费观看| 亚洲AV无码一区二区乱子仑| 日韩精品亚洲aⅴ在线影院| 日韩中文字幕免费视频| 亚洲高清一区二区三区电影| 国产AⅤ无码专区亚洲AV| 免费阿v网站在线观看g| 美女视频黄.免费网址| 亚洲一区二区三区电影| 免费人成视频x8x8入口| 91热久久免费精品99| 国产成人高清亚洲一区91| 亚洲天天做日日做天天看| 国产99视频精品免费视频7| 日本免费在线中文字幕| 亚洲AV成人精品一区二区三区 | 亚洲国产天堂在线观看| 热99re久久免费视精品频软件 | 亚洲免费在线观看视频| 精品国产污污免费网站入口在线 | 久久免费视频99| 美女视频免费看一区二区| 亚洲伊人久久大香线蕉啊| 国产亚洲精品久久久久秋霞| 成人a免费α片在线视频网站| 免费国产成人午夜在线观看| 精品亚洲国产成人av| 亚洲另类古典武侠| 亚洲VA中文字幕无码毛片 | 亚洲黄色免费网站| 国产国拍精品亚洲AV片| 国产成人精品123区免费视频| 亚州免费一级毛片| 国色精品va在线观看免费视频| 美女被爆羞羞网站免费| 亚洲日韩精品A∨片无码加勒比| 精品亚洲国产成AV人片传媒| 国产亚洲成AV人片在线观黄桃 | 亚洲Av无码专区国产乱码DVD|