ActiveMQ入门案例-生产者代码实现

<–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–>