<–start–>
使用Java程序操作ActiveMQ生产消息，代码的复杂度较高，但也没有默写下来的必要。
开发ActiveMQ首先需要导入activemq-all.jar包，如果是maven项目，就需要在pom文件中导入坐标。本例中创建的是一个maven项目，所以在pom文件中引入坐标：
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
<version>5.14.0</version>
</dependency>
要测试代码就需要引入juint坐标：
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
Java代码操作ActiveMQ生产消息:
public class ActiveMQProducer {
@Test
public void testProduceMQ() throws Exception {
// 连接工厂
// 使用默认用户名、密码、路径
// 路径 tcp://host:61616
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
// 获取一个连接
Connection connection = connectionFactory.createConnection();
// 建立会话
Session session = connection.createSession(true,
Session.AUTO_ACKNOWLEDGE);
// 创建队列或者话题对象
Queue queue = session.createQueue("HelloWorld");
// 创建生产者 或者 消费者
MessageProducer producer = session.createProducer(queue);
// 发送消息
for (int i = 0; i < 10; i++) {
producer.send(session.createTextMessage("你好，activeMQ:" + i));
}
// 提交操作
session.commit();
}
}
<–end–>