文档章节

ActiveMQ点对点模式的浅谈

dev_chao
 dev_chao
发布于 2017/04/10 17:02
字数 234
阅读 9
收藏 0

activemq点对点模式,如果有多个消费者,它是如何保证消息不会重复消费的?

首先看queues:

Number Of Consumers  消费者的数量,如果打开了2个会话,每个会话2个consumer,则该值为4。
Number Of Pending Messages  等待消费的消息数,即当前未出队列的数量。
Messages Enqueued  进入队列的消息的总数量,包括已经消费了的。 
Messages Dequeued  出了队列的消息的总数量,可以理解为是消费者消费掉的数量。

再看下consumers的情况:

可以知道,ActiveMQ把消息分发到不同队列里,每个队列都有1个消费者。如果消费者停止消费,分发了的消息将会重新被分发到其他消费者的队列。消费者主动拉取消息,这样保证了消息不会被多个消费者得到。

© 著作权归作者所有

共有 人打赏支持
dev_chao
粉丝 3
博文 36
码字总数 11158
作品 0
广州
私信 提问
Linux 安装ActiveMQ(使用Mac远程访问)

阅读本文需要安装JDK 一 ActiveMQ简介 activemq是用java语言编写的一款开源消息总线 activemq是apache出品 activemq消息的传递有两种类型 一种是点对点(即一个生产者和一个消费者一一对应) 另...

梦三
07/15
0
0
消息队列篇—详谈ActiveMQ消息队列模式的分析及使用

消息队列(Message Queue)是分布式系统中重要的组件,通用使用场景可以简单地描述为当不需要立即获得结果,但是并发量需控制时就需要使用消息队列。消息列队有两种消息模式,一种是点对点的...

afreon
04/22
0
0
深入浅出 消息队列 ActiveMQ

一、 概述与介绍 ActiveMQ 是Apache出品,最流行的、功能强大的即时通讯和集成模式的开源服务器。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现。提供客户端支持跨语言和...

亮liang
2015/05/27
0
0
JMS配置说明-----activeMQ-5.6

1 简介 activeMQ是一个完全支持JMS1.1 和J2EE规范的JMS Provider实现; 尽管规范出台已经是很久的事情了,但JMS在当今的J2EE应用中仍然扮演着特殊的地位; 特性列表 多种语言和协议编写客户端...

次渠龙哥
06/26
0
0
爬虫架构 | 消息队列应用场景及ActiveMQ、RabbitMQ、RocketMQ、Kafka对比

前言:在之前的业务中,使用了Kafka和RabbitMQ两种消息队列,这篇文章来做一个总结。 消息队列中间件是分布式系统中重要的组件,主要实现异步消息,应用解耦,流量削峰及消息通讯等功能。 下...

小怪聊职场
04/26
0
0

没有更多内容

加载失败,请刷新页面

加载更多

ElasticJob自定义注解注册任务

一,我们需要自定义个注解 @Target({ElementType.TYPE})@Retention(RetentionPolicy.RUNTIME)public @interface ElasticSimpleJob { @AliasFor("cron") public abstract Str......

满风
19分钟前
1
0
架构师必备,带你弄清混乱的JAVA日志体系

引言 还在为弄不清 commons-logging-xx.jar 、 log4j-xx.jar 、 sl4j-api-xx.jar 等日志框架之间复杂的关系而感到烦恼吗? 还在为如何统一系统的日志输出而感到不知所措嘛? 您是否依然存在这...

微笑向暖wx
20分钟前
1
0
Excel快速入门教程1-简介

什么是Microsoft Excel? Microsoft Excel是一个电子表格程序,用于记录和分析数值数据。 Excel将电子表格视为列和行表的集合。 字母标签通常分配给列,而数字标签通常分配给行。 列和行相交...

python测试开发人工智能安全
20分钟前
1
0
设计模式

设计模式 菜鸟教程

qwergkp
21分钟前
1
0
只需五分钟-用Maven快速搭建Spring Cloud微服务

Maven安装手册 如果想学习Java工程化、高性能及分布式、深入浅出。微服务、Spring,MyBatis,Netty源码分析的朋友可以加我的Java高级交流:854630135,群里有阿里大牛直播讲解技术,以及Jav...

编程SHA
25分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部