在Java開(kāi)發(fā)中，我們經(jīng)常需要使用隊(duì)列來(lái)實(shí)現(xiàn)高效的異步消息傳遞，以及實(shí)現(xiàn)多線(xiàn)程之間的數(shù)據(jù)共享，這時(shí)候我們就會(huì)用到Java的并發(fā)隊(duì)列和MQ消息隊(duì)列。那么這兩者有哪些區(qū)別呢？

Java的并發(fā)隊(duì)列是Java并發(fā)包中提供的一組線(xiàn)程安全的隊(duì)列，它實(shí)現(xiàn)了一些高效的隊(duì)列算法，例如CAS（Compare-and-Swap）算法、CLH（Craig、Landin、Hagersten）鎖，提供了高性能的并發(fā)隊(duì)列操作。在Java的并發(fā)隊(duì)列中，常用的有ArrayBlockingQueue、LinkedBlockingQueue、PriorityBlockingQueue、DelayQueue、SynchronousQueue等。

ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
queue.put(1);
int value = queue.take();
System.out.println(value);

MQ消息隊(duì)列是一種分布式、跨進(jìn)程、跨服務(wù)器的消息傳遞機(jī)制。MQ消息隊(duì)列采用了異步通信模型，解決了不同進(jìn)程之間的耦合和依賴(lài)關(guān)系，同時(shí)實(shí)現(xiàn)了高可用、高并發(fā)、高吞吐量的消息傳遞。在Java中，常用的MQ消息隊(duì)列有ActiveMQ、RabbitMQ、Kafka、RocketMQ等。

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("test");
MessageProducer producer = session.createProducer(queue);
TextMessage message = session.createTextMessage("Hello, World!");
producer.send(message);
session.close();
connection.close();

從上面的代碼可以看出：Java的并發(fā)隊(duì)列適合于在進(jìn)程內(nèi)部進(jìn)行數(shù)據(jù)共享，而MQ消息隊(duì)列適合于跨進(jìn)程、跨服務(wù)器的異步消息傳遞。