java整合activemq

Java整合ActiveMQ的步骤如下：

1. 下载ActiveMQ的压缩包，解压到本地目录。

2. 在Java程序中添加ActiveMQ的依赖，可以通过Maven或手动添加jar包的方式。Maven依赖如下：

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.16.0</version>
</dependency>

3. 编写Java代码连接ActiveMQ，并发送/接收消息。

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

public class ActiveMQDemo {
    public static void main(String[] args) throws Exception {
        // 创建连接工厂
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

        // 创建连接，并启动
        Connection connection = connectionFactory.createConnection();
        connection.start();

        // 创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 创建目的地（Queue或Topic）
        Destination destination = session.createQueue("testQueue");

        // 创建消息生产者
        MessageProducer producer = session.createProducer(destination);

        // 发送消息
        TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
        producer.send(message);

        // 创建消息消费者
        MessageConsumer consumer = session.createConsumer(destination);

        // 接收消息
        Message receivedMessage = consumer.receive();
        if (receivedMessage instanceof TextMessage) {
            TextMessage textMessage = (TextMessage) receivedMessage;
            System.out.println("Received message: " + textMessage.getText());
        }

        // 关闭连接
        connection.close();
    }
}

在以上代码中，我们首先创建了一个连接工厂，用于创建连接。然后创建连接，并启动。接下来创建会话和目的地，这里我们使用了Queue。然后创建消息生产者，发送一条消息。最后创建消息消费者，接收一条消息。注意，在这里我们只是接收了一条消息，实际上可以使用MessageConsumer的监听器来实现异步接收消息。最后关闭连接。

4. 启动ActiveMQ服务器，可以使用命令行或ActiveMQ提供的GUI工具来启动。命令行启动方式如下：

cd activemq/bin
./activemq start

5. 运行Java程序，即可看到发送和接收消息的结果。

以上就是Java整合ActiveMQ的基本步骤。需要注意的是，在实际应用中，我们需要考虑消息的持久化、消息的过期时间、消息的重发等问题，以及如何优化消息的性能和可靠性。