>Java >java지도 시간 >활성 MQ 서비스를 시작하는 방법

활성 MQ 서비스를 시작하는 방법

零下一度
零下一度원래의
2017-06-23 09:46:205033검색

1. 활성 MQ 서비스를 시작하는 방법

(1) 명령을 사용하여 시작

   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  使用指定的配置文件启动

(2) 브로커를 시작하는 코드

  프로그램에서 코딩을 통해 브로커를 시작할 수 있습니다. 여러 브로커를 시작하려면 각 브로커에서 이름을 Broker.setName("brokerOne")으로 설정해야 합니다

1. BrokerService를 사용하여 브로커를 시작합니다

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

2 BrokerFactory를 사용하여 브로커를 시작합니다

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>

위 내용은 활성 MQ 서비스를 시작하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.