加载中
RocketMQ刷盘策略

我们都知道RocketMQ的消息是持久化到文件的,具体的消息的刷盘策略是什么,是发送一条消息就直接持久化到文件中吗?作为一款高性能的消息中间件这样做肯定不行,至少性能上不允许这样操作,那...

2019/08/06 09:59
4.2K
RocketMQ消息重试

RocketMQ为了保证消息被消费采用ACK确认机制,消费者消费消息时需要给Broker反馈消息消费的情况,成功或失败,对于失败的消息会根据内部算法一段时间后重新消费。会一直消费下去吗?内部是如...

2019/08/06 09:57
2K
RocketMQ权限控制

RocketMQ作为一款优秀的中间件,应用领域非常广泛,金融、电商、电信、医疗、社科、安保等不同的领域都有其大规模的应用,无疑安全性很受质疑,因为内部没有安全相关的业务模块,消息的发送和...

2019/08/06 09:50
2.3W
RocketMQ主从同步

RocketMQ作为一款优秀的分布式消息中间件,分布式系统的一个很重要的特点就是要保证系统的高可用(HA),RocketMQ则是通过主从同步机制保证系统的高可用。 1、概述 主从同步同步的是啥作为消息...

2019/08/06 09:46
6.9K
RocketMQ消息过滤

消息过滤包括基于表达式过滤与基于类模式两种过滤模式。其中表达式过滤又分为TAG和SQL92模式,分别介绍各自的过滤机制,及代码示例内容,深入探消息过滤的原理。 1、TAG模式过滤 发送消息时我...

2019/08/06 08:57
3.4K
RocketMQ延迟消息

延时消息即消息发送后并不立即对消费者可见,而是在用户指定的时间投递给消费者。比如我们现在发送一条延时30秒的消息,消息发送后立即发送给服务器,但是服务器在30秒后才将该消息交给消费者...

2019/08/06 08:50
4.9K
RocketMQ消费位置

RocketMQ创建消费者的时指定了Topic主题及Tag,我们发现新创建的消费者消费不了历史的数据,只能消费掉创建以后消费者发送的数据。这是什么原因,我们能把所有的消息都消费吗?,我们可以指定...

2019/08/06 08:44
6K
RocketMQ消费模式

RocketMQ提供两种消费策略CLUSTERING集群消费(默认)和BROADCASTING广播消费,在创建Consumer消费者时可以指定消费策略,策略不同其内部机制也不同,消息的消费方式、记录消费进度、消息的消费...

2019/08/06 08:39
8.9K
RocketMQ顺序消息

我们知道消息队列的特性导致其消息不是顺序进行消费的,RocketMQ没有提供所谓的顺序消息来供我们使用,但是有时候一些场景需要需要顺序的去接收消息。今天我们重点讨论一下如何实现这种功能。...

2019/08/06 08:26
5.2K
RocketMQ简单介绍

一、简介 RocketMQ是阿里开源的一款分布式消息中间件,满足线上海量消息堆积的需求, 在2016年底捐赠给Apache开源基金会成为孵化项目,2017年正式成为了Apache顶级项目。是一款纯Java的消息中...

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部