【ActiveMQ】Broker

 学习视频 

尚硅谷ActiveMQ教程(MQ消息中间件快速入门)

集数：33-34

 学习格言 

练拳不练功，到老一场空；基础不牢，地动山摇。

相当于一个ActiveMQ服务器实例

说白了，Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java代码中，以便随时用随时启动，

在用的时候再去启动这样能节省了资源，也保证了可靠性。

可以通过不同的conf配置文件模拟不同的实例进行启动。

用ActiveMQ Broker作为独立的消息服务器来构建JAVA应用。

ActiveMQ也支持在vm中通信基于嵌入式的broker，能够无缝的集成其它java应用。

 所需依赖

    
    
        org.apache.activemq
        activemq-all
        5.15.15
    
    
        org.apache.xbean
        xbean-spring
        3.16
    

    
        com.fasterxml.jackson.core
        jackson-databind
        2.9.5
    

    
    
        org.slf4j
        slf4j-api
        1.7.25
    
    
        ch.qos.logback
        logback-classic
        1.2.3
    

 测试程序

import org.apache.activemq.broker.BrokerService;

public class EmbedBroker {
    public static void main(String[] args) throws Exception {
        // ActiveMQ 也支持在vm中通讯基于嵌入式的broker
        BrokerService brokerService = new BrokerService();
        brokerService.setUseJmx(true);
        brokerService.addConnector("tcp://localhost:61616");
        brokerService.start();
    }
}

之后，将生产者和消费者的地址换成tcp://localhost:61616，也同样能够使用。就相当于在本机启动一个小型的MQ服务器。