Java操作JMS：ActiveMQ集成指南

在当今的企业级应用开发中，消息队列（Message Queue）扮演着至关重要的角色。它不仅能够实现系统间的解耦，还能提高系统的可扩展性和可靠性。ActiveMQ作为一款流行的开源消息中间件，广泛应用于各种分布式系统中。本文将详细介绍如何在Java项目中集成ActiveMQ，并通过JMS（Java Message Service）进行消息的发送和接收。

环境准备

首先，确保你已经安装了Java开发环境（JDK）和Maven构建工具。接下来，创建一个新的Maven项目，并在pom.xml中添加ActiveMQ和JMS的依赖：

<dependencies>
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-core</artifactId>
        <version>5.7.0</version>
    </dependency>
    <dependency>
        <groupId>javax.jms</groupId>
        <artifactId>jms</artifactId>
        <version>1.1</version>
    </dependency>
</dependencies>

ActiveMQ服务器启动

在开始编写代码之前，需要启动ActiveMQ服务器。可以从ActiveMQ官网下载并解压，然后运行以下命令启动：

bin/activemq start

默认情况下，ActiveMQ服务器会监听tcp://localhost:61616端口。

编写Java代码

创建连接工厂

首先，创建一个ActiveMQConnectionFactory对象，用于建立与ActiveMQ服务器的连接：

import org.apache.activemq.ActiveMQConnectionFactory;

public class JmsProducer {
    public static void main(String[] args) {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        // 后续代码
    }
}

创建连接和会话

通过连接工厂创建连接，并开启一个会话：

import javax.jms.Connection;
import javax.jms.Session;

public class JmsProducer {
    public static void main(String[] args) {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        try (Connection connection = factory.createConnection();
             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
            // 后续代码
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

创建目的地

在JMS中，目的地可以是队列（Queue）或主题（Topic）。这里以队列为例：

import javax.jms.Queue;
import javax.jms.Destination;

public class JmsProducer {
    public static void main(String[] args) {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        try (Connection connection = factory.createConnection();
             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
            Queue queue = session.createQueue("testQueue");
            // 后续代码
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

发送消息

创建一个消息生产者，并发送消息：

import javax.jms.MessageProducer;
import javax.jms.TextMessage;

public class JmsProducer {
    public static void main(String[] args) {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        try (Connection connection = factory.createConnection();
             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
            Queue queue = session.createQueue("testQueue");
            MessageProducer producer = session.createProducer(queue);
            TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
            producer.send(message);
            System.out.println("Message sent: " + message.getText());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

接收消息

创建一个消息消费者，并接收消息：

import javax.jms.MessageConsumer;
import javax.jms.Message;

public class JmsConsumer {
    public static void main(String[] args) {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        try (Connection connection = factory.createConnection();
             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)) {
            Queue queue = session.createQueue("testQueue");
            MessageConsumer consumer = session.createConsumer(queue);
            connection.start();
            Message message = consumer.receive(1000);
            if (message instanceof TextMessage) {
                TextMessage textMessage = (TextMessage) message;
                System.out.println("Received: " + textMessage.getText());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}