ActiveMQ实战

1、【精品文档】如有侵权，请联系网站删除，仅供学习与交流····· ActiveMQ实战.精品文档.· ActiveMQ实战（linux）：安装与运行· 1 下载与安装从镜像站点下载ActiveMQ的二进制包：wget 建议把文件放到/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、的安装目录，所有东西都在这里面。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 81

3、61可以通过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，记

4、得把它下载下来，加入到测试程序的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.ActiveMQ

5、ConnectionFactory;import mand.ActiveMQQueue; * author Frank Wenpublic class Send     public static void main(String args)         ConnectionFactory cf = new ActiveMQConnectionFactory("tcp:/09:61616");        C

6、onnection conn = null;        Session session = null;        try             conn = cf.createConnection();            session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

7、            Destination destination = new ActiveMQQueue("jms_test_queue");            MessageProducer producer = session.createProducer(destination);            TextMessage message = se

8、ssion.createTextMessage();            message.setText("Hello World!");            producer.send(message);            System.out.println("Send a message: Hello World!"); &

9、#160;       catch (JMSException ex)             ex.printStackTrace();         finally             try                 if(session != null)  &

10、#160;                  session.close();                if(conn != null)                     conn.close();             ca

11、tch (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.Mes

12、sageConsumer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;import mand.ActiveMQQueue; * author Frank Wenpublic class Receive     public static void main(String args)         ConnectionFactory cf

13、 = new ActiveMQConnectionFactory("tcp:/09:61616");        Connection conn = null;        Session session = null;        try             conn = cf.createConnection();

14、0;           session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);            Destination destination = new ActiveMQQueue("jms_test_queue");            MessageConsumer consumer = se

15、ssion.createConsumer(destination);            conn.start();            Message message = consumer.receive();            TextMessage textMessage = (TextMessage) message;      

16、     System.out.println("Receive a message: " + textMessage.getText();         catch (JMSException ex)             ex.printStackTrace();         finally         

17、60;  try                 if(session != null)                     session.close();                if(conn != null)          &#

18、160;          conn.close();             catch (JMSException ex)                 ex.printStackTrace();先后执行以上两个程序，如果能正确发送和接收JMS消息，则表明ActiveMQ正常工作。· ActiveMQ实战（3）：Web控制台的安全性安装好ActiveMQ后，其默认没有任何

19、安全控制，任何人都可以通过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的官方网站下载

20、，下载Jetty6.1.9版本，解压后，在lib里可以找到该文件。2、在$activemq.base/conf/jetty.xml里，加上这么一段：<userRealms>    <jaasUserRealm name="adminRealm" loginModuleName="adminLoginModule" /></userRealms>3、在$activemq.base/conf/目录下新建一个login.config文件，内容如下：adminLoginModule  &

21、#160;  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

22、.base/webapps/admin/WEB-INF/web.xml里，添加如下内容：<security-constraint>    <web-resource-collection>        <web-resource-name>adminRealm</web-resource-name>        <url-pattern>/*</url-pattern>  

23、;  </web-resource-collection>    <auth-constraint>        <role-name>admins</role-name>    </auth-constraint></security-constraint><login-config>      <auth-method>BASIC<

24、;/auth-method>      <realm-name>adminRealm</realm-name></login-config>6、最后，修改$activemq.base/bin/activemq文件，把配置文件添加到环境变量。把ACTIVEMQ_OPTS修改为：ACTIVEMQ_OPTS="$ACTIVEMQ_OPTS $SUNJMX $SSL_OPTS -Djava.security.auth.login.config=$ACTIVEMQ_BASE/conf/login.config&q

25、uot;配置完毕。重启ActiveMQ，在浏览器里打开09:8161/admin，就会弹出一个对话框，要求输入用户名和密码。· ActiveMQ实战（4）：JMS的安全性对于JMS服务的安全控制，ActiveMQ提供两种方式：简单授权方式和JAAS授权方式。我们在这里采用简单的授权方式。如果要实现复杂的权限和角色机制，可以使用JAAS方式，这里不予讲述。JMS安全的配置，在文件$activemq.base/conf/activemq-security.xml中有范例。打开该文件，可以看到，有两个plugins：simpleAuthentication

26、Plugin和authorizationPlugin，后者是JAAS授权方式需要用到的，在这里，我们只需要用到前者。编辑$activemq.base/conf/activemq.xml文件，加入如下一段代码：<plugins>    <simpleAuthenticationPlugin>        <users><authenticationUser username="$activemq.username" password="$activemq.password" groups="users,admins"/