代码拉取完成,页面将自动刷新
什么是Broker
Broker是实现ActiveMQ功能的一个实例。以代码的形式去创建启动一个Broker,就可以当做一个微型的mq服务器传递消息。
通过conf启动不同的activemq实例
# 复制一份activemq.xml
cp activemq.xml activemq02.xml
# 通过activemq02.xml启动mq
./activemq start xbean:file:/home/activemq/conf/activemq02.xml
//多个实例同理
实现broker
public static void main(String[] args) throws Exception {
/**
* 启动这个broker之后,demo1 demo2中的broker_url就可以改成tcp://localhost:61616
* 用这个broker启动的微型的activemq服务来传递消息
*/
BrokerService brokerService = new BrokerService();
brokerService.setUseJmx(true);
brokerService.addConnector("tcp://localhost:61616");
brokerService.start();
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。