架構訊息中介軟體基於記憶體的mq

如果使用者的請求比較費時，可以考慮將使用者的請求資訊放到佇列中，立即返回給使用者處理中等資訊，這樣可以給使用者比較流暢的體驗，後端可以利用單獨的服務消費訊息，做到了解耦，提高了併發能力。

本文使用jdk為我們提供的阻塞佇列api，來實現乙個基於記憶體的簡單訊息佇列。主要涉及的介面blockingqueue,以及它的實現類arrayblockingqueue（陣列實現的）和linkedblockingqueue(鍊錶實現的)。

blockingqueue的主要方法

新增元素

put() //往佇列裡插入元素,如果佇列已經滿,則會一直等待直到隊列為空插入新元素,或者執行緒被中斷丟擲異常;

offer() //往佇列新增元素如果佇列已滿直接返回false,佇列未滿則直接插入並返回true;

add() //對offer()方法的簡單封裝.如果佇列已滿,丟擲異常new illegalstateexception("queue full");

刪除元素

remove() //方法直接刪除隊頭的元素;

take() //取出並刪除隊頭的元素,當隊列為空,則會一直等待直到佇列有新元素可以取出,或者執行緒被中斷丟擲異常;

pool() //取出並刪除隊頭的元素,當隊列為空,返回null;

peek() //直接取出隊頭的元素,並不刪除;

element() //對peek方法進行簡單封裝,如果隊頭元素存在則取出並不刪除,如果不存在丟擲異常nosuchelementexception();

基於記憶體的佇列，佇列的大小依賴於jvm記憶體的大小，一般如果是記憶體占用不大且處理相對較為及時的都可以採用此種方法。如果你在佇列處理的時候需要有失敗重試機制，那麼用此種佇列就不是特別合適了，可以使用基於資料庫的mq。

使用示例，簡單模仿基於生產者、消費者、訊息佇列模型的記憶體mq

*生產者模型

public class produce 
public produce(int id, blockingqueuequeue) 
public void produce(string message)
}}

*消費者模型

public class consumer 
public consumer(blockingqueuequeue, int id)
public void consumer() catch (interruptedexception e) 					
}}, 0, 5, timeunit.seconds);
}}

*測試類

public class test  catch (interruptedexception e) 
for(int i=0;i<20;i++)	
}}

ps:訊息佇列無論在分布式還是在高併發概念中，都是乙個非常重要的資料處理方式，本文只是我對訊息中介軟體這個技術棧的第一次試水，後面會陸續增加基於資料庫的mq，以及現在已經比較成熟商業中介軟體產品rabbitmq、rocketmq等的學習筆記。

架構訊息中介軟體基於記憶體的mq

訊息中介軟體 MQ

MQ訊息中介軟體

訊息中介軟體MQ

架構 訊息中介軟體 基於記憶體的mq

訊息中介軟體 MQ

MQ訊息中介軟體

訊息中介軟體MQ

相關推薦

架構訊息中介軟體基於記憶體的mq