Java接收MQ消息的具体代码实现

以下是Java接收MQ消息的一个简单代码实现：

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

public class Receiver {
    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("testQueue");
        // 创建消费者
        MessageConsumer consumer = session.createConsumer(destination);
        // 循环接收消息
        while (true) {
            Message message = consumer.receive();
            if (message instanceof TextMessage) {
                String text = ((TextMessage) message).getText();
                System.out.println("Received: " + text);
            } else {
                break;
            }
        }
        // 关闭连接
        connection.close();
    }
}

在上面的代码中，我们使用了ActiveMQ的Java客户端库来创建连接、会话、目标和消费者。使用while循环接收消息，如果收到的消息是文本类型，则将其输出到控制台。最后，我们关闭了连接以释放资源。请注意，这只是一个简单的实现，你需要根据自己的需求进行修改和优化。