云原生中间件RocketMQ-消费者消费模式之广播模式、偏移量offset解析
msgId一定是全局唯一标识符,但是实际使用中,可能会存在相同的消息有两个不同msgId的情况(消费者主动重发、因客户端重投机制导致的重复等),这种情况就需要使业务字段进行重复消费。: 当使用广播消费模式时, 消息队列 RocketMQ 会将每条消息推送给集群内所有注册过的客户端, 保证消息至少被每
云原生中间件RocketMQ-生产者核心解析、主从同步机制解析,生产者同步异步消息发送
方法中通过定义了一个固定时间的定时任务,时间是10秒钟执行一次,当然前提条件是broker节点的角色是slave,而broker节点是master时,如果有定时任务会取消,因为master是不用同步元数据信息。4个方法的内容实际上就是封装了netty做rpc的调用,对不同的操作都会对应到一个code
RocketMQ 顺序消息解析——图解、源码级解析
优秀的程序员不应该只是CRUD