Java中高级核心知识全面解析——消息队列（为什么要用消息队列，常见消息队列对比，JMS和AMQP谁更好用？）

在解释为何使用消息队列、对比不同消息队列及提供JMS示例代码之前，我们先来简要概述消息队列的概念和常见应用场景。

消息队列是一种用于存储消息的数据结构，通常是先进先出（FIFO），用于解耦生产者和消费者。

常见应用场景包括：

• 异步处理
• 解耦
• 削峰填谷
• 日志处理
• 事件通知

为什么要使用消息队列？

1. 解耦：消息队列解决了不同系统和模块之间的依赖和通信问题。
2. 异步处理：消息队列提供了异步处理机制，可以提高系统的响应速度。
3. 削峰填谷：消息队列可以缓解高峰期的流量压力，平滑系统负载。
4. 日志处理：消息队列可以用于日志处理和分析。
5. 事件通知：消息队列可以用于事件的通知和订阅。

常见消息队列对比

消息队列特性典型使用场景

Kafka分布式、高吞吐、可持久化、基于Zookeeper管理日志收集、流处理、实时数据分析

RabbitMQ支持AMQP协议、高可用、易用、支持多种消息模式（Work Queues、Publish/Subscribe）异步处理、系统解耦、消息通信

ActiveMQ支持JMS、支持多种协议、支持集群、有良好的管理界面企业级系统消息通信

RocketMQ阿里巴巴开源的消息中间件，特性丰富分布式事务、消息存储、流计算

SQS由Amazon Web Services提供的消息队列服务，支持多种消息协议大规模分布式系统的异步通信

JMS示例代码

以下是使用Java Message Service（JMS）的一个简单示例，演示如何发送和接收消息。

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
 
public class JMSExample {
    public static void main(String[] args) {
        // 创建连接工厂
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
 
        try {
            // 创建连接
            Connection connection = connectionFactory.createConnection();
            connection.start();
 
            // 创建会话
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 
            // 创建目的地（队列/主题）
            Destination destination = session.createQueue("MyQueue");
 
            // 创建生产者
            MessageProducer producer = session.createProducer(destination);
 
            // 创建文本消息
            TextMessage message = session.createTextMessage("Hello, JMS!");
 
            // 发送消息
            producer.send(message);
 
            System.out.println("Message sent");
 
            // 关闭生产者、会话、连接
            producer.close();