深入浅出JMS(三)--ActiveMQ简单的HelloWorld实例

Myth丶恋晨 2022-06-09 13:47 217阅读 0赞

第一篇博文[深入浅出JMS(一)–JMS基本概念][JMS_JMS]，我们介绍了JMS的两种消息模型：点对点和发布订阅模型，以及消息被消费的两个方式：同步和异步，JMS编程模型的对象，最后说了JMS的优点。

第二篇博文[深入浅出JMS(二)–ActiveMQ简单介绍以及安装][JMS_ActiveMQ]，我们介绍了消息中间件ActiveMQ，安装，启动，以及优缺点。

这篇博文，我们使用ActiveMQ为大家实现一种点对点的消息模型。如果你对点对点模型的认识较浅，可以看一下第一篇博文的介绍。

JMS其实并没有想象的那么高大上，看完这篇博文之后，你就知道什么叫简单，下面直接进入主题。

### 开发环境 ###

我们使用的是ActiveMQ 5.11.1 Release的Windows版，官网最新版是ActiveMQ 5.12.0 Release，大家可以自行下载，[下载地址][Link 1]。

需要注意的是，开发时候，要将apache-activemq-5.11.1-bin.zip解压缩后里面的activemq-all-5.11.1.jar包加入到classpath下面，这个包包含了所有jms接口api的实现。

### 搭建开发环境 ###

*  建立项目   
    我们只需要建立一个java项目就可以了，导入jar包，项目截图：   
    ![这里写图片描述][20150920171843767]

点对点的消息模型，只需要一个消息生成者和消息消费者，下面我们编写代码。

*  编写生产者

package com.tgb.activemq;
    
    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.ActiveMQConnection;
    import org.apache.activemq.ActiveMQConnectionFactory;
    /** * 消息的生产者（发送者） * @author liang * */
    public class JMSProducer { 
    
        //默认连接用户名
        private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;
        //默认连接密码
        private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;
        //默认连接地址
        private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;
        //发送的消息数量
        private static final int SENDNUM = 10;
    
        public static void main(String[] args) {
            //连接工厂
            ConnectionFactory connectionFactory;
            //连接
            Connection connection = null;
            //会话 接受或者发送消息的线程
            Session session;
            //消息的目的地
            Destination destination;
            //消息生产者
            MessageProducer messageProducer;
            //实例化连接工厂
            connectionFactory = new ActiveMQConnectionFactory(JMSProducer.USERNAME, JMSProducer.PASSWORD, JMSProducer.BROKEURL);
    
            try {
                //通过连接工厂获取连接
                connection = connectionFactory.createConnection();
                //启动连接
                connection.start();
                //创建session
                session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
                //创建一个名称为HelloWorld的消息队列
                destination = session.createQueue("HelloWorld");
                //创建消息生产者
                messageProducer = session.createProducer(destination);
                //发送消息
                sendMessage(session, messageProducer);
    
                session.commit();
    
            } catch (Exception e) {
                e.printStackTrace();
            }finally{
                if(connection != null){
                    try {
                        connection.close();
                    } catch (JMSException e) {
                        e.printStackTrace();
                    }
                }
            }
    
        }
        /** * 发送消息 * @param session * @param messageProducer 消息生产者 * @throws Exception */
        public static void sendMessage(Session session,MessageProducer messageProducer) throws Exception{
            for (int i = 0; i < JMSProducer.SENDNUM; i++) {
                //创建一条文本消息 
                TextMessage message = session.createTextMessage("ActiveMQ 发送消息" +i);
                System.out.println("发送消息：Activemq 发送消息" + i);
                //通过消息生产者发出消息 
                messageProducer.send(message);
            }
    
        }
    }
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17
       18
       19
       20
       21
       22
       23
       24
       25
       26
       27
       28
       29
       30
       31
       32
       33
       34
       35
       36
       37
       38
       39
       40
       41
       42
       43
       44
       45
       46
       47
       48
       49
       50
       51
       52
       53
       54
       55
       56
       57
       58
       59
       60
       61
       62
       63
       64
       65
       66
       67
       68
       69
       70
       71
       72
       73
       74
       75
       76
       77
       78
       79
       80
       81
       82
       83
       84
       85
       86
       87
       88
       89
       90

*  编写消费者

