java 消息队列 实例


1.为什么要用队列

假设你的服务器每分钟的处理量为1000个,但客户端再峰值的时候可能一分钟会发10000个消息给你,这时候你就可以把他做成队列,然后按正常有序的处理,

先进后出(LIFO),先进先出(FIFO)可根据自己的情况进行定夺

stack  先进后出(LIFO)--------Java 对应的类 Stack

队列 先进先出(FIFO)--------java对应的类Queue

2。简单java实现(用Linkedlist封装实现)

  栈类

  1. public class MyStack<T> {  
  2.     private LinkedList<T> storage = new LinkedList<T>();  
  3.   
  4.     public synchronized void push(T e) {//需要加上同步  
  5.         storage.addFirst(e);  
  6.     }  
  7.   
  8.     public T peek() {  
  9.         return storage.getFirst();  
  10.     }  
  11.   
  12.     public void pop() {  
  13.         storage.removeFirst();  
  14.     }  
  15.   
  16.     public boolean empty() {  
  17.         return storage.isEmpty();  
  18.     }  
  19.   
  20.     @Override  
  21.     public String toString() {  
  22.         return storage.toString();  
  23.     }  
  24.   
  25. }  

  测试类

  

  1. ublic class StackTest {  
  2.     public static void main(String[] args) {  
  3.         MyStack<String> stack = new MyStack<String>();  
  4.         for(String s : "the prefect code".split(" ")){//LIFO  
  5.             stack.push(s);  
  6.         }  
  7.         while(!stack.empty()){  
  8.             System.out.print(stack.peek()+" ");  
  9.             stack.pop();  
  10.         }  
  11.           
  12.         System.out.println();  
  13.         for(char s : "写了个一句话倒起来说的程序".toCharArray()){//用例:正话反说  
  14.             stack.push(String.valueOf(s));  
  15.         }  
  16.         while(!stack.empty()){  
  17.             System.out.print(stack.peek());  
  18.             stack.pop();  
  19.         }  
  20.     }  
  21. }  

  使用场景:

  如果你在页面做某一个操作,需要对所有区域或者某种类型相同的用户发送消息(即需要插入很多条消息数据)

  有可能会很慢,那么我们就可以用队列来做,将用户提交的数据保存,然后将其他操作放入队列中,然后立即返回用户结果,由消息队列异步进行这些操作。


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM