java mq在哪里启动_如何启动active MQ 服务

一、如何启动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"?>tcp://localhost:61616

private static void springStart() throws Exception{

ApplicationContext context=new ClassPathXmlApplicationContext("spring-activemq.xml");

BrokerService broker=(BrokerService) context.getBean("jmsBroker");

broker.start();

}