ActiveMQ简单入门(新手必看篇)
程序员文章站
2023-12-19 14:06:40
一、创建一个简单的hello world案例
首先需要导入activemq-all-5.14.5.jar包,写生产端:
package com.ietree.m...
一、创建一个简单的hello world案例
首先需要导入activemq-all-5.14.5.jar包,写生产端:
package com.ietree.mq.helloworld; import javax.jms.connection; import javax.jms.connectionfactory; import javax.jms.deliverymode; import javax.jms.destination; 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 exception { // 第一步:建立connectionfactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可,默认端口为:tcp://localhost:61616 connectionfactory connectionfactory = new activemqconnectionfactory(activemqconnectionfactory.default_user, activemqconnectionfactory.default_password, "tcp://localhost:61616"); // 第二步:通过connectionfactory工厂对象我们创建一个connection链接,并且调用connectionfactory的start方法开启链接,connection默认是关闭的 connection connection = connectionfactory.createconnection(); connection.start(); // 第三步:通过connection对象创建session会话(上下文环境对象),用于接收消息,参数配置1为是否启用事务,参数配置2为签收模式,一般我们设置为自动签收 session session = connection.createsession(boolean.false, session.auto_acknowledge); // 第四步:通过session创建destination对象,指的是一个客户端用来指定生产消息目标和消费信息来源的对象,在ptp模式中,destination被称作queue即队列;在pub/sub模式,destination被称作topic即主题。在程序中可以使用多个queue和topic。 destination destination = session.createqueue("queue1"); // 第五步:我们需要通过session对象创建消息的发送和接收对象(生产者和消费者)messageproducer/messageconsumer。 messageproducer messageproducer = session.createproducer(destination); // 第六步:我们可以使用messageproducer的setdeliverymode方法为其设置持久化特性和非持久化特性(deliverymode) messageproducer.setdeliverymode(deliverymode.non_persistent); // 第七步:最后我们使用jms规范的textmessage形式创建数据(通过session对象),并用messageproducer的send方法发送数据。同理,客户端使用receive方法进行接收数据,最后需要关闭connection连接。 for (int i = 0; i < 5; i++) { textmessage textmessage = session.createtextmessage(); textmessage.settext("我是消息内容......" + i); messageproducer.send(textmessage); system.out.println("生产者:" + textmessage.gettext()); } if (connection != null) { connection.close(); } } }
写消费端:
package com.ietree.mq.helloworld; import javax.jms.connection; import javax.jms.connectionfactory; import javax.jms.destination; import javax.jms.messageconsumer; import javax.jms.session; import javax.jms.textmessage; import org.apache.activemq.activemqconnectionfactory; public class receiver { public static void main(string[] args) throws exception { // 第一步:建立connectionfactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可,默认端口为:tcp://localhost:61616 connectionfactory connectionfactory = new activemqconnectionfactory(activemqconnectionfactory.default_user, activemqconnectionfactory.default_password, "tcp://localhost:61616"); // 第二步:通过connectionfactory工厂对象我们创建一个connection链接,并且调用connectionfactory的start方法开启链接,connection默认是关闭的 connection connection = connectionfactory.createconnection(); connection.start(); // 第三步:通过connection对象创建session会话(上下文环境对象),用于接收消息,参数配置1为是否启用事务,参数配置2为签收模式,一般我们设置为自动签收 session session = connection.createsession(boolean.false, session.auto_acknowledge); // 第四步:通过session创建destination对象,指的是一个客户端用来指定生产消息目标和消费信息来源的对象,在ptp模式中,destination被称作queue即队列;在pub/sub模式,destination被称作topic即主题。在程序中可以使用多个queue和topic。 destination destination = session.createqueue("queue1"); // 第五步:我们需要通过session对象创建消息的发送和接收对象(生产者和消费者)messageproducer/messageconsumer。 messageconsumer messageconsumer = session.createconsumer(destination); while (true) { textmessage msg = (textmessage) messageconsumer.receive(); if(msg == null){ break; } system.out.println("接收到的内容:" + msg.gettext()); } if (connection != null) { connection.close(); } } }
通过http://localhost:8161/admin/queues.jsp路径查看消息消费情况。
二、activemq 安全机制
activemq的web管理界面:http://127.0.0.1:8161/admin
activemq管控台使用jetty部署,所以需要修改密码则需要到相应的配置文件:apache-activemq-5.14.5\conf\jetty-realm.properties
activemq应该设置有安全机制,只有符合认证的用户才能进行发送和获取消息,所以我们也可以在activemq.xml里添加安全验证配置,apache-activemq-5.14.5\conf\jetty-realm.properties\activemq.xml,在123行之后添加一个插件配置即可。
以上这篇activemq简单入门(新手必看篇)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。