Heim > Java > javaLernprogramm > So starten Sie den aktiven MQ-Dienst

So starten Sie den aktiven MQ-Dienst

零下一度
Freigeben: 2017-06-23 09:46:20
Original
5077 Leute haben es durchsucht

1. So starten Sie den aktiven MQ-Dienst

(1), verwenden Sie den Befehl zum Starten

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

(2), Code zum Starten des Brokers

Im Programm können Sie den Broker durch Codierung starten. Wenn Sie mehrere Broker starten möchten, müssen Sie für jeden Broker einen Namen festlegen BrokerService zum Starten des Brokers

    public static void main(String[] args) throws Exception {
        BrokerService broker=new BrokerService();
        broker.setUseJmx(true);
        broker.addConnector("tcp://localhost:61616");
        broker.start();
    }
Nach dem Login kopieren
2. Verwenden Sie BrokerFactory, um den Broker zu starten

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();
    }
Nach dem Login kopieren
broker.properties:
Nach dem Login kopieren
useJmx=true
persistent=false
brokerName=Cheese
Nach dem Login kopieren
3. Verwenden Sie 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>
Nach dem Login kopieren
private static void springStart() throws Exception{
        ApplicationContext context=new ClassPathXmlApplicationContext("spring-activemq.xml");
        BrokerService broker=(BrokerService) context.getBean("jmsBroker");
        broker.start();
    }
Nach dem Login kopieren
<br>
Nach dem Login kopieren

Das obige ist der detaillierte Inhalt vonSo starten Sie den aktiven MQ-Dienst. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Verwandte Etiketten:
Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage