ActiveMQ(一)--简介

xiaoxiao2021-03-01  17

一、简介

消息中间件(Message Oriented Middleware, MOM)

不使用MOM,那么系统A调用系统B,这是一种同步调用,A系统会等待B系统的返回,然后A系统才能继续执行。 使用MOM,系统A调用系统B,这是一种异步调用。A把消息发到MOM之后,就不管了,继续往下执行。  

二、安装和启动

去官网下载Linux的包,放到Linux的安装目录,解压即可。

启动:   cd bin       ./activemq start

检查是否启动:访问http://192.168.25.128:8161/admin/       用户名和密码都是:admin

三、发消息实例

<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.12.0</version> </dependency> <dependency> <groupId>org.apache.xbean</groupId> <artifactId>xbean-spring</artifactId> <version>3.4</version> </dependency> import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class QueueSender { public static void main(String[] args) throws JMSException, InterruptedException { ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.128:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("my-queue"); MessageProducer producer = session.createProducer(destination); for (int i = 0; i < 3; i++) { TextMessage message = session.createTextMessage("message--" + i); producer.send(message); } session.commit(); session.close(); connection.close(); } } import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class QueueReceiver { public static void main(String[] args) throws JMSException { ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.128:61616"); Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("my-queue"); MessageConsumer consumer = session.createConsumer(destination); int i = 0; while (i < 3) { i++; TextMessage message = (TextMessage) consumer.receive(); session.commit(); System.out.println("收到的消息:" + message.getText()); } session.close(); connection.close(); } }

 

 

 

转载请注明原文地址: https://www.6miu.com/read-3450194.html

最新回复(0)