云原生中间件RocketMQ-消费者消费模式之广播模式、偏移量offset解析

msgId一定是全局唯一标识符,但是实际使用中,可能会存在相同的消息有两个不同msgId的情况(消费者主动重发、因客户端重投机制导致的重复等),这种情况就需要使业务字段进行重复消费。: 当使用广播消费模式时, 消息队列 RocketMQ 会将每条消息推送给集群内所有注册过的客户端, 保证消息至少被每

云原生中间件RocketMQ-生产者核心解析、主从同步机制解析,生产者同步异步消息发送

方法中通过定义了一个固定时间的定时任务,时间是10秒钟执行一次,当然前提条件是broker节点的角色是slave,而broker节点是master时,如果有定时任务会取消,因为master是不用同步元数据信息。4个方法的内容实际上就是封装了netty做rpc的调用,对不同的操作都会对应到一个code

RocketMQ 顺序消息解析——图解、源码级解析

优秀的程序员不应该只是CRUD

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