编写代码实现Java实现创建ActiveMQ生产者 ？

在Java中创建ActiveMQ生产者，你首先需要添加ActiveMQ的依赖到你的项目中。如果你正在使用Maven，你可以在你的pom.xml文件中添加如下依赖：

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.16.3</version> <!-- 请检查并使用最新的版本 -->
</dependency>

然后，你可以使用以下代码创建一个ActiveMQ生产者：

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

public class ActiveMQProducer {

    private static final String URL = "tcp://localhost:61616";
    private static final String SUBJECT = "MY_QUEUE";

    public static void main(String[] args) {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(URL);
        Connection connection = null;
        Session session = null;
        Destination destination = null;
        MessageProducer producer = null;
        TextMessage message = null;

        try {
            connection = connectionFactory.createConnection();
            connection.start();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            destination = session.createQueue(SUBJECT);
            producer = session.createProducer(destination);
            message = session.createTextMessage("Hello, ActiveMQ!");
            producer.send(message);
            System.out.println("Message sent: " + message.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            try {
                if (producer != null) producer.close();
                if (session != null) session.close();
                if (connection != null) connection.close();
            } catch (JMSException e) {
                e.printStackTrace();
            }
        }
    }
}

这段代码首先创建一个ConnectionFactory对象，该对象用于创建与ActiveMQ服务器的连接。然后，它创建一个连接，并启动它。接下来，它创建一个会话，该会话是发送和接收消息的线程上下文。然后，它创建一个目标（在这种情况下是一个队列），并创建一个生产者，该生产者将消息发送到该目标。最后，它创建一个文本消息，并使用生产者发送它。在发送消息后，它关闭生产者、会话和连接。如果在这些步骤中的任何一步发生异常，它都会捕获JMSException并打印堆栈跟踪。在所有步骤完成后，它确保关闭所有资源。

请注意，你需要将URL和SUBJECT替换为你自己的ActiveMQ服务器地址和队列名称。如果你的ActiveMQ服务器需要用户名和密码，你可以在创建ConnectionFactory时提供它们。例如：new ActiveMQConnectionFactory("tcp://localhost:61616?jms.username=myUser&jms.password=myPass")。