paulwong

          基于Spring Boot, Axon CQRS/ES,和Docker構(gòu)建微服務(wù)

          這是一個使用Spring Boot和Axon以及Docker構(gòu)建的Event Sorucing源碼項目,技術(shù)特點:
          1.使用Java 和Spring Boot實現(xiàn)微服務(wù);
          2.使用命令和查詢職責(zé)分離 (CQRS) 和 Event Sourcing (ES) 的框架Axon Framework v2, MongoDB 和 RabbitMQ;
          3.使用Docker構(gòu)建 交付和運行;
          4.集中配置和使用Spring Cloud服務(wù)注冊;
          5.使用Swagger 和 SpringFox 提供API文檔

          項目源碼:GitHub

          工作原理:
          這個應(yīng)用使用CQRS架構(gòu)模式構(gòu)建,在CQRS命令如ADD是和查詢VIEW(where id=1)分離的,在這個案例中領(lǐng)域部分代碼已經(jīng)分離成兩個組件:一個是屬于命令這邊的微服務(wù)和屬性查詢這邊的微服務(wù)。

          微服務(wù)是單個職責(zé)的功能,自己的數(shù)據(jù)存儲,每個能彼此獨立擴展部署。

          屬于命令這邊的微服務(wù)和屬性查詢這邊的微服務(wù)都是使用Spring Boot框架開發(fā)的,在命令微服務(wù)和查詢微服務(wù)之間通訊是事件驅(qū)動,事件是通過RabbitMQ消息在微服務(wù)組件之間傳遞,消息提供了一種進程節(jié)點或微服務(wù)之間可擴展的事件載體,包括與傳統(tǒng)遺留系統(tǒng)或其他系統(tǒng)的松耦合通訊都可以通過消息進行。

          請注意,服務(wù)之間不能彼此共享數(shù)據(jù)庫,這是很重要,因為微服務(wù)應(yīng)該是高度自治自主的,這樣反過來有助于服務(wù)能夠彼此獨立地擴展伸縮規(guī)模。

          CQRS中命令是“改變狀態(tài)的動作”。命令的微服務(wù)包含所有領(lǐng)域邏輯和業(yè)務(wù)規(guī)則,命令被用于增加新的產(chǎn)品或改變它們的狀態(tài),這些命令針對某個具體產(chǎn)品的執(zhí)行會導(dǎo)致事件Event產(chǎn)生,這會通過Axon框架持久化到MongoDB中,然后通過RabbitMQ傳播給其他節(jié)點進程或微服務(wù)。

          在event-sourcing中,事件是狀態(tài)改變的原始記錄,它們用于系統(tǒng)來重新建立實體的當(dāng)前狀態(tài)(通過重新播放過去的事件到當(dāng)前就可以構(gòu)建當(dāng)前的狀態(tài)),這聽上去會很慢,但是實際上,事件都很簡單,執(zhí)行非常快,也能采取‘快照’策略進行優(yōu)化。

          請注意,在DDD中,實體是指一個聚合根實體。

          上面是命令這邊的微服務(wù),下面看看查詢這邊的微服務(wù):
          查詢微服務(wù)一般扮演一種事件監(jiān)聽器和視圖角色,它監(jiān)聽到命令那邊發(fā)出的事件,然后處理它們以符合查詢這邊的要求。

          在這個案例中,查詢這邊只是簡單建立和維持了一個 ‘materialised view’或‘projection’ ,其中保留了產(chǎn)品的最新狀態(tài),也就是產(chǎn)品id和描述以及是否被賣出等等信息,查詢這邊能夠被復(fù)制多次以方便擴展,消息可以保留在RabbitMQ隊列中實現(xiàn)持久保存,這種臨時保存消息方式可以防止查詢這邊微服務(wù)當(dāng)機。

          命令微服務(wù)和查詢微服務(wù)兩者都有REST API,提供外界客戶端訪問。

          下面看看如何通過Docker運行這個案例,需要 Ubuntu 16.04:
          1.Docker ( v1.8.2)
          2.Docker-compose ( v1.7.1)

          在一個空目錄,執(zhí)行下面命令下載docker-compose:

          $ wget https://raw.githubusercontent.com/benwilcock/microservice-sampler/master/docker-compose.yml
          注意:不要更改文件名稱。

          啟動微服務(wù):只是簡單一個命令:

          $ docker-compose up

          你會看到許多下載信息和日志輸出在屏幕上,這是Docker image將被下載和運行。一共有六個docker,分別是: ‘mongodb’, ‘rabbitmq’, ‘config’, ‘discovery’, ‘product-cmd-side’, 和 ‘product-qry-side’.

          使用下面命令進行測試增加一個新產(chǎn)品:

          $ curl -X POST -v --header "Content-Type: application/json" --header "Accept: */*" "http://localhost:9000/products/add/1?name=Everything%20Is%20Awesome"

          查詢這個新產(chǎn)品:

          $ curl http://localhost:9001/products/1

          Microservices With Spring Boot, Axon CQRS/ES, and Docker

          posted on 2017-02-18 22:00 paulwong 閱讀(1864) 評論(0)  編輯  收藏 所屬分類: DDD

          主站蜘蛛池模板: 青铜峡市| 花莲县| 宜宾县| 远安县| 青阳县| 连平县| 德惠市| 临颍县| 辉县市| 同仁县| 克东县| 梧州市| 鞍山市| 清流县| 湖北省| 玉山县| 水城县| 轮台县| 呼和浩特市| 醴陵市| 松阳县| 延安市| 沁阳市| 哈尔滨市| 分宜县| 抚远县| 连南| 广河县| 宜丰县| 额尔古纳市| 汉阴县| 梅州市| 曲周县| 山丹县| 洞口县| 台南市| 延庆县| 大冶市| 南华县| 芒康县| 普定县|