JMS 之 Active MQ 启动嵌入式Broke详解编程语言

一、如何启动active MQ 服务

(一)、使用命令启动

   a、/usr/local/activemq-5.9.0/bin 目录下 ./activemq start   默认使用conf/activemq.xml 配置文件 
   b、[[email protected] 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://www.springframework.org/schema/beans/spring-beans-2.0.xsd 
    http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd 
    http://camel.apache.org/schema/spring 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(); 
    }

 

原创文章,作者:奋斗,如若转载,请注明出处:https://blog.ytso.com/tech/pnotes/16307.html

(0)
上一篇 2021年7月19日 19:09
下一篇 2021年7月19日 19:09

相关推荐

发表回复

登录后才能评论