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();
相關文章
相關標籤/搜索