`
newleague
  • 浏览: 1473009 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类

ActiveMQ入门

    博客分类：
  • JMS
 
阅读更多
 

 


1、环境：
Windows XP
apache-activemq-5.2.0-bin.zip
 
2、安装
解压缩到apache-activemq-5.2.0-bin.zip到一个目录，比如C:\apache-activemq-5.2.0
 
3、配置
配置就在C:\apache-activemq-5.2.0\conf目录下三个文件
activemq.xml
credentials.properties
log4j.properties
 
4、启动ActiveMQ
运行C:\apache-activemq-5.2.0\bin\activemq.bat
5、测试
ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否成功启动 netstat -an|find "61616"

C:\Documents and Settings\Administrator>netstat -an|find "61616"
    TCP        0.0.0.0:61616                    0.0.0.0:0                            LISTENING
6、监控
ActiveMQ5.0版本默认启动时，启动了内置的jetty服务器，提供一个demo应用和用于监控ActiveMQ的admin应用。
admin：http://127.0.0.1:8161/admin/
demo：http://127.0.0.1:8161/demo/

下面是ActiveMQ5.2的一个最简单例子！
环境还是apache-activemq-5.2.0-bin.zip，需要注意的是，开发时候，要将apache-activemq- 5.2.0-bin.zip解压缩后里面的activemq-all-5.2.0.jar包加入到classpath下面，这个包包含了所有jms接口 api的实现。

Java代码 复制代码 收藏代码
  1. import org.apache.activemq.ActiveMQConnection;   
  2. import org.apache.activemq.ActiveMQConnectionFactory;   
  3.   
  4. import javax.jms.*;   
  5.   
  6. /**  
  7. * 消息的生产者（发送者）  
  8. *  
  9. */  
  10. public class JmsSender {   
  11.         public static void main(String[] args) throws JMSException {   
  12.                 // ConnectionFactory ：连接工厂，JMS 用它创建连接   
  13.                 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(   
  14.                                 ActiveMQConnection.DEFAULT_USER,   
  15.                                 ActiveMQConnection.DEFAULT_PASSWORD,   
  16.                                 "tcp://192.168.14.117:61616");   
  17.                 //JMS 客户端到JMS Provider 的连接   
  18.                 Connection connection = connectionFactory.createConnection();   
  19.                 connection.start();   
  20.                 // Session： 一个发送或接收消息的线程   
  21.                 Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);   
  22.                 // Destination ：消息的目的地;消息发送给谁.   
  23.                 // 获取session注意参数值my-queue是Query的名字   
  24.                 Destination destination = session.createQueue("my-queue");   
  25.                 // MessageProducer：消息生产者   
  26.                 MessageProducer producer = session.createProducer(destination);   
  27.                 //设置不持久化   
  28.                 producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);   
  29.                 //发送一条消息   
  30.                 sendMsg(session, producer);   
  31.                 session.commit();   
  32.                 connection.close();   
  33.         }   
  34.   
  35.         /**  
  36.          * 在指定的会话上，通过指定的消息生产者发出一条消息  
  37.          *  
  38.          * @param session    消息会话  
  39.          * @param producer 消息生产者  
  40.          */  
  41.         public static void sendMsg(Session session, MessageProducer producer) throws JMSException {   
  42.                 //创建一条文本消息   
  43.                 TextMessage message = session.createTextMessage("Hello ActiveMQ！");   
  44.                 //通过消息生产者发出消息   
  45.                 producer.send(message);   
  46.                 System.out.println("");   
  47.         }   
  48. }  
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
* 消息的生产者（发送者）
*
*/
public class JmsSender {
        public static void main(String[] args) throws JMSException {
                // ConnectionFactory ：连接工厂，JMS 用它创建连接
                ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                                ActiveMQConnection.DEFAULT_USER,
                                ActiveMQConnection.DEFAULT_PASSWORD,
                                "tcp://192.168.14.117:61616");
                //JMS 客户端到JMS Provider 的连接
                Connection connection = connectionFactory.createConnection();
                connection.start();
                // Session： 一个发送或接收消息的线程
                Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
                // Destination ：消息的目的地;消息发送给谁.
                // 获取session注意参数值my-queue是Query的名字
                Destination destination = session.createQueue("my-queue");
                // MessageProducer：消息生产者
                MessageProducer producer = session.createProducer(destination);
                //设置不持久化
                producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
                //发送一条消息
                sendMsg(session, producer);
                session.commit();
                connection.close();
        }

        /**
         * 在指定的会话上，通过指定的消息生产者发出一条消息
         *
         * @param session    消息会话
         * @param producer 消息生产者
         */
        public static void sendMsg(Session session, MessageProducer producer) throws JMSException {
                //创建一条文本消息
                TextMessage message = session.createTextMessage("Hello ActiveMQ！");
                //通过消息生产者发出消息
                producer.send(message);
                System.out.println("");
        }
}
 
Java代码 复制代码 收藏代码
  1. import org.apache.activemq.ActiveMQConnection;   
  2. import org.apache.activemq.ActiveMQConnectionFactory;   
  3.   
  4. import javax.jms.*;   
  5.   
  6. /**  
  7. * 消息的消费者（接受者）  
  8. *  
  9. */  
  10. public class JmsReceiver {   
  11.         public static void main(String[] args) throws JMSException {   
  12.                 // ConnectionFactory ：连接工厂，JMS 用它创建连接   
  13.                 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(   
  14.                                 ActiveMQConnection.DEFAULT_USER,   
  15.                                 ActiveMQConnection.DEFAULT_PASSWORD,   
  16.                                 "tcp://192.168.14.117:61616");   
  17.                 //JMS 客户端到JMS Provider 的连接   
  18.                 Connection connection = connectionFactory.createConnection();   
  19.                 connection.start();   
  20.                 // Session： 一个发送或接收消息的线程   
  21.                 Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);   
  22.                 // Destination ：消息的目的地;消息发送给谁.   
  23.                 // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置   
  24.                 Destination destination = session.createQueue("my-queue");   
  25.                 // 消费者，消息接收者   
  26.                 MessageConsumer consumer = session.createConsumer(destination);   
  27.                 while (true) {   
  28.                         TextMessage message = (TextMessage) consumer.receive(1000);   
  29.                         if (null != message)   
  30.                                 System.out.println("收到消息：" + message.getText());   
  31.                         else  
  32.                                 break;   
  33.                 }   
  34.                 session.close();   
  35.                 connection.close();   
  36.         }   
  37. }  
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
* 消息的消费者（接受者）
*
*/
public class JmsReceiver {
        public static void main(String[] args) throws JMSException {
                // ConnectionFactory ：连接工厂，JMS 用它创建连接
                ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                                ActiveMQConnection.DEFAULT_USER,
                                ActiveMQConnection.DEFAULT_PASSWORD,
                                "tcp://192.168.14.117:61616");
                //JMS 客户端到JMS Provider 的连接
                Connection connection = connectionFactory.createConnection();
                connection.start();
                // Session： 一个发送或接收消息的线程
                Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
                // Destination ：消息的目的地;消息发送给谁.
                // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置
                Destination destination = session.createQueue("my-queue");
                // 消费者，消息接收者
                MessageConsumer consumer = session.createConsumer(destination);
                while (true) {
                        TextMessage message = (TextMessage) consumer.receive(1000);
                        if (null != message)
                                System.out.println("收到消息：" + message.getText());
                        else
                                break;
                }
                session.close();
                connection.close();
        }
}
 
启动ActiveMQ，然后开始执行：
先运行发送者，连续运行了三次，最后一次控制台输出：


Process finished with exit code 0
 
后运行接受者，输出结果：
收到消息Hello ActiveMQ！
收到消息Hello ActiveMQ！
收到消息Hello ActiveMQ！

Process finished with exit code 0
 
注意：
其中的端口61616是ActiveMQ默认的配置，在activemq.xml中，

Xml代码 复制代码 收藏代码
  1. <!-- The transport connectors ActiveMQ will listen to -->  
  2.              <transportConnectors>  
  3.                      <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>  
  4.                      <transportConnector name="ssl" uri="ssl://localhost:61617"/>  
  5.                      <transportConnector name="stomp" uri="stomp://localhost:61613"/>  
  6.                      <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>  
  7.              </transportConnectors>   
   <!-- The transport connectors ActiveMQ will listen to -->
                <transportConnectors>
                        <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
                        <transportConnector name="ssl" uri="ssl://localhost:61617"/>
                        <transportConnector name="stomp" uri="stomp://localhost:61613"/>
                        <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
                </transportConnectors>
 
，建议不要改动，都用这个端口多好，就像ftp都用21端口，也没错。
 
 
这是官方的HelloWorld例子，不过看着不顺眼：
分享到：
| java回调函数
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics