訊息佇列Java的簡單實現
阿新 • • 發佈:2019-01-02
此文章是剛畢業的時候比較懵懂寫的,實際上不可稱之為訊息佇列,等我有空了會更新一篇關於主流mq的文章,謝謝包容(20171123)
今天看到我們的招聘資訊有對訊息佇列有要求,然後就思索了一翻,網上一搜一大堆。
我可以舉個小例子先說明應用場景
假設你的伺服器每分鐘的處理量為200個,但客戶端再峰值的時候可能一分鐘會發1000個訊息給你,這時候你就可以把他做成佇列,然後按正常有序的處理,先進後出(LIFO),先進先出(FIFO)可根據自己的情況進行定奪
stack 先進後出(LIFO)--------java 對應的類 Stack
佇列 先進先出(FIFO)--------java對應的類Queue
這兩種都可用Linkedlist進行封裝和實現,下面是我自己寫的一個棧的例子
/** * @author 劉伊凡 * --------->>>>>>佇列的實現-------------- */ public class MyStack<T> { private LinkedList<T> storage = new LinkedList<T>(); public synchronized void push(T e) {//需要加上同步 storage.addFirst(e); } public T peek() { return storage.getFirst(); } public void pop() { storage.removeFirst(); } public boolean empty() { return storage.isEmpty(); } @Override public String toString() { return storage.toString(); } }
下面是一個測試類
/** * @author 劉伊凡 * */ public class StackTest { public static void main(String[] args) { MyStack<String> stack = new MyStack<String>(); for(String s : "the prefect code".split(" ")){//LIFO stack.push(s); } while(!stack.empty()){ System.out.print(stack.peek()+" "); stack.pop(); } System.out.println(); for(char s : "寫了個一句話倒起來說的程式".toCharArray()){//用例:正話反說 stack.push(String.valueOf(s)); } while(!stack.empty()){ System.out.print(stack.peek()); stack.pop(); } } }
挺有意思的,讓我想了,以前在學校的晚會上,主持人互動的時候會讓人上臺去答題拿獎品,其中有一個題目就是主持人說一句話,然後要求選手倒起來說,我們的這個程式很符合需求嘛,哈哈,我們可以用java來作弊,學以致用
訊息佇列的應用場景,補充(來自網際網路)
使用場景的話,舉個例子:
假設使用者在你的軟體中註冊,服務端收到使用者的註冊請求後,它會做這些操作:
- 校驗使用者名稱等資訊,如果沒問題會在資料庫中新增一個使用者記錄
- 如果是用郵箱註冊會給你傳送一封註冊成功的郵件,手機註冊則會發送一條簡訊
- 分析使用者的個人資訊,以便將來向他推薦一些志同道合的人,或向那些人推薦他
- 傳送給使用者一個包含操作指南的系統通知
- 等等……
或者還有一種情況,同時有大量使用者註冊你的軟體,再高併發情況下注冊請求開始出現一些問題,例如郵件介面承受不住,或是分析資訊時的大量計算使cpu滿載,這將會出現雖然使用者資料記錄很快的新增到資料庫中了,但是卻卡在發郵件或分析資訊時的情況,導致請求的響應時間大幅增長,甚至出現超時,這就有點不划算了。面對這種情況一般也是將這些操作放入訊息佇列(生產者消費者模型),訊息佇列慢慢的進行處理,同時可以很快的完成註冊請求,不會影響使用者使用其他功能。
所以在軟體的正常功能開發中,並不需要去刻意的尋找訊息佇列的使用場景,而是當出現效能瓶頸時,去檢視業務邏輯是否存在可以非同步處理的耗時操作,如果存在的話便可以引入訊息佇列來解決。否則盲目的使用訊息佇列可能會增加維護和開發的成本卻無法得到可觀的效能提升,那就得不償失了。