• 技术文章 >Java >java教程

    如何启动active MQ 服务

    零下一度零下一度2017-06-23 09:46:20原创3386
    一、如何启动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://activemq.apache.org/schema/core/activemq-core.xsd
         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();
        }

    以上就是如何启动active MQ 服务的详细内容,更多请关注php中文网其它相关文章!

    声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn核实处理。
    专题推荐:Active Broke 嵌入式 启动
    上一篇:反射机制的定义、获取Class三种方法 下一篇:设置Field的类型实例详解
    php培训_php实战培训【立即报名】-php中文网第20期

    相关文章推荐

    • 【活动】充值PHP中文网VIP即送云服务器• 详细了解java多线程机制• Java中的Object类知识点归纳• 一文掌握JAVA 面向对象之多态• 完全掌握Java锁(图文解析)• 深入解析Java中的方法引用
    1/1

    PHP中文网