文档章节

ActiveMQ实现消息发布者

CharlesYG
 CharlesYG
发布于 2017/05/15 20:12
字数 510
阅读 7
收藏 0

####创建ActiveMQ消息生产者

  1. 创建一个普通的Java项目。

  2. 引入ActiveMQ jar包 这里引入的是 activemq-all-5.14.5.jar 在ActiveMQ安装包里面有。

  3. 简单代码如下所示:

public class MQProducers {
    private static final int NUM = 10;
    public static void main(String[] args) {
        ConnectionFactory connectionFactory;//连接工厂 
        Connection connection=null;//连接
        Session session;//会话
        Destination destination;//消息目的地
        MessageProducer messageProducer;//消息生产者
        //实例化工厂 这里采用的是ActiveMQ 默认的用户名、密码、服务器连接地址  生产环境下 需在ActiveMQ服务器上进行配置。
        connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, ActiveMQConnection.DEFAULT_BROKER_URL);
        try {
            connection = connectionFactory.createConnection();//创建连接
            connection.start();//启动
            session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);//设置支持事务,ACK设置:消息自动签收
            destination = session.createQueue("mq.queue");//创建消息目的地
            messageProducer = session.createProducer(destination);//创建消息生产者
            sendMsg(session, messageProducer);//发送消息
            session.commit();//提交事务
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            if(connection!=null){
                try {
                    connection.close();//关闭和ActiveMQ的连接
                } catch (JMSException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }   
        }
    }
    /**
     * 发送消息
     * @param session
     * @param messageProducer
     * @throws JMSException
     */
    public static void sendMsg(Session session,MessageProducer messageProducer) throws JMSException{
        for (int i = 0; i < NUM; i++) {
            TextMessage message =  session.createTextMessage("发送消息:"+i);
            System.out.println("发送ActiveMQ消息:"+i);
            messageProducer.send(message);
        }
    }  
}

####代码解释
3.1. ConnectionFactory 创建ActiveMQ服务器连接工厂
3.2 connection = connectionFactory.createConnection(); 创建ActiveMQ服务器连接
3.3 connection.setClientID("消费者1"); 设置连接名,这一步也不是必须的,可以忽略,ActiveMQ会自动生成一个连接名
3.4 connection.start(); 启动ActiveMQ服务器连接
3.5 connection.createSession(true, Session.AUTO_ACKNOWLEDGE); 创建连接会话,这里采用事务模式接收消息
3.6 Destination destination = session.createQueue("mq.queue"); 通过连接会话创建消息目的地
3.7 MessageProducer messageProducer = session.createProducer(destination); 通过连接会话创建消息生产者
3.8 TextMessage message = session.createTextMessage("发送消息:"+i); 通过会话来创建一个文本消息
3.9 messageProducer.send(message); 消息生产者向Active服务器发送消息

总结

这里主要简单得展示了如何创建一个消息生产者并发送消息,下一篇将介绍我们如何创建一个消息消费者接收ActiveMQ消息。

© 著作权归作者所有

CharlesYG
粉丝 1
博文 27
码字总数 28667
作品 0
闵行
高级程序员
私信 提问
ActiveMQ初探(1)——介绍与基本使用

一、ActiveMQ 1.1 什么是ActiveMQ 是Apache出品,最流行的,能力强劲的。ActiveMQ是一个完全支持和规范的 实现,尽管规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊...

yuanlaijike
2018/04/15
0
0
ActiveMQ入门以及整合spring boot

一、 ActiveMQ 消息队列的使用 MQ MQ:Message Queue 消息队列,就是用来在系统之间进行消息传递的 这个队列有一系列具体的实现技术:ActiveMQ、rabbitMQ、kafka、RocketMQ(alibaba) HttpCil...

Armymans
2018/11/10
0
0
Docker学习之搭建ActiveMQ消息服务

前言 ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J...

微笑向暖wx
2018/11/09
0
0
Spring Cloud Stream Binder 实现

Spring Cloud Stream Binder 实现 JMS 实现 ActiveMQ 1.增加Maven依赖

xiaoshuaiv5
04/01
0
0
通过 ActiveMQ 演示如何使用 JMS API

消息机制是软件组件和应用程序之间通讯的一种方法,一个消息系统是一个点对点的服务:消息客户端可以发送消息也可以接收消息,每一个客户端连接到一个消息代理,这个代理提供了消息的创建、发...

tsl0922
2012/11/27
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

浅谈跨平台框架Flutter的搭建与运行

作者:个推iOS开发工程师 伊泽瑞尔 Flutter是Google推出的跨平台的解决方案,用以帮助开发者在 Android 和 iOS 两个平台开发高质量原生应用的全新移动 UI 框架。 之前我们为大家介绍了《跨平...

个推
32分钟前
1
0
Spring Boot 面试,一个问题就被干趴下了!

最近LZ面试了不少人,其中不乏说对 Spring Boot 非常熟悉的,然后当我问到一些 Spring Boot 核心功能和原理的时候,没人能说得上来,或者说不到点上,可以说一个问题就问趴下了! 这是我的问...

Java领航员
33分钟前
1
0
U72024 C++初识类

题目 (Circle类)一个圆形的旱冰场地,场地内抹水泥,造价为每平方米20元,围栏用木条围成,每米造价35元。设计一个Circle类,可以求出圆的面积和边长,用户可以此求出旱冰场的造价。请在下...

StupidZhe
今天
9
0
你应该选择哪种树莓派?

本文是《14 天学会树莓派使用》系列文章的第一篇。虽然本系列文章主要面向没有使用过树莓派或 Linux 或没有编程经验的人群,但是肯定有些东西还是需要有经验的读者的,我希望这些读者能够留下...

linux-tao
今天
3
0
动态代理知识详解

动态代理实现的两种方式 给动态代理举个栗子:例如我们平时买笔记本电脑,很多时候都是不从厂家拿货,而是通过经销商买电脑。代理模式出现解决了生产厂家的一些问题,那么这个这个思想在我们...

我叫小糖主
今天
13
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部