使用ActiveMq构建应用

Posted on | In

Broker：相当于一个ActiveMq服务器实例

命令行启动：activemq start，使用默认的ActiveMq.xml启动

activemq start xbean:file:../conf/ActiveMq-bak.xml：使用指定的配置文件启动

构建java应用

嵌入式broker启动

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
// 使用BrokerService启动
BrokerService brokerService = new BrokerService();
brokerService.setUseJmx(true);
brokerService.addConnector("tcp://47.105.172.68:61616");
brokerService.start();

// 使用BrokerFactory启动
String uri = "properties:broker.properties";
BrokerService broker = BrokerFactory.createBroker(new URI(uri));
broker.addConnector("tcp://47.105.172.68:61616");
broker.start();

// broker.properties
useJmx=true
persistent=false
brokerName=Hia

// 如果需要启动多个broke，需要为每个broke设置不同的名字，链接地址也得区分