ActiveMQ-inAction-ActiveMQ-学习笔记

Broker java

  • Running Broker
    • ActiveMQ5.0 的二进制发布包中bin目录中包含一个名为activemq的脚本,直接运行这个脚本就能够启动一个broker。
      • sh activemq start 
    • 此外也能够经过Broker Configuration URI或Broker XBean URI对broker进行配置,如下是一些命令行参数的例子:

Example tcp

Description 编码

activemq spa

Runs a broker using the 命令行

default 'xbean:activemq.xml' as code

the broker configuration xml

file. ip

activemq xbean:myconfig.xml ci

Runs a broker using the file it

myconfig.xml as the broker

configuration file that is

located in the classpath.

activemq xbean:file:./conf/broker1.xml

Runs a broker using the file

broker1.xml as the broker

configuration file that is

located in the relative

file

path ./conf/broker1.xml

activemq

xbean:file:C:/ActiveMQ/conf/broker2.xml

Runs a broker using the file

broker2.xml as the broker

 

configuration file that is

located in the absolute

file path C:/ActiveMQ/conf/broker2.

xml

activemq broker:(tcp://localhost:61616,

tcp://localhost:5000)?useJmx=true

Runs a broker with two

transport connectors and JMX enabled.

activemq broker:(tcp://localhost:61616,

network:tcp://localhost:5000)?persistent=f

alse

Runs a broker with 1

transport connector and 1

network connector with

persistence disabled.

Embedded Broker

  • 能够经过在应用程序中以编码的方式启动broker,例如:
  • Java代码 
    • BrokerService broker = new BrokerService();  
      broker.addConnector("tcp://localhost:61616");  
      broker.start();  
  • 若是须要启动多个broker,那么须要为broker设置一个名字。例如:
  • Java代码
    • ​​​​​​​
      BrokerService broker = new BrokerService();   
      broker.setName("fred");   
      broker.addConnector("tcp://localhost:61616");   
      broker.start();
相关文章
相关标签/搜索