ActiveMQ实战.doc

ActiveMQ实战（linux）：安装与运行 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 61616netstat -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.printStackTrace(); finally try if(session != null) session.close(); if(conn != null) conn.close(); catch (JMSException ex) ex.printStackTrace(); 接收JMS消息的程序如下：package jmstest;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageConsumer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;import mand.ActiveMQQueue;/* author Frank Wen*/public class Receive 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); MessageConsumer consumer = session.createConsumer(destination); conn.start(); Message message = consumer.receive(); TextMessage textMessage = (TextMessage) message; System.out.println(Receive a message: + textMessage.getText(); catch (JMSException ex) ex.printStackTrace(); finally try if(session != null) session.close(); if(conn != null) conn.close(); catch (JMSException ex) ex.printStackTrace(); 先后执行以上两个程序，如果能正确发送和接收JMS消息，则表明ActiveMQ正常工作。 ActiveMQ实战（3）：Web控制台的安全性安装好ActiveMQ后，其默认没有任何安全控制，任何人都可以通过8161端口登录Web控制台，任何人都可以通过61616端口发送和接收JMS消息。在实际应用中，需要由我们自己对ActiveMQ进行安全性配置。首先讲Web控制台的安全性。ActiveMQ默认使用Jetty作为内嵌的Web服务器。当然，你也可以把ActiveMQ的部署到Tomcat、JBoss等其他服务器中。在这里，我们采用默认内嵌的Jetty，并使用JAAS来实现安全控制。1、把 jetty-plus-6.1.9.jar 放到 $activemq.base/lib/web/中。如果你手上没有jetty-plus-6.1.9.jar文件，可以从Jetty的官方网站下载，下载Jetty6.1.9版本，解压后，在lib里可以找到该文件。2、在$activemq.base/conf/jetty.xml里，加上这么一段： 3、在$activemq.base/conf/目录下新建一个login.config文件，内容如下：adminLoginModule org.mortbay.jetty.plus.jaas.spi.PropertyFileLoginModule required debug=true file=$activemq.base/conf/perties;4、在$activemq.base/conf/目录下新建一个perties文件，内容如下：myusername:mypassword,admins该文件的格式是：用户名:密码,角色5、在$activemq.base/webapps/admin/WEB-INF/web.xml里，添加如下内容： adminRealm /* admins BASIC adminRealm6、最后，修改$activemq.base/bin/activemq文件，把配置文件添加到环境变量。把ACTIVEMQ_OPTS修改为：ACTIVEMQ_OPTS=$ACTIVEMQ_OPTS $SUNJMX $SSL_OPTS -Djava.security.auth.login.config=$ACTIVEMQ_BASE/conf/login.config配置完毕。重启ActiveMQ，在浏览器里打开09:8161/admin，就会弹出一个对话框，要求输入用户名和密码。 ActiveMQ实战（4）：JMS的安全性对于JMS服务的安全控制，ActiveMQ提供两种方式：简单授权方式和JAAS授权方式。我们在这里采用简单的授权方式。如果要实现复杂的权限和角色机制，可以使用JAAS方式，这里不予讲述。JMS安全的配置，在文件$activemq.base/conf/activemq-security.xml中有范例。打开该文件，可以看到，有两个plugins：simpleAuthenticationPlugin和authorizationPlugin，后者是JAAS授权方式需要用到的，在这里，我们只需要用到前者。编辑$activemq.base/conf/activemq.xml文件，加入如下一段代码： $activemq.username和$activemq.password是在perties文