ActiveMq学习⑤__ActiveMq的Broker

news2024/11/27 21:38:34

ActiveMq的Broker

是什么？

相当于一个ActiveMq的服务器实例

Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java 代码中，以便随时用随时启动，在用的时候再去启动这样节省了资源，也保证了可靠性。

按照不同的配置文件启动ActiveMq
[root bin]# ./activemq start xbean:file:/opt/apache-activemq-5.15.9/conf/activemq02.xml

嵌入式的Borker

用ActiveMq Broker 作为独立的消息服务器来构建JAVA应用。
ActiveMQ也支持在VM中通信基于嵌入式的broker，能够无缝的集成其他Java应用

package com.example.activemq.queue;

import org.apache.activemq.broker.BrokerService;

public class EmbedBroker {

    public static void main(String[] args) throws Exception {

//        ActiveMQ也支持在VM中通信基于嵌入式的broker，能够无缝的集成其他Java应用

        BrokerService brokerService = new BrokerService();
        brokerService.setUseJmx(true);
        brokerService.addConnector("tcp://localhost:61616");
        brokerService.start();

    }
}