关于 RocketMQ 的文章

这是关于 RocketMQ 标签的相关文章列表

联合漏洞预警服务(2022-07-19 暂停开放)

置顶联合漏洞预警服务(2022-07-19 暂停开放)

关于在线社工库关闭的问题 TOOBUG博客自2016年开始与之前守夜人平台进行合作,充分利用守夜人平台的预警中心,为双方会员提供信息安全预警、账号行为分析、个人信息检索、人际关系分析、用户网络指纹记录、精准IP定位等...

RocketMQ高级特性总结(事务消息、顺序消息、延迟消息)

热文RocketMQ高级特性总结(事务消息、顺序消息、延迟消息)

文章目录事务消息场景分析基本思路及问题所在基本概念 RocketMQ-事务消息设计思路两阶段提交事务状态定时回查关键API 延迟消息场景分析关键API RocketMQ延迟级别延迟消息Produc...

RocketMQ-消息发送源码分析(三)消息重试及Broker故障延迟机制

热文RocketMQ-消息发送源码分析(三)消息重试及Broker故障延迟机制

文章目录问题点消息重试消息队列选择默认机制 Broker故障转移机制问题点上篇文章已经介绍了消息发送时，topic的路由信息是如何获取的，最终路由结果是一个TopicPublishInfo对象，其中mes...

RocketMQ-消息发送源码分析(二)消息发送基本流程及Topic路由信息获取

热文RocketMQ-消息发送源码分析(二)消息发送基本流程及Topic路由信息获取

文章目录问题点消息发送方式消息发送基本流程路由信息获取问题点同样，在介绍消息发送流程之前，先抛出几个问题消息发送有哪几种方式？ producer是如何查找、维护topic对应的路由信息的？消息发送的实...

RocketMQ-消息发送源码分析(一)生产者启动流程

热文RocketMQ-消息发送源码分析(一)生产者启动流程

在介绍Mq生产者启动流程之前，先抛出几个个问题，带着问题去分析源码 1、消息生产者启动时具体做了什么？ 2、消息生产者启动时和NameServer，Broker之间建立了什么关系？先从启动入库着手，消息生产者启动入...

RocketMQ-NameServer路由机制源码分析

热文RocketMQ-NameServer路由机制源码分析

文章目录 RouteInfoManager 路由注册(Broker注册) Broker发起注册请求 NameServer接收注册请求路由查询(QueueData、BrokerData信息查询) 路由信息删除上篇文...

RocketMQ-NameServer配置加载、启动源码分析

热文RocketMQ-NameServer配置加载、启动源码分析

文章目录 NameServer作用 NameServer启动 NameServer配置加载 NameServerController初始化 kvConfig加载初始化NettyRemotingServer 注册默认...

分布式事务-RocketMQ事务消息源码分析

热文分布式事务-RocketMQ事务消息源码分析

前言上篇文章介绍了RocketMQ事务消息的基本原理，对大致的流程及设计思路有个大致的了解分布式事务-RocketMQ消息事务设计思路及Demo 文章最后，也提出了几个问题为什么prepare消息在发送后不会被...

RocketMQ源码解析：消息丢失如何排查？

热文RocketMQ源码解析：消息丢失如何排查？

消息丢失如何排查？当我们在使用mq的时候，经常会遇到消息消费异常的问题，原因有很多种，比如 producer发送失败 consumer消费异常 consumer根本就没收到消息那么我们该如何排查了? 其实借助Ro...

RocketMQ源码解析：消息发送和消费核心流程汇总

热文RocketMQ源码解析：消息发送和消费核心流程汇总

从上帝视角看一下消息发送和消费当我们使用RocketMQ时，RocketMQ-Dashboard是一个非常好用的图形化界面工具我们首先在RocketMQ-Dashboard上创建一个topic，每个topic下4...

RocketMQ源码解析：同步刷盘和异步刷盘的实现

热文RocketMQ源码解析：同步刷盘和异步刷盘的实现

同步刷盘在RocketMQ中有同步刷盘和异步刷盘两种方式 2种刷盘方式适用的场景如下刷盘方式适用场景同步刷盘数据可靠性高，适用于金融等对数据可靠性要求高的场景，性能比异步刷盘要低异步刷盘性能和吞吐量高 ...