fFee-ops's Blog
RocketMQ消费进度管理 RocketMQ消费进度管理
业务实现消费回调的时候,当且仅当此回调函数返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS ,RocketMQ才会认为这批消息(默认是1条)是消费完成的 如果这时候消息消费失败,例如数据库异常,余额不足
2022-02-03
RocketMQ业务保障 RocketMQ业务保障
1. 为什么从业务上保证1.1 消息丢失问题RocketMQ虽然号称消息不会丢失,但是还是有几率存在MQ宕机以及rocketMQ使用上的问题可能存在消息丢失等,对于类似于支付确认的消息一般来说是一条都不允许丢失的 1.2 消息幂等性在网络环
2022-02-03
RocketMQ文件刷盘机制与过期文件删除 RocketMQ文件刷盘机制与过期文件删除
文件刷盘机制RocketMQ 的消息是存储在磁盘上的,这样做有两个优点: 保证断电后恢复 让存储的消息量超出内存的限制 RocketMQ 存储与读写是基于 JDK NIO 的内存映射机制,具体使用 MappedByteBuffer(基于
2022-02-03
RocketMQ消息存储 RocketMQ消息存储
目前的MQ中间件从存储模型来,分为需要持久化和不需要持久化的两种模型,现在大多数的是支持持久化存储的,比如ActiveMQ、RabbitMQ、Kafka、RocketMQ。ZeroMQ却不需要支持持久化存储而业务系统也大多需要MQ有持久存储
2022-02-03
RocketMQ死信队列 RocketMQ死信队列
RocketMQ的死信队列介绍就没有RabbitMQ那么复杂。在这篇文章会简单的介绍一下RocketMQ死信队列的特点。 死信消息特性 不会再被消费者正常消费 有效期与正常消息相同,均为 3 天,3 天后会被自动删除。故死信消息应在产生的
2022-02-01
RocketMQ消息保障 RocketMQ消息保障
1. 生产端保障生产端保障需要从以下几个方面来保障 使用可靠的消息发送方式 注意生产端重试 生产禁止自动创建topic 1.1 ⚠消息发送保障1.1.1同步发送发送者向MQ执行发送消息API时,同步等待,直到消息服务器返回发送结果,会在
2022-02-01
RocketMQ消息投递策略 RocketMQ消息投递策略
​ RocketMQ的消息投递分分为两种:一种是生产者往MQ Broker中投递;另外一种则是MQ broker 往消费者 投递(这种投递的说法是从消息传递的角度阐述的,实际上底层是消费者从MQ broker 中Pull拉取的)。 Rock
2022-02-01
RocketMQ顺序消息 RocketMQ顺序消息
顺序类型无序消息无序消息也指普通的消息,Producer 只管发送消息,Consumer 只管接收消息,至于消息和消息之间的顺序并没有保证。 Producer 依次发送 orderId 为 1、2、3 的消息 Consumer 接到的消
2022-02-01
SpringBoot整合RocketMQ SpringBoot整合RocketMQ
0. 启动Name Server与 Broker1. 引入依赖添加 RocketMQ 客户端访问支持,具体版本和安装的 RocketMQ 版本一致即可。 <dependency> <groupId>org.apache.
2022-01-31
RocketMQ安装 RocketMQ安装
Linux安装环境说明对于 RocketMQ 4.3.0版本,官方要求环境如下,其中 Git 用于从 GitHub 获取源码,没有安装也没关系,可以直接下载。官方推荐的流程是:Linux 系统上安装 Git 工具 、Maven、Java J
2022-01-26
RocketMQ 介绍及基本概念 RocketMQ 介绍及基本概念
1 介绍RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。 1.1 RocketMQ 特点 支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型 在一个队列
2022-01-26