完整性和不丢失的方式处理消息 BlockingQueue类

用到队列机制。
BlockingQueue类就是先进先出的队列，还有很多其他队列类。
用法：
1，声明创建BlockingQueue类
2，创建一个子线程的类，业务处理放在子线程中，并实例化，将BlockingQueue的类对象传进去
3，有消息的时候就将消息加进BlockingQueue的类对象中：
Message msg=new Message();
queue.add(msg);
BlockingQueue<Message> queue = new ArrayBlockingQueue<Message>(2048);
Consumer c = new Consumer(queue);new Thread(c).start();
class Consumer implements Runnable{    PRivate final BlockingQueue<Message> queue;    public Consumer(BlockingQueue<Message> q){        this.queue = q;    }    public void run() {        while(true){               Message msg= queue.take();
          }    }}