分类： rocketmq
-
关于rocketmq:RocketMQ-消费者启动流程
消费者在发送音讯的时候，有一个分组的概念。也就是说，有一个或者多个消费者的名称，是同一个，这些名称一样的消费者…
-
关于rocketmq:RocketMQ-过期文件的删除
在音讯一直的发送给Broker，Broker又一直的把音讯贮存在Commitlog文件、ConsumeQueu…
-
关于rocketmq:RocketMQ-文件不一致的解决方案
后面提到了ConsumeQueue和IndexFile是通过ReputMessageService线程异步同步…
-
关于rocketmq:RocketMQ-消息消费队列与索引文件
consumequeue是音讯生产队列存储目录，比方咱们建了一个TopicTest，有四个MessageQue…
-
关于rocketmq:RocketMQ-刷盘机制
同步刷盘的服务，也是一个线程，专门用来解决这些result。他保护着requestsWrite和request…
-
关于rocketmq:RocketMQ-消息发送存储流程
为了保障音讯不失落，RocketMQ会把音讯进行长久化，也就是说，会把音讯写入commitlog的日志，这个目…
-
关于rocketmq:RocketMQ-MessageQueue是怎么指定的
kafka是有Partition的概率，发送音讯的时候，跟进分区规定进行抉择哪个Partition，每个Par…
-
关于rocketmq:RocketMQ-元数据的拉取
拉取的机会和Kafka — 元数据的拉取机会的相似，分为发消息的时候以及定时工作。拉取的流程获取topic的…
-
关于rocketmq:聊聊rocketmqstreams的ILeaseService
ILeaseService接口定义了hasLease、startLeaseTask、lock、tryLocke…
-
关于rocketmq:RocketMQ学习十五消费进度提交
通过队列负载机制后，会调配给以后消费者一些队列，留神一个生产组能够订阅多个主题，正如下面 pullReques…