20200202 ActiveMQ 5. ActiveMQ的Broker

ActiveMQ 5. ActiveMQ的Broker

5.1. 是什么

相当于一个ActiveMQ服务器实例。

Broker 就是实现了用代码形式启动 ActiveMQ 将 MQ 内嵌到 Java 代码中，可以随时启动，节省资源，提高了可靠性。

5.2. 使用指定配置文件启动ActiveMQ

# 复制配置文件
cp activemq.xml activemq02.xml
# 使用指定配置文件启动ActiveMQ
./bin/activemq start xbean:file:/myactivemq/apache-activemq-5.15.11/conf/activemq02.xml 
# 验证启动成功
lsof -i:61616

5.3. 嵌入式Broker

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

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

简单使用

pom.xml

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.9.5</version>
</dependency>

嵌入式Broker代码实现

public class Embebroker {

    public static void main(String[] args) throws Exception {
        // broker 服务
        BrokerService brokerService = new BrokerService();

        // 把小型 activemq 服务器嵌入到 java 代码
        brokerService.setUseJmx(true);

        // 原本的是 192.……  是linux 上的服务器，而这里是本地windows 的小型mq 服务器
        brokerService.addConnector("tcp://localhost:61616");

        brokerService.start();
    }
}

测试

将之前的生产者和消费者代码中的ACTIVEMQ_URL从tcp://192.168.181.128:61616/修改为tcp://localhost:61616/。