Windows安装activeMQ和MQ的简单使用

 时间:2024-10-03 23:25:37

ApacheActiveMQ是Apache软件基金会所研发的开放源代码消息中间件;由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行。

工具/原料

Windows系统的电脑

activeMQ

方法/步骤

1、首先下载Act坡纠课柩iveMQ(下载地址:http://activemq.apache.org/components/cl锾攒揉敫assic/download/)安装包并解压,点击解压文件进入bin目录,根据电脑系统是32位还是64位,进入相应的win32或win64目录中,执行activemq.bat文件就可以。出现下图说明安装成功:

Windows安装activeMQ和MQ的简单使用

2、开始验证是否能够正常运行:打开浏览器输入http://127.0.0.1:8161/admin/,默认账号密码为admin和admin,输入完后出现下图:说明能够正常运行。

Windows安装activeMQ和MQ的简单使用

3、那么怎么修改他的账号密码呢?在ActiveMQ根目录下的conf目录里面的admin:admin,admin(对应格式为账号:密码,角色)改为自己需求的账号密码,ActiveMQ提供默认的两种角色admin和user。根据自己的需求选择。

Windows安装activeMQ和MQ的简单使用

Windows安装activeMQ和MQ的简单使用

4、ActiveMQ还会开启几个端口,端口个数跟版本有关系,想要修改端口号可以在如下图中的文件里面改。

Windows安装activeMQ和MQ的简单使用

5、改jetty.xml文件里面的端口号,则后台管理地址的端口号也需要相应的作上改动。如将8161改为9999,则后台管理地址则需要变为http://127.0.0.1:8161/admin/

Windows安装activeMQ和MQ的简单使用

6、改activemq.xml文件里面的端口号这改的是tcp,amqp,stomp,mqtt和ws等协议传输的相应端口。

Windows安装activeMQ和MQ的简单使用

7、用默认的方式给ActiveMQ写入进站消息。publicstaticvoid葡矩酉缸main(String[]args)t茑霁酌绡hrowsException{//获取mq连接工程ActiveMQConnectionFactoryactiveMQConnectionFactory=newActiveMQConnectionFactory("admin","admin","tcp://127.0.0.1:61616");//对应账号密码//创建连接并启动ConnectioncreateConnection=activeMQConnectionFactory.createConnection();createConnection.start();//创建默认的会话工厂Sessionsession=createConnection.createSession(false,Session.AUTO_ACKNOWLEDGE);//创建队列Destinationdestination=session.createQueue("msg");MessageProducerproducer=session.createProducer(destination);producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);senMsg(session,producer,"我是生产者。");}publicstaticvoidsenMsg(Sessionsession,MessageProducerproducer,Stringmsg)throwsJMSException{TextMessagetextMessage=session.createTextMessage("你好!"+msg);producer.send(textMessage);}

8、如下图:下面tcp://127.0.0.1:61616中的端口号就是步骤6中提到的如果修改第一个的端口号相应的这边端口号也需要修改。

Windows安装activeMQ和MQ的简单使用

9、MQ出栈消息的获取:publicstaticvoidm瞢铍库祢ain(String[]args)t茑霁酌绡hrowsJMSException{ActiveMQConnectionFactoryactiveMQConnectionFactory=newActiveMQConnectionFactory("admin","admin","tcp://127.0.0.1:61616");//这个是MQ真正的后台通讯地址。ConnectioncreateConnection=activeMQConnectionFactory.createConnection();createConnection.start();Sessionsession=createConnection.createSession(false,Session.AUTO_ACKNOWLEDGE);Destinationdestination=session.createQueue("msg");MessageConsumerconsumer=session.createConsumer(destination);while(true){//监听消息知道队列中的消息全部输出完跳出TextMessagetextMessage=(TextMessage)consumer.receive();if(textMessage!=null){System.out.println("消费者获取到消息:"+textMessage.getText());}else{break;}}}

10、上面就是简单MQ的小技巧,小知识,希望你们能用上。

路由器能正常上网,网上邻居不能访问的解决方法 vmware虚拟机安装ghost版xp-黑屏错误及解决方法 win如何开启远程协助? 怎样检查D盘的文件系统错误? Windows Update自动从网络搜索下载驱动
热门搜索
无迹遮韩国漫画免费天天漫画 爱心的图片 圆形图片 怪怪守护神漫画 水瓶座图片