agmtopy
  Post Categories
Netty 2 杂记 42 JVM 11 数据库 18 算法 11 文章收藏 7 数据结构 1 网络协议 1 框架 1 容器化 4 分布式 6 并发 19 编译原理 3 操作系统 3 jvm 2 性能 2 SpringBoot 1 笔记 2 极客时间 1 JavaParser 1 架构 3 AI 2 spring 19 设计模式 6 领域驱动 3 消息队列 19 RPC 2 英文发音 1
Pulsar发送消息分析 Pulsar发送消息分析
Pulsar发送消息分析 Pulsar提供的多种发送消息的模式,分别是:send(msg)-同步消息,sendAsync(msg)-异步消息; 简单示例 public class SampleProducer { publ
2025-07-08 消息队列
pulsar
pulsar的简单使用 pulsar的简单使用
pulsar的简单使用 Apache Pulsar 是一个云原生的分布式消息传递和流媒体平台，最初由 Yahoo! 创建。现在是作为Apache软件基金会的顶级项目. 在pulsar这个项目中还大量使用了另外一个Apache的顶级项目Boo
2022-03-19 消息队列
pulsar
rocketmq索引实现原理之IndexService rocketmq索引实现原理之IndexService
rocketmq索引实现原理之IndexService 在之前的文章中分析了消息是如果通过Commitlog的逻辑设计到MappedFile的与文件系统进行交付的过程，这篇文章来分析消息体是如何实现快速查找的以及底层实现 RocketMQ的
2021-10-13 消息队列
RocketMQ
rocketmq的存储实现原理之MappedFile rocketmq的存储实现原理之MappedFile
rocketmq的存储实现原理之MappedFile MappedFile是RoketMq处理底层文件的类,在上面一篇文章中已经了解了如何通过CommitLog类来处理请求以及如何通过MappedFile来实现底层存储的 MappedFil
2021-09-09 消息队列
RocketMQ
rocketmq的存储实现原理之commitlog rocketmq的存储实现原理之commitlog
rocketmq的存储实现原理之commitlog 在之前的《rocketmq的存储原理》文章中分析了rocketmq的存储过程主要是通过两个类来实现的分别是commitlog和MappedFile，这篇文章重点分析commitlog这个类
2021-09-09 消息队列
RocketMQ
RocketMQ中NameSrv的详细设计分析 RocketMQ中NameSrv的详细设计分析
RocketMQ中NameSrv的详细设计分析 设计目标 NameSrv是RoctetMQ项目下的一个模块，作为RockerMQ中的轻型注册中心,只负责与Topic有关的功能。 使用NameSrv来替代ZK等注册中心主要是有两个好处: 减
2021-06-11 消息队列
RocketMQ
延迟队列的实现思路 延迟队列的实现思路
延迟队列的实现思路 定义 延迟队列指的是元素按照延迟时间进行排序形成并且到时后能自动弹出的有序队列,底层数据结构既可以是数组也可以是链表 适用场景 按照倒计时触发的业务场景,例如电商网站中的订单未支付自动取消,竞拍,日历待办提醒的场景,
2021-01-20 消息队列
RocketMQ
rocketmq的存储原理 rocketmq的存储原理
rocketmq的存储原理 rocketmq的存储设计主要是分为三个文件： comitLog文件，该文件是用来顺序存放所有的消息 consumeQueue文件，该文件是用来保存每一个消费队列的消费信息的 IndexFile文件，该文件是用
2019-04-01 消息队列
RocketMQ
rocketmq顺序消息的分析 rocketmq顺序消息的分析
rocketmq顺序消息的分析 顺序消息是指的是一组需要有序的消息集合，在同一参照系下才有意义。rocketmq的顺序消息主要是分为两个方面： product保证将一组有序的消息发送到同一个messageQueue下 consumer消费
2019-03-31 消息队列
RocketMQ
rocketmq的通信协议分析 rocketmq的通信协议分析
rocketmq的通信协议分析 rocketmq底层的通信是放在org.apache.rocketmq.remoting包下的，主要有RPCHook、RemotingServer、RemotingClient、RemotingUtil、Re
2019-03-29 消息队列
RocketMQ
RocketMQ主从同步机制分析 RocketMQ主从同步机制分析
RocketMQ主从同步机制分析 Broker分为Slave、Master两种角色，因此Slave会从master中同步信息、topicConfig、ConsumerOffer、DelayOffset、SubscriptionGroupCo
2019-03-28 消息队列
RocketMQ
rocketmq常见问题 rocketmq常见问题
rocketmq常见问题 RocketMQ由哪些角色组成？ 由NameSrv、Broker、Consumer、Producer组成 RocketMQ的整体流程？ NameSrv首先启动 Broker启动后向NameSrv进行注册，并对外提
2019-03-27 消息队列
RocketMQ
1 / 2