消息中间件之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-创新互联
本文URL：http://cxhlcq.com/article/ppshh.html