关于rocketmq:RocketMQ学习四顺序消费消息过滤临时

91次阅读

共计 691 个字符,预计需要花费 2 分钟才能阅读完成。

13 章
因为 RocketMQ 只提供了音讯队列的部分有序,故如果要实现某一类音讯的程序执行,就必须将这类音讯发送到同一个队列,故这里在音讯发送时应用了 MessageQueueSelector,并且应用用户账户进行队列负载,这样同一个账户的音讯就会账号余额变更的程序达到队列,而后队列中的音讯就能被程序生产。
那 RocketMQ 程序生产是如何实现的?队列从新负载时还能放弃程序生产吗?程序生产会反复生产吗?
音讯过滤,Tag 底层实现

所谓的音讯积压:就是 Broker 端以后队列无效数据最大的偏移量(brokerOffset)与音讯生产端的以后解决进度(consumerOffset)之间的差值,即示意以后须要生产但没有生产的音讯。
须要晓得这两个偏移量具体详情

RocketMQ 生产端限流机制

RocketMQ 服务端性能自查技巧,也就是看 Broker 的性能,个别是看日志文件里‘PAGECACHERT’关键字

系统配置 48C256G,集群架构为 4 主 4 从,200 个线程、音讯大小为 3K、主题为 16 个队列,TPS 可达 12W 左右

17 章
调优倡议
18 章
平滑运维

RoketMQ 源码剖析
https://my.oschina.net/wangsh…
https://www.jianshu.com/u/c5a…

23 章
音讯轨迹
25 章
Nameserver 设计原理及相干问题

CompletableFuture 剖析

27
commitlog 文件
consumequeue
mmap,ByteBuffer 剖析
程序写

28
刷盘分同步与异步
文件复原机制

29
如何应用 Netty 创立客户端,建设连贯,发送音讯,服务端如何解决音讯
线程隔离机制

正文完
 0