1 Star 0 Fork 0

le1024 / le1024

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
8_activemq-Broker.md 1.01 KB
一键复制 编辑 原始数据 按行查看 历史
le1024 提交于 2022-04-28 10:27 . m

什么是Broker

Broker是实现ActiveMQ功能的一个实例。以代码的形式去创建启动一个Broker,就可以当做一个微型的mq服务器传递消息。

通过conf启动不同的activemq实例

# 复制一份activemq.xml
cp activemq.xml activemq02.xml

# 通过activemq02.xml启动mq
./activemq start xbean:file:/home/activemq/conf/activemq02.xml

//多个实例同理
image-20210814230720737

实现broker

public static void main(String[] args) throws Exception {
        /**
         * 启动这个broker之后,demo1 demo2中的broker_url就可以改成tcp://localhost:61616
         * 用这个broker启动的微型的activemq服务来传递消息
         */
        BrokerService brokerService = new BrokerService();
        brokerService.setUseJmx(true);
        brokerService.addConnector("tcp://localhost:61616");
        brokerService.start();
    }
1
https://gitee.com/le1024/le1024.git
git@gitee.com:le1024/le1024.git
le1024
le1024
le1024
master

搜索帮助