MQ

時間 2019-11-17

原文原文鏈接

2.1 解耦

如今我有一個系統A，系統A能夠產生一個userIdjava

而後，如今有系統B和系統C都須要這個userId去作相關的操做數據庫

寫成僞代碼多是這樣的：網絡

public class SystemA { // 系統B和系統C的依賴  SystemB systemB = new SystemB(); SystemC systemC = new SystemC(); // 系統A獨有的數據userId  private String userId = "Java3y"; public void doSomething() { // 系統B和系統C都須要拿着系統A的userId去操做其餘的事  systemB.SystemBNeed2do(userId); systemC.SystemCNeed2do(userId); } }

結構圖以下：併發

ok，一切平安無事度過了幾個天。異步

某一天，系統B的負責人告訴系統A的負責人，如今系統B的SystemBNeed2do(String userId)這個接口再也不使用了，讓系統A別去調它了。分佈式

因而，系統A的負責人說"好的，那我就不調用你了。"，因而就把調用系統B接口的代碼給刪掉了：this

public void doSomething() { // 系統A再也不調用系統B的接口了  //systemB.SystemBNeed2do(userId);  systemC.SystemCNeed2do(userId); }

又過了幾天，系統D的負責人接了個需求，也須要用到系統A的userId，因而就跑去跟系統A的負責人說："老哥，我要用到你的userId，你調一下個人接口吧"spa

因而系統A說："沒問題的，這就搞"設計

而後，系統A的代碼以下：3d

public class SystemA { // 已經再也不須要系統B的依賴了  // SystemB systemB = new SystemB();  // 系統C和系統D的依賴  SystemC systemC = new SystemC(); SystemD systemD = new SystemD(); // 系統A獨有的數據  private String userId = "Java3y"; public void doSomething() { // 已經再也不須要系統B的依賴了  //systemB.SystemBNeed2do(userId);  // 系統C和系統D都須要拿着系統A的userId去操做其餘的事  systemC.SystemCNeed2do(userId); systemD.SystemDNeed2do(userId); } }

時間飛逝：

又過了幾天，系統E的負責人過來了，告訴系統A，須要userId。
又過了幾天，系統B的負責人過來了，告訴系統A，仍是從新掉那個接口吧。
又過了幾天，系統F的負責人過來了，告訴系統A，須要userId。
…...

因而系統A的負責人，天天都被這給騷擾着，改來改去，改來改去.......

還有另一個問題，調用系統C的時候，若是系統C掛了，系統A還得想辦法處理。若是調用系統D時，因爲網絡延遲，請求超時了，那系統A是反饋fail仍是重試？？

最後，系統A的負責人，以爲隔一段時間就改來改去，沒意思，因而就跑路了。

而後，公司招來一個大佬，大佬通過幾天熟悉，上來就說：將系統A的userId寫到消息隊列中，這樣系統A就不用常常改動了。爲何呢？下面咱們來一塊兒看看：

系統A將userId寫到消息隊列中，系統C和系統D從消息隊列中拿數據。這樣有什麼好處？

系統A只負責把數據寫到隊列中，誰想要或不想要這個數據(消息)，系統A一點都不關心。
即使如今系統D不想要userId這個數據了，系統B又忽然想要userId這個數據了，都跟系統A無關，系統A一點代碼都不用改。
系統D拿userId再也不通過系統A，而是從消息隊列裏邊拿。系統D即使掛了或者請求超時，都跟系統A無關，只跟消息隊列有關。

這樣一來，系統A與系統B、C、D都解耦了。

2.2 異步

咱們再來看看下面這種狀況：系統A仍是直接調用系統B、C、D

代碼以下：

public class SystemA { SystemB systemB = new SystemB(); SystemC systemC = new SystemC(); SystemD systemD = new SystemD(); // 系統A獨有的數據  private String userId ; public void doOrder() { // 下訂單  userId = this.order(); // 若是下單成功，則安排其餘系統作一些事  systemB.SystemBNeed2do(userId); systemC.SystemCNeed2do(userId); systemD.SystemDNeed2do(userId); } }