您好,欢迎来到站长目录(28sn.com)!


ActiveMQ入门代码

来源:网络整理 浏览:327次 时间:2021-09-21

Hello world程序演示:

生产者:

package com.mq.helloworld;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Sender {    public static void main(String[] args) throws JMSException {        //第一步:建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可。默认端口为"tcp://localhost:61616"        ConnectionFactory connectionfactory=new ActiveMQConnectionFactory(                ActiveMQConnectionFactory.DEFAULT_USER,                ActiveMQConnectionFactory.DEFAULT_PASSWORD,                "tcp://localhost:61616"                );        //第二步:通过ConnectionFactory工厂对象,我们创建一个Connection连接,并且调用Connection的start方法开启连接,Connection默认是关闭的        Connection connection = connectionfactory.createConnection();        connection.start();        //第三步:通过Connection对象创建Session会话(上下文环境对象),用于接收消息,参数配置1为是否启用事务,参数配置2为签收模式,一般设置为手动签收        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        //第四步:通过Session创建Destination对象,指的是一个客户端用来指定生产消息目标和消费消息来源的对象,在PTP模式中,Destination被称为Queue即队列;在Pub/Sub模式中,Destination被称作Topic即主题,在程序中可以使用多个Queue和Topic        Destination destinition=session.createQueue("queue1");        //第五步:我们需要通过Session对象创建消息的发送和接收对象(生产者和消费者)MessageProducer/MessageConsumer        MessageProducer messageProducer = session.createProducer(destinition);        //第六步:我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode)        messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);        //第七步:最后我们使用JMS规范的TextMessage形式创建数据(通过Session对象),并用MessageProducer的send方法发送数据        TextMessage textMessage = session.createTextMessage();        textMessage.setText("Hello World!");        messageProducer.send(textMessage);        if(connection!=null){            connection.close();        }    }}     

消费者:

package com.mq.helloworld;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.MessageConsumer;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Receiver {    public static void main(String[] args) throws JMSException {        //第一步:建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可。默认端口为"tcp://localhost:61616"        ConnectionFactory connectionfactory=new ActiveMQConnectionFactory(                ActiveMQConnectionFactory.DEFAULT_USER,                ActiveMQConnectionFactory.DEFAULT_PASSWORD,                "tcp://localhost:61616"                );        //第二步:通过ConnectionFactory工厂对象,我们创建一个Connection连接,并且调用Connection的start方法开启连接,Connection默认是关闭的        Connection connection = connectionfactory.createConnection();        connection.start();        //第三步:通过Connection对象创建Session会话(上下文环境对象),用于接收消息,参数配置1为是否启用事务,参数配置2为签收模式,一般设置为自动签收        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        //第四步:通过Session创建Destination对象,指的是一个客户端用来指定生产消息目标和消费消息来源的对象,在PTP模式中,Destination被称为Queue即队列;在Pub/Sub模式中,Destination被称作Topic即主题,在程序中可以使用多个Queue和Topic        Destination destinition=session.createQueue("queue1");        //第五步:我们需要通过Session对象创建消息的发送和接收对象(生产者和消费者)MessageProducer/MessageConsumer        MessageConsumer messageConsumer = session.createConsumer(destinition);        //第六步:最后我们使用JMS规范的TextMessage形式接收数据        while (true) {            TextMessage msg=(TextMessage) messageConsumer.receive();            System.out.println(msg.getText());            if(msg==null) break;        }                if(connection!=null){            connection.close();        }    }}

 安全认证机制:

在activemq.xml文件中的broker节点中的末尾增加下面的内容

        <plugins>            <simpleAuthenticationPlugin>                <users>                    <authenticationUser username="bhz" password="bhz" groups="users,admins"/>                </users>            </simpleAuthenticationPlugin>        </plugins>

然后,再访问MQ时就需要认证了,在生产者和消费者第一步中将default_user、default_password换成配置文件中自定义的username和password即可访问MQ。

生产者详解:

消费者详解:

 

推荐站点

  • 我爱发烧音乐我爱发烧音乐

    我爱发烧音乐囊括了从流行音乐到古典音乐多个类型的音乐作品,专栏推荐最新的音乐,提供音乐排名榜单!可供免费线上收听音乐,歌曲流畅,音效极佳! 网站提供的钢琴以及二胡专栏,可供收听者,陶冶情操,改善心情,是难得的轻音乐典藏!

    www.520fs.com
  • 世纪音乐网世纪音乐网

    世纪音乐网是专业的在线音乐试听MP3下载网站。歌曲总计30余万首,收录了网上最新歌曲和流行音乐,DJ舞曲,非主流音乐,经典老歌,劲舞团歌曲,搞笑歌曲,儿童歌曲,英文歌曲等。是您上网听歌的最佳网站。

    www.ssjj.com
  • 杭州网杭州网

      杭州网是杭州地区唯一的新闻门户网站,由中共杭州市委宣传部、杭州日报报业集团和杭州广播电视集团共同组建的杭州网络传媒有限公司运营。

    www.hangzhou.com.cn
  • 深圳在线深圳在线

      深圳在线 www.szol.net是深圳本地最大、最早的地方生活资讯网站之一,网站名“深圳在线www.szol.net”由南方报业传媒集团编辑委员会总编辑、南方日报社总编辑、南方都市报总编辑、南方书画院名誉院长王春芙亲笔题名,深圳在线www.szol.net团队与深圳热线www.szonline.net、奥一网www.oeeee.com都源于全国最早成立于1996年的知名网络公司——深圳万用网。

    www.szol.net
  • 今题网今题网

     今题网- 中国领先的社区服务网,提供社区服务, 在线交友和商家推广服务,于2004年创建上线,公司现有员工超过百名。今题网自成立以来,凭借其独特的定位和丰富的社区交友功能, 凭借其团队超强的搜索引擎优化技术吸引超过千万的用户成为今题网的注册会员。

    www.jinti.com

鄂公网安备 42062502000001号