ActiveMQ的消息模式——队列模式（Queue）

shery 发布于2019-08-15 15:41 / 2675人阅读

摘要：一队列模式特点客户端包括生产者和消费者队列中的消息只能被一个消费者消费消费者可以随时消费队列中的消息二创建过程创建连接创建会话通过来创建其它的将生产者和消费者都会指向目标生产者向目标发送消息消费者设置监听器，监听消息。

前言

此处的代码只是简化理解，实际项目会结合Spring使用。

一、队列模式特点

客户端包括生产者和消费者

队列中的消息只能被一个消费者消费

消费者可以随时消费队列中的消息

二、创建过程

1.创建连接Connection
2.创建会话Session
3.通过Session来创建其它的（MessageProducer、MessageConsumer、Destination、TextMessage）
4.将生产者 MessageProducer 和消费者 MessageConsumer 都会指向目标 Destination
5.生产者向目标发送TextMessage消息send()
6.消费者设置监听器，监听消息。

三、代码实现

1. 创建Maven项目




    4.0.0

    com.jms
    jms-test
    1.0-SNAPSHOT
    
    
    
        
            org.apache.activemq
            activemq-all
            5.9.0

2. 生产者 AppProducer.java

public class AppProducer {
    private static final String url = "tcp://127.0.0.1:61616";
    private static final String queueName = "queue-test";

    public static void main(String[] args) throws JMSException {
        //1.创建ConnectionFactory
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        //2.创建Connection
        Connection connection = connectionFactory.createConnection();
        //3.启动连接
        connection.start();
        //4.创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5.创建一个目标
        Destination destination = session.createQueue(queueName);
        //6.创建一个生产者
        MessageProducer producer = session.createProducer(destination);
        for (int i = 0; i < 10; i++) {
            //7.创建消息
            TextMessage textMessage = session.createTextMessage("test" + i);
            //8.发布消息
            producer.send(textMessage);

            System.out.println("发送消息"+textMessage.getText());
        }

        //9.关闭连接
        connection.close();

    }
}

3. 消费者 AppConsumer.java

消费者的连接Connection是不能关闭的，因为消息的接收是异步的，会导致消息不能被消费。

public class AppConsumer {
    private static final String url = "tcp://127.0.0.1:61616";
    private static final String queueName = "queue-test";

    public static void main(String[] args) throws JMSException {
        //1. 创建ConnectionFactory
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        //2. 创建Connection
        Connection connection = connectionFactory.createConnection();
        //3. 启动连接
        connection.start();
        //4. 创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5. 创建一个目标
        Destination destination = session.createQueue(queueName);
        //6. 创建一个消费者
        MessageConsumer consumer = session.createConsumer(destination);
        //7. 创建一个监听器
        consumer.setMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                try {
                    System.out.println("接收消息  = [" + ((TextMessage) message).getText() + "]");
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });

        //8.关闭连接（消费者的连接不允许关闭的，因为消息的接收是异步的，会导致消息不能被消费）
        //connection.close();
    }
}

四、运行查看 1. 运行生产者 AppProducer

运行AppProducer.java后会发现队列中添加了10条消息，如下图：

2. 开启消费者 AppConsumer

运行AppConsumer.java后会发现队列中的10条消息被消费了，如下图：

3.开启两个消费者后，运行生产者

会发现生产者发送的10个消息，被两个消费者平分了。
AppConsumer1

接收消息  = [test1]
接收消息  = [test3]
接收消息  = [test5]
接收消息  = [test7]
接收消息  = [test9]

AppConsumer2

接收消息  = [test0]
接收消息  = [test2]
接收消息  = [test4]
接收消息  = [test6]
接收消息  = [test8]

五、队列模式和主题模式的区别

是否需要提前订阅
队列模式：消费者不需要提前订阅也可以消费消息
主题模式：只有提前进行订阅的消费者才能成功消费消息

多个消费者如何分配消息
队列模式：只能平均消费消息，被别的消费者消费的消息不能重复被其他的消费者消费
主题模式：每个订阅者都可以消费主题模式中的每一条消息

服务器托管云服务器消息队列activemq activemq消息队列队列queue 阿里的消息队列

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/69209.html

慕课网_《Java消息中间件》学习总结

摘要：时间年月日星期六说明本文部分内容均来自慕课网。这个时候，可以启动多台积分系统，来同时消费这个消息中间件里面的登录消息，达到横向扩展的作用。时间：2017年07月22日星期六说明：本文部分内容均来自慕课网。@慕课网：http://www.imooc.com教学源码：无学习源码：https://github.com/zccodere/s... 第一章：课程介绍 1-1 课程安排 Java...

twohappy 2019-08-15 11:00 评论0 收藏0
消息队列ActiveMQ的使用详解

摘要：学习消息队列的使用之前，我们先来搞清。是操作消息的接口。消息生产者由创建，并用于将消息发送到。接收消息打印结果这是接收到的消息消费者启动。。。。通过上一篇文章《消息队列深入解析》，我们已经消息队列是什么、使用消息队列的好处以及常见消息队列的简单介绍。这一篇文章，主要带大家详细了解一下消息队列ActiveMQ的使用。学习消息队列ActiveMQ的使用之前，我们先来搞清JMS。 J...

niceforbear 2019-08-15 15:40 评论0 收藏0
消息中间件及ActiveMQ介绍

摘要：中间件的分类基于远程过程调用的中间件。基于对象请求代理的中间件。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。一.中间件 1.1 什么是中间件? 由于业务、机构和技术是不断变化的，因此为其服务的软件系统必须适应这样的变化。在合并、添加服务或扩展可用服务之后，公司可能无力负担重新创建信息系统所需的成本。正是在...

jaysun 2019-08-15 17:48 评论0 收藏0
JMS 在 SpringBoot 中的使用

摘要：本文主要讲述消息服务在中的使用。所以需要一个监听容器工厂的概念，即接口，它会引用上面创建好的与的连接工厂，由它来负责接收消息以及将消息分发给指定的监听器。为了消费消息，订阅者必须保持运行的状态。 JMS 在 SpringBoot 中的使用摘要：本文属于原创，欢迎转载，转载请保留出处：https://github.com/jasonGeng88/blog> 本文所有服务均采用doc...

Michael_Ding 2019-08-14 18:43 评论0 收藏0
Spring boot 集成 ActiveMQ

摘要：安装到官方网站下载最新的的安装包，并解压到本地目录下，下载链接如下。修改消费者使用配置消费者监听的队列，其中是接收到的消息收到的报文为接收到的消息重新执行安装ActiveMQ 到Apache官方网站下载最新的ActiveMQ的安装包，并解压到本地目录下，下载链接如下：http://activemq.apache.org/do...。showImg(https://segmentfau...

Donne 2019-08-19 11:43 评论0 收藏0