zoukankan      html  css  js  c++  java
  • JMS 之 Active MQ 启动嵌入式Broke

    一、如何启动active MQ 服务

    (一)、使用命令启动

       a、/usr/local/activemq-5.9.0/bin 目录下 ./activemq start   默认使用conf/activemq.xml 配置文件
       b、[root@localhost bin]# ./activemq start xbean:file:../conf/activemq-slave1.xml  使用指定的配置文件启动

    (二)、代码启动broker

      在程序中可以通过编码的方式启动broker,如果要启动多个broker需要为每一个broker设置名字  broker.setName("brokerOne")

    1、使用BrokerService 启动broker

        public static void main(String[] args) throws Exception {
            BrokerService broker=new BrokerService();
            broker.setUseJmx(true);
            broker.addConnector("tcp://localhost:61616");
            broker.start();
        }

    2、使用BrokerFactory启动broker

    private static void brokerFactoryStart() throws Exception{
            String uri="properties:broker.properties";
            BrokerService broker=BrokerFactory.createBroker(new URI(uri));
            broker.addConnector("tcp://localhost:61616");
            broker.start();
        }
    broker.properties:
    useJmx=true
    persistent=false
    brokerName=Cheese

    3、使用spring

    spring-activemq.xml:

    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:amq="http://activemq.apache.org/schema/core"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
        http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd
        http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
        <bean id="jmsBroker" class="org.apache.activemq.broker.BrokerService" init-method="start" destroy-method="stop">
          <property name="brokerName" value="myBroker"/>
          <property name="persistent" value="false"/>
          <property name="transportConnectorURIs">
              <list>
                  <value>tcp://localhost:61616</value>
              </list>
          </property>
        </bean>
    </beans>
    private static void springStart() throws Exception{
            ApplicationContext context=new ClassPathXmlApplicationContext("spring-activemq.xml");
            BrokerService broker=(BrokerService) context.getBean("jmsBroker");
            broker.start();
        }
  • 相关阅读:
    为什么要用全文搜索引擎:全文搜索引擎 VS 数据库管理系统
    大数据学习路线之hive存储格式
    web测试教程之JavaScript中的变量
    Java学习中面向过程与面向对象的优缺点
    Java教程之Java反射
    Python技术基础知识点:OS模块的应用
    软件测试教程——概念解析及常用方法概说
    UI设计师必备技能 网页中的色彩搭配(色彩篇)
    UI技术分享 如何提高自己的设计视野
    JavaScript学习指南分享
  • 原文地址:https://www.cnblogs.com/jalja/p/7062176.html
Copyright © 2011-2022 走看看