active MQ搭建

ActiveMQ 是Apache出品，最流行的，能力強勁的開源消息總線。ActiveMQ 是一個徹底支持JMS1.1和J2EE 1.4規範的 JMS Provider實現，儘管JMS規範出臺已是好久的事情了，可是JMS在當今的J2EE應用中間仍然扮演着特殊的地位。

1安裝

定義activemq安裝目錄爲/usr/local/activemq

定義activemq數據存放目錄爲 /data/postmall/activemq/

cd /tmp

wget http://archive.apache.org/dist/activemq/apache-activemq/5.4.1/apache-activemq-5.4.1-bin.tar.gz

tar -zxvf apache-activemq-5.4.1-bin.tar.gz

mv activemq /usr/local/

vim /usr/local/activemq/conf/activemq.xml

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="/data/postmall/activemq/data" destroyApplicationContextOnStop="true">

<destinationPolicy>

<policyMap>

<policyEntries>

<policyEntry topic=">" producerFlowControl="true" memoryLimit="64mb">

<pendingSubscriberPolicy>

<vmCursor />

</pendingSubscriberPolicy>

</policyEntry>

<policyEntry queue=">" producerFlowControl="true" memoryLimit="64mb">

</policyEntry>

</policyEntries>

</policyMap>

</destinationPolicy>

<managementContext>

<managementContext createConnector="false"/>

</managementContext>

<persistenceAdapter>

<kahaPersistenceAdapter directory="/data/postmall/activemq/data" maxDataFileLength="32mb"/>

</persistenceAdapter>

<transportConnectors>

<transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>

</transportConnectors>

</broker>

<import resource="jetty.xml"/>

</beans>

2 啓動ActiveMQ

/usr/local/activemq/bin/activemq setup /home/web/.activemqrc

/usr/local/activemq/bin/activemq start

檢查activemq是否已經啓動並查看日誌是否正常

ps -ef | grep active

tail -fn 100 /usr/local/activemq/data/activemq.log

/usr/local/activemq/bin/activemq stop

 3  Activemq 啓動腳本

# su - web

Web> cat activemq_61616_restart.sh

#!/bin/bash

# restart activemq port 61616

cd

/usr/local/activemq1/bin/activemq stop

if [ -f /usr/local/activemq1/data/activemq.pid ]

then

rm -f /usr/local/activemq1/data/activemq.pid

fi

sleep 5

/usr/local/activemq1/bin/activemq start