消息中间件之ActiveMQ
一,简介
ActiveMQ是较优秀的JMS实现框架,在异步消息通信方面有简单便捷,性能良好的优点。
公司主营业务:做网站、成都网站制作、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。创新互联公司是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联公司推出城中免费做网站回馈大家。
二,安装
下载地址:http://mirror.bit.edu.cn/apache/activemq/
解压即可
三,启动
windows启动
linux启动
四,java应用
依赖的包:activemq-all-5.12.0.jar
发送消息:// 构造ConnectionFactory实例对象,此处采用ActiveMq的实现jar
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://localhost:61616");
// 构造从工厂得到连接对象
Connection connection = connectionFactory.createConnection();
// 启动
connection.start();
// 获取操作连接
Session session = connection.createSession(Boolean.TRUE,
Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("FirstQueue");
// 得到消息生成者【发送者】
MessageProducer producer = session.createProducer(destination);
// 设置不持久化,此处学习,实际根据项目决定
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
到此生产者对象生成,下一步发送数据//创建消息
TextMessage message = session
.createTextMessage("ActiveMq 发送的消息");
//发送
producer.send(message);
消费者接受数据
创建连接如上
`//消息消费者对象
MessageConsumer consumer = session.createConsumer(destination);
//接收消息
TextMessage message = (TextMessage) consumer.receive(100000);
`
五,消息管理
自带管理:http://127.0.0.1:8161/admin/
用户名密码:默认用户名密码admin,admin
设置
管理页面主要几个菜单:
1,home:当前ActiveMq的信息,名称,id,版本等
2,queues:在当前消息中运行的队列,以及队列的生产者,消费者数目,入队出队消息数目等
3,topic
4,Subscribers
5,Connections
网页标题:消息中间件之ActiveMQ
新闻来源:http://scyanting.com/article/iigcjs.html