目录

一、broker是什么

二、启动broker时指定配置文件

三、嵌入式Broker

（一）Pom.xml

（二）Broker实例

（三）验证

一、broker是什么

相当于一个ActiveMQ服务器实例。说白了，Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java代码中，以便随时用随时启动，在用的时候再去启动这样能节省了资源，也保证了可用性。这种方式，我们实际开发中很少采用，因为他缺少太多了东西，如：日志，数据存储等等。

二、启动broker时指定配置文件

启动broker时指定配置文件，可以帮助我们在一台服务器上启动多个broker。实际工作中一般一台服务器只启动一个broker。

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

三、嵌入式Broker

（一）Pom.xml

    org.apache.activemqactivemq-all5.15.9org.apache.xbeanxbean-spring3.16com.fasterxml.jackson.corejackson-databind2.10.1org.slf4jslf4j-api1.7.30ch.qos.logbacklogback-classic1.2.11org.projectlomboklombok1.16.16junitjunit4.12test

（二）Broker实例

public class EmbedBroker {public static void main(String[] args) throws Exception {//activemq也支持在vm中通信基于嵌入式BrokerBrokerService brokerService = new BrokerService();brokerService.setUseJmx(true);brokerService.addConnector("tcp://localhost:61616"); //嵌入java，所以地址是本机brokerService.start();}}

启动

（三）验证

生产者和消费者做以下修改

//    public static final String ACTIVEMQ_URL = "tcp://193.179.123.10:61616";public static final String ACTIVEMQ_URL = "tcp://localhost:61616";public static final String QUEUE_NAME = "queue01";

总结：Broker实例相当于一个小型的activemq，且可以无缝嵌入Java代码，这正体现了Java的强大

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！