zoukankan      html  css  js  c++  java
  • 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应用。

    简单使用

    1. pom.xml
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
        <version>2.9.5</version>
    </dependency>
    
    1. 嵌入式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();
        }
    }
    
    1. 测试

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

  • 相关阅读:
    pip 安装依赖 requirements.txt
    TCP三次握手四次挥手详细理解附面试题
    装饰器修复技术
    BBS(第一篇)
    Auth模块
    Django--中间件
    cookie和session
    创建多对多表关系的三种方式
    批量插入数据,自定义分页器
    Django--几个重要方法优化(面试重点)
  • 原文地址:https://www.cnblogs.com/huangwenjie/p/12251035.html
Copyright © 2011-2022 走看看