1.面对 tcp 直接连接程序，像网上的mina 、netty

  直连比较mq 要快，

   用mq 可以，过段时间不用弄了，再换另外一种技术。

1.1 ConcurrentLinkedQueue: 是一个适用高并发场景下的队列，通过无锁的方式，实现了高并非下的高性能，通常ConcurrentLinkedQueue 性能好于BlockingQueue 。它是一个基于连接节点无界线程安全队列，该队列的元素尊循先进先出的原则，头是最先加入的，尾是最近加入的，该队列不允许null 元素。

   ConcurrentLinkedQueue 重要方法：

   add() 和offer() 都是加入元素的方法（在ConcurrentLinkedQueue 中，这俩个方法没有任何区别）

   poll()和peek() 都是取头元素节点，区别在于前者会删除元素，后者不会。

1.2 BlockingQueue

•    ArrayBlockingQueue :基于数组的阻塞队列实现，在ArrayBlockingQueue 内部，维护了一个定长的数组，以便缓冲队列中的数组对象，其内部没有实现读写分离，也就意味着生成和消费不能完全并行，长度是需要定义的，可以指定先进先出还是先进后出也叫有界队列，在很多场合非常适用。
• LinkedBlockingQueue:基于链表的阻塞队列，同ArrayBlockQueue类似，其内部也维护着一个数据缓冲队列（该队列由一个列表构成），LinkedBlockingQueue 之所以能够高效的处理并发数据，是因为内部实现采用分离锁（读写分离两个锁）从而实现生产者和消费者操作的完全并行运行。它是一个无界队列。
• PriorityBlockingQueue:基于优先级的阻塞队列（优先级的判断通过构造函数传入的Compator 对象来决定，也就是传入队列的对象必须实现Comparable 接口），在实现PriorityBlockingQueue时，内部控制线程同步的锁采用的是公平的锁，它也是一个无界的队列。
• DelayQueue :带有延迟时间的Queue ,其中元素只有当其指定的延迟时间到了，才能够从队列中获取到该元素。DelayQueue 中的元素必须实现Delayed 接口，DelayQueue 是一个没有大小限制的队列，应用场景很多，比如对缓冲超时的数据进行移除、任务超时处理、空闲连接的关闭等等。
• SynchronousQueue :一种没有缓冲的队列，生产者产生的数据直接会被消费者获取并消费。

         1）、 不能添加元素，在有需要的时候即调用take() 时候，可以调用 add() ; 具体的例子如下：

          public static void main(String[] args ){

                final SynchronousQueue<String> q = new SynchronousQueue<String>();

        Thread t1 = new Thread(new Runnable(){             public void run(){                 try {                     System.out.println(q.take());                 } catch (InterruptedException e) {                     // TODO Auto-generated catch block                     e.printStackTrace();                 }             }         });         t1.start();         Thread t2 = new Thread(new Runnable(){             public void run(){                 q.add("abcde");             }         });                  t2.start(); }