java activemq 发送 消息

Java中使用ActiveMQ发送消息

ActiveMQ是一个流行的开源消息中间件，它可以在Java应用程序之间进行异步通信。通过ActiveMQ，我们可以实现消息的传递、发布/订阅模式等功能。本文将介绍如何在Java中使用ActiveMQ发送消息，包括搭建ActiveMQ环境、创建消息发送者等操作。

1. 搭建ActiveMQ环境

首先，我们需要下载ActiveMQ并解压到本地。然后进入ActiveMQ的bin目录，运行以下命令启动ActiveMQ服务：

./activemq start

启动完成后，我们可以通过访问 http://localhost:8161/admin 来访问ActiveMQ的管理界面，以便监控消息队列的状态。

2. 创建消息发送者

接下来，我们将创建一个Java程序作为消息发送者，用于向ActiveMQ发送消息。首先，我们需要添加ActiveMQ的依赖：

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

然后，编写消息发送者的代码：

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;

public class MessageSender {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = factory.createConnection();
        connection.start();
        
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = session.createProducer(session.createTopic("test"));
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        
        TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
        producer.send(message);
        
        session.close();
        connection.close();
    }
}

在上面的代码中，我们通过ActiveMQ的ConnectionFactory来创建Connection，然后创建Session和MessageProducer，并发送一条消息到名为"test"的主题。

3. 运行程序

最后，我们可以编译并运行MessageSender.java文件，向ActiveMQ发送消息。在程序运行后，可以在ActiveMQ的管理界面中查看到消息队列中的消息。

javac MessageSender.java
java MessageSender

总结

通过本文的介绍，我们了解了如何在Java中使用ActiveMQ发送消息。首先，我们搭建ActiveMQ环境并启动ActiveMQ服务；然后，创建一个消息发送者程序，通过ActiveMQ的API向消息队列发送消息。希望本文能帮助您在实际项目中使用ActiveMQ进行消息通信。