acticemq给一个使用的demo
时间: 2023-07-20 21:26:07 浏览: 73
好的,以下是一个使用 ActiveMQ 的 Java Demo:
```java
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
public class ActiveMQDemo {
public static void main(String[] args) throws JMSException {
// 创建连接工厂
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
// 创建连接
Connection connection = connectionFactory.createConnection();
connection.start();
// 创建会话
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建队列
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();
System.out.println("Received message: " + ((TextMessage) receivedMessage).getText());
// 关闭连接
session.close();
connection.close();
}
}
```
此 Demo 实现了一个简单的生产者和消费者,生产者发送一条消息到队列中,消费者从队列中接收消息并输出到控制台。注意,此 Demo 需要在本地启动 ActiveMQ 服务器。
阅读全文