当前位置 博文首页 > 文章内容

    ActiveMQ的Broker

    作者: 栏目:未分类 时间:2020-08-11 14:00:16

    本站于2023年9月4日。收到“大连君*****咨询有限公司”通知
    说我们IIS7站长博客,有一篇博文用了他们的图片。
    要求我们给他们一张图片6000元。要不然法院告我们

    为避免不必要的麻烦,IIS7站长博客,全站内容图片下架、并积极应诉
    博文内容全部不再显示,请需要相关资讯的站长朋友到必应搜索。谢谢!

    另祝:版权碰瓷诈骗团伙,早日弃暗投明。

    相关新闻:借版权之名、行诈骗之实,周某因犯诈骗罪被判处有期徒刑十一年六个月

    叹!百花齐放的时代,渐行渐远!



    是什么?
    相当于一个ActiveMQ服务器实例
    说白了,Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java代码中,以便随时用随时启动,在用的时候再去启动这样能节省资源,也保证了可用性

    使用多个配置文件启动activemq

    cp activemq.xml  activemq02.xml 
    // 以active02 启动mq 服务器
    ./activemq start xbean:file:/myactivemq/apache-activemq-5.15.9/conf/activemq02.xml
    

    把小型 activemq 服务器嵌入到 java 代码: 不在使用linux 的服务器

    需要的包

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

    代码实现

    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();
        }
    }