ActiveMQ简易入门
发表于:2024-10-21 作者:千家信息网编辑
千家信息网最后更新 2024年10月21日,ActiveMQ官方下载地址:http://activemq.apache.org/download.html下载解压后,执行bin目录下activemq.bat启动mq服务找到lib目录并引入相关j
千家信息网最后更新 2024年10月21日ActiveMQ简易入门
ActiveMQ官方下载地址:http://activemq.apache.org/download.html
下载解压后,执行bin目录下activemq.bat启动mq服务
找到lib目录并引入相关jar包
Sender消息发送者类
package com.ycj.activemq;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageProducer;import javax.jms.Session;import org.apache.activemq.ActiveMQConnectionFactory;public class Sender { private static final String MQ_USER = "admin"; private static final String MQ_PWD = "admin"; private static final String MQ_URL = "tcp://localhost:61616"; private static final String MQ_QUEUE_DEFAULT = "testQueue"; public static void main(String[] args) throws JMSException { // 创建JMS连接工厂 ConnectionFactory factory = new ActiveMQConnectionFactory(MQ_USER, MQ_PWD, MQ_URL); // 通过工厂获取链接并启动 Connection connection = factory.createConnection(); connection.start(); // 创建session Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); // 创建destination 消息目的地 Destination destination = session.createQueue(MQ_QUEUE_DEFAULT); // 根据destination初始化一个生产者 MessageProducer producer = session.createProducer(destination); // 生产者消息不持久化 producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); // 生成消息 并发送 Message msg1 = session.createTextMessage("I'm msg1"); Message msg2 = session.createTextMessage("I'm msg2"); producer.send(msg1); producer.send(msg2); session.commit(); connection.close(); System.out.println("producer send msg done!"); }}
Receiver消息接收者类
package com.ycj.activemq;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.MessageConsumer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Receiver { private static final String MQ_USER = "admin"; private static final String MQ_PWD = "admin"; private static final String MQ_URL = "tcp://localhost:61616"; private static final String MQ_QUEUE_DEFAULT = "testQueue"; public static void main(String[] args) throws JMSException { // 创建JMS连接工厂 ConnectionFactory factory = new ActiveMQConnectionFactory(MQ_USER, MQ_PWD, MQ_URL); // 通过工厂获取链接并启动 Connection connection = factory.createConnection(); connection.start(); // 创建session Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); // 创建destination 消息目的地 Destination destination = session.createQueue(MQ_QUEUE_DEFAULT); // 根据destination初始化一个消费者 MessageConsumer consumer = session.createConsumer(destination); while (true) { TextMessage msg = (TextMessage) consumer.receive(1000*1000); if (null != msg) { System.out.println("message has been received:" + msg.getText()); } } }}
依次运行Receiver和Sender,控制台输出:
Sender
Receiver
打开浏览器输入http://localhost:8161/admin/index.jsp,选择Queues可以监控队列消费情况
消息
工厂
生产者
目录
目的
目的地
链接
消费
生产
发送者
地址
官方
情况
接收者
控制台
浏览器
消费者
队列
控制
服务
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
中控软件 数据库
连云港网络安全类型
深圳门禁软件开发服务
艾瑞数据库怎么查
房友中介数据库版本
北京赛车软件开发
警告 服务器
网络技术的发端于欧洲
2003服务器双网卡设置
开展网络安全宣传讲座
数据库正在使用中能备份吗
c 聊天软件开发
延吉市网络安全周
从整个数据库查一个名字
做单机数据库系统用什么语言
北京在线软件开发
合肥网络软件开发公司电话
软件开发结果报告
网络安全管理员的单词
iphone云服务器连接
db2导出数据库工具下载
服务器是网络的什么系统
地下城正在连接服务器然后就闪退
望远县政务软件开发联系电话
浦东新区信息化软件开发包括什么
战雷服务器连接错误
长大后想从事软件开发
阿里云服务器的管理和维护
网络技术和实战经验哪个好
服务器能查到名字吗