MQ生产者的java源码

以下是一个简单的MQ生产者Java源码示例：

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

public class MQProducer {
    private static final String QUEUE_NAME = "myQueue";

    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(QUEUE_NAME);

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

        // 创建消息
        TextMessage message = session.createTextMessage("Hello World!");

        // 发送消息
        producer.send(message);

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

在此示例中，我们使用ActiveMQConnectionFactory创建一个连接工厂，并将其连接到本地ActiveMQ代理的tcp端口。我们使用连接工厂创建一个连接，并使用该连接创建一个会话。我们创建一个队列作为目标，然后创建一个生产者来发送消息。最后，我们通过调用producer.send(message)发送消息，并关闭连接。

请注意，在实际使用中，您需要处理异常并正确地关闭连接和其他资源