ActiveMQ实战.doc

ActiveMQ实战（）：安装与运行 1 下载与安装 从镜像站点下载ActiveMQ的二进制包： wget /activemq/apache-activemq/5.3.0/apache-activemq-5.3.0-bin.tar.gz 建议把文件放到/usr/local/目录下： cp apache-activemq-5.3.0-bin.tar.gz /usr/local/ 然后解压： tar –xzf apache-activemq-5.3.0-bin.tar.gz 解压后得到一个文件夹apache-activemq-5.3.0。这就是ActiveMQ的安装目录，所有东西都在这里面。 2 启动ActiveMQ 为确保你能够运行ActiveMQ，先修改apache-activemq-5.3.0目录的权限： chmod -R 777 apache-activemq-5.3.0 进入安装目录下的bin文件夹，执行： ./activemq ActiveMQ就启动起来了。 3 验证是否启动成功 ActiveMQ默认使用61616 端口提供JMS服务，使用8161端口作为Web控制台。执行以下命令，查看这两个端口是否启动起来了，如果是，则表明ActiveMQ启动成功。 netstat -ln | grep 61616 netstat -ln | grep 8161 可以通过09:8161/admin 访问ActiveMQ的Web控制台。 4 停止ActiveMQ 首先找到activemq进程的PID： ps –ef | grep activemq 然后kill之： Kill -9 PID ActiveMQ实战（2）：测试其是否正常工作 既然ActiveMQ安装好了并启动成功，接下来我们就编写一个测试程序，向它发送JMS消息，并从它上面接收JMS消息，看看是否能正常工作。 安装目录/usr/local/apache-activemq-5.3.0中，有一个jar包activemq-all-5.3.0.jar，记得把它下载下来，加入到测试程序的CLASSPATH中。 发送JMS消息的程序如下： package jmstest; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnectionFactory; import mand.ActiveMQQueue; /** ?* ?* @author Frank Wen ?*/ public class Send { ?? ?public static void main(String[] args) { ?? ? ? ?ConnectionFactory cf = new ActiveMQConnectionFactory(tcp://09:61616); ?? ? ? ?Connection conn = null; ?? ? ? ?Session session = null; ?? ? ? ?try { ?? ? ? ? ? ?conn = cf.createConnection(); ?? ? ? ? ? ?session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); ?? ? ? ? ? ?Destination destination = new ActiveMQQueue(jms_test_queue); ?? ? ? ? ? ?MessageProducer producer = session.createProducer(destination); ?? ? ? ? ? ?TextMessage message = session.createTextMessage(); ?? ? ? ? ? ?message.setText(Hello World!); ?? ? ? ? ? ?producer.send(message); ?? ? ? ? ? ?System.out.println(Send a message: Hello World!); ?? ? ? ?} catch (JMSException ex) { ?? ? ? ? ? ?ex.print