ActiveMQ 5.ActiveMQ的Broker

ActiveMQ

@Author:hanguixian

@Email:[email protected]

五 ActiveMQ的Broker

1 是什么

• 相当于一个ActiveMQ服务器实例
• Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java代码中，以便随用随启，达到了节约资源的目的，同时也保证了可靠性。

2 嵌入式Broker

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

2.1 代码

• pom.xml

<dependencies>
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-all</artifactId>
      <version>5.15.10</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-databind -->
    <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-databind</artifactId>
      <version>2.10.0</version>
    </dependency>
</dependencies>
           

• BrokerServer

import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.BrokerService;

public class ActiveBrokerServer {

    public static void main(String[] args) throws Exception {
        //activeMQ也支持在VM中通信给予嵌入式的broker
        BrokerService brokerService = new BrokerService() ;
        brokerService.setUseJmx(true);
        //这相当与在本地启动了一个activeMQ服务，端口：61616
        brokerService.addConnector("tcp://localhost:61616") ;
        brokerService.start();
    }
}