欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  Java

如何启动active MQ 服务

程序员文章站 2022-03-20 08:21:23
...
一、如何启动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 服务的详细内容,更多请关注其它相关文章!