我要评论mq简单实现（为网络简单版）
public class MqServer { public static void main(String[] args) throws InterruptedException { //定义消息队列容器 LinkedBlockingDeque<String> blockingDeque = new LinkedBlockingDeque<>(); //创建生产者线程 Thread producer = new Thread(()->{ //相对列存放内容 for (int msg=0 ; msg<10 ;msg++){ blockingDeque.offer(msg+""); System.out.println(Thread.currentThread().getName()+",向mq服务端存入："+msg); } },"生产者线程"); //主线程等待生产者投递消息全部完成，开始继续向下执行 producer.start(); producer.join(); //创建消费者线程 new Thread(() -> { //自旋 for (;;){ String mgs = blockingDeque.poll(); if (mgs==null){ return; } System.out.println(Thread.currentThread().getName()+",从mq服务器取出消息："+mgs); } },"生产者线程").start(); } } 本文地址：https://blog.csdn.net/qq_38009686/article/details/108036322
您可能感兴趣的文章:
如您对本文有疑问或者有任何想说的，请点击进行留言回复，万千网友为您解惑！
网友评论