ActiveMQ 使用示例：发送和接收消息

以下是一个简单的 ActiveMQ 使用示例，包括如何创建连接、创建队列、发送和接收消息：

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;

public class ActiveMQDemo {

  public static void main(String[] args) throws JMSException {
    // 创建连接工厂
    ConnectionFactory factory = new ActiveMQConnectionFactory('tcp://localhost:61616');
    // 创建连接
    Connection connection = factory.createConnection();
    // 启动连接
    connection.start();
    // 创建会话
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    // 创建目标，即队列
    Destination destination = session.createQueue('test.queue');
    // 创建生产者
    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 receivedTextMessage = (TextMessage) receivedMessage;
      System.out.println('Received message: ' + receivedTextMessage.getText());
    }
    // 关闭连接
    connection.close();
  }

}

此代码演示了如何使用 ActiveMQ 连接到本地 ActiveMQ 代理，创建一个名为 'test.queue' 的队列，将 'Hello, ActiveMQ!' 消息发送到该队列，然后接收该消息。您需要将 'tcp://localhost:61616' 替换为您的 ActiveMQ 代理的地址。