设为首页 加入收藏

TOP

ActiveMQ入门案例-生产者代码实现
2018-01-01 06:07:10 】 浏览:49
Tags:ActiveMQ 入门 案例 生产者 代码 实现

使用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();


    }
}



编程开发网
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Linux系统编程:简单文件IO操作 下一篇使用 parallel 利用起你的所有 CP..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

最新文章

热门文章

C 语言

C++基础

windows编程基础

linux编程基础

C/C++面试题目