package com.tgb.activemq;
    
    import javax.jms.Connection;
    import javax.jms.ConnectionFactory;
    import javax.jms.Destination;
    import javax.jms.JMSException;
    import javax.jms.MessageConsumer;
    import javax.jms.Session;
    import javax.jms.TextMessage;
    
    import org.apache.activemq.ActiveMQConnection;
    import org.apache.activemq.ActiveMQConnectionFactory;
    /** * 消息的消费者（接受者） * @author liang * */
    public class JMSConsumer { 
    
        private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默认连接用户名
        private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默认连接密码
        private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//默认连接地址
    
        public static void main(String[] args) {
            ConnectionFactory connectionFactory;//连接工厂
            Connection connection = null;//连接
    
            Session session;//会话 接受或者发送消息的线程
            Destination destination;//消息的目的地
    
            MessageConsumer messageConsumer;//消息的消费者
    
            //实例化连接工厂
            connectionFactory = new ActiveMQConnectionFactory(JMSConsumer.USERNAME, JMSConsumer.PASSWORD, JMSConsumer.BROKEURL);
    
            try {
                //通过连接工厂获取连接
                connection = connectionFactory.createConnection();
                //启动连接
                connection.start();
                //创建session
                session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                //创建一个连接HelloWorld的消息队列
                destination = session.createQueue("HelloWorld");
                //创建消息消费者
                messageConsumer = session.createConsumer(destination);
    
                while (true) {
                    TextMessage textMessage = (TextMessage) messageConsumer.receive(100000);
                    if(textMessage != null){
                        System.out.println("收到的消息:" + textMessage.getText());
                    }else {
                        break;
                    }
                }
    
            } catch (JMSException e) {
                e.printStackTrace();
            }
    
        }
    }
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17
       18
       19
       20
       21
       22
       23
       24
       25
       26
       27
       28
       29
       30
       31
       32
       33
       34
       35
       36
       37
       38
       39
       40
       41
       42
       43
       44
       45
       46
       47
       48
       49
       50
       51
       52
       53
       54
       55
       56
       57
       58
       59
       60
       61
       62
       63
       64

### 运行 ###

1.  首先，启动ActiveMQ，如何启动ActiveMQ如何启动，请看第二篇博文。在浏览器中输入：[http://localhost:8161/admin/][http_localhost_8161_admin]，然后开始执行：
2.  运行发送者，eclipse控制台输出，如下图：   
    ![这里写图片描述][20150920173405956]   
    此时，我们先看一下ActiveMQ服务器，Queues内容如下：   
    ![这里写图片描述][20150920173620033]  
    我们可以看到创建了一个名称为HelloWorld的消息队列，队列中有10条消息未被消费，我们也可以通过Browse查看是哪些消息，如下图：   
    ![这里写图片描述][20150920174135335]  
    如果这些队列中的消息，被删除，消费者则无法消费。
3.  我们继续运行一下消费者，eclipse控制台打印消息，如下：   
    ![这里写图片描述][20150920174317150]   
    此时，我们先看一下ActiveMQ服务器，Queues内容如下：   
    ![这里写图片描述][20150920174417511]  
    我们可以看到HelloWorld的消息队列发生变化，多一个消息者，队列中的10条消息被消费了，点击Browse查看，已经为空了。   
    点击Active Consumers，我们可以看到这个消费者的详细信息：   
    ![这里写图片描述][20150920175100179]

我们的实例到此就结束了，大家可以自己多点ActiveMQ服务器的内容，进一步熟悉ActiveMQ。

### 总结 ###

这篇博文我们实现了点对点的消息模型以及发送的一个同步消息，是不是非常的简单？

下面博文，我们将实现一个ActiveMQ和Spring整合的实例。

[源码下载][Link 2]

转载自： [**http://blog.csdn.net/jiuqiyuliang/article/details/48608237**][http_blog.csdn.net_jiuqiyuliang_article_details_48608237]

[JMS_JMS]: http://blog.csdn.net/jiuqiyuliang/article/details/46701559
[JMS_ActiveMQ]: http://blog.csdn.net/jiuqiyuliang/article/details/47160259
[Link 1]: http://activemq.apache.org/download-archives.html
[20150920171843767]: /images/20220609/1c1a1fbbf3d54416a4bb07f7dc4d553a.png
[http_localhost_8161_admin]: http://localhost:8161/admin/
[20150920173405956]: /images/20220609/0fe1fec12cfb457d8d5e23f2bdd5818d.png
[20150920173620033]: /images/20220609/a3b4df1776844a4facae0de3d95c4456.png
[20150920174135335]: /images/20220609/b80110b4feb0468bb9ce0b519cc88322.png
[20150920174317150]: /images/20220609/eb1bc8db62944efe87affe9dbeab5ce7.png
[20150920174417511]: /images/20220609/1240302b0df44b38966428e4e648c7e2.png
[20150920175100179]: /images/20220609/786860e5fb4c42c0b03ee6c824fce18b.png
[Link 2]: http://download.csdn.net/detail/jiuqiyuliang/9122251
[http_blog.csdn.net_jiuqiyuliang_article_details_48608237]: http://blog.csdn.net/jiuqiyuliang/article/details/48608237