1.安装activeMQ,直接解压,启动
2.访问localhost:8161/admin/ 用户名密码都是admin
3.点对点消息传递域,每个消息只能一个消费者,消息的生产者与消费者之间没有
时间上的相关性。
4.发布/订阅,每个消息可以有多个消费者,生产者与消费者之间有时间上的相关性
,订阅一个主题的消费者只能消费自它订阅之后发布的消息
5.在点对点消息传递域中,目的地被称为队列(queue);在发布/订阅消息传递域中,目的地
被称为主题(topic)
6.topic分为非持久性消息和持久性消息
7.启动:./activemq start,默认启动的是activemq.xml
指定文件启动:./activemq start xbean:file:../conf/activemq-2.xml
8.broker service启动broker
BrokerService broker = new BrokerService();
broker.setUseJmx(true);
broker.addConnection("tcp://");
broker.start();
9.borkerFactory启动broker
String uri = "properties:broker.properties";
BrokerService broker1 = BrokerFactory.createBroker(new URI(Uri));
broker1.addConnector("tcp://");
broker1.start();
properties内容:
useJms = true
persistent = false
brokerName = Cheese
10.利用Spring集成activeMq
引入:spring-jms
activemq-pool 依赖
配置jmsTemplate
使用模板发送和接收
注:就是将以前的创建工程和会话等等都封装
11.可以实现MessageListener监听,监听消息的发送,去启动接收消息