一、如何啟動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(); }
<br>
#
以上是如何啟動active MQ 服務的詳細內容。更多資訊請關注PHP中文網其他相關文章!