消息中间件之ActiveMQ

Posted 2020-10-25

一，简介
ActiveMQ是较优秀的JMS实现框架，在异步消息通信方面有简单便捷，性能良好的优点。

二，安装
下载地址：http://mirror.bit.edu.cn/apache/activemq/
解压即可

三，启动
windows启动
linux启动

四，java应用
依赖的包：activemq-all-5.12.0.jar
发送消息：
// 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar<br/>ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(<br/>ActiveMQConnection.DEFAULT_USER,<br/>ActiveMQConnection.DEFAULT_PASSWORD,<br/>"tcp://localhost:61616");<br/>// 构造从工厂得到连接对象<br/>Connection connection = connectionFactory.createConnection();<br/>// 启动<br/>connection.start();<br/>// 获取操作连接<br/>Session session = connection.createSession(Boolean.TRUE,<br/>Session.AUTO_ACKNOWLEDGE); <br/>Destination destination = session.createQueue("FirstQueue");<br/>// 得到消息生成者【发送者】<br/>MessageProducer producer = session.createProducer(destination);<br/>// 设置不持久化，此处学习，实际根据项目决定<br/>producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); <br/>
到此生产者对象生成，下一步发送数据
//创建消息<br/>TextMessage message = session<br/>.createTextMessage("ActiveMq 发送的消息");<br/>//发送<br/>producer.send(message);<br/>
消费者接受数据
创建连接如上
`//消息消费者对象
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