Comment démarrer le service MQ actif

1. Comment démarrer le service MQ actif

(1), utilisez la commande pour démarrer

   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), code pour démarrer le courtier

Dans le programme, vous pouvez démarrer le courtier via le codage. Si vous souhaitez démarrer plusieurs courtiers, vous devez définir un nom pour chaque courtier broker.setName("brokerOne")

1. BrokerService pour démarrer le courtier

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

2. Utilisez BrokerFactory pour démarrer le courtier

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. Utilisez 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>

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!