- 综合排序
- 最热优先
- 最新优先
- 来自专栏码匠的流水账
聊聊rocketmq5的PushConsumer
序本文主要研究一下rocketmq5的PushConsumer的消费逻辑PushConsumerImplorg/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.javaclass pq.eraseMessage(messageView, consumeResult)，同时它对这个新future增加了listener在其执行完毕之后继续执行consumeIteratively处理下一个消息小结rocketmq5
35110编辑于 2024-08-10 - 来自专栏电光石火
RocketMQ5部署
由于 Local 模式下 Proxy 和 Broker 是同进程部署，Proxy本身无状态，因此主要的集群配置仍然以 Broker 为基础进行即可。
68920编辑于 2023-10-16 - 来自专栏魔都程序缘
RocketMQ5 PopAck源码拆解
内容较多建议PC上对照代码查看，手机你可能会晕”01 RocketMQ5 架构RocketMQ已经开启5.X时代，4.X已成为LTS版本。 各大云厂商也推出支持RocketMQ5.X版本的产品，在介绍Pop，ack之前需要先了解RocketMQ5的架构。 05 gRPC client：RocketMQ5的新客户端，使用gRpc协议访问RocketMQ Proxy。注意：社区很多朋友咨询这个客户端是否可以访问4.X 集群，答案是不支持。
51300编辑于 2023-11-27 - 来自专栏码匠的流水账
聊聊rocketmq5的PushConsumer
本文主要研究一下rocketmq5的PushConsumer的消费逻辑 PushConsumerImpl org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java pq.eraseMessage(messageView, consumeResult)，同时它对这个新future增加了listener在其执行完毕之后继续执行consumeIteratively处理下一个消息 小结 rocketmq5
38910编辑于 2024-08-12 - 来自专栏码匠的流水账
聊聊rocketmq5的RocketMQClientTemplate
序 本文主要研究一下rocketmq5的RocketMQClientTemplate rocketmq-spring 自从rocketmq推出了5版本之后，rocketmq-spring就区分了4.x与 5.x版本，4.x版本是rocketmq-spring开头，5.x版本是rocketmq-v5-client开头；rocketmq5的RocketMQClientTemplate对应的是旧版的RocketMQTemplate simpleConsumer.ackAsync(messageView); } ack是通过simpleConsumer.ack来操作；ackAsync是通过simpleConsumer.ackAsync来操作 小结 rocketmq5
49610编辑于 2024-08-01 - 来自专栏码匠的流水账
聊聊rocketmq5的RocketMQClientTemplate
序本文主要研究一下rocketmq5的RocketMQClientTemplaterocketmq-spring自从rocketmq推出了5版本之后，rocketmq-spring就区分了4.x与5.x 版本，4.x版本是rocketmq-spring开头，5.x版本是rocketmq-v5-client开头；rocketmq5的RocketMQClientTemplate对应的是旧版的RocketMQTemplate simpleConsumer.ackAsync(messageView); }ack是通过simpleConsumer.ack来操作；ackAsync是通过simpleConsumer.ackAsync来操作小结rocketmq5
66210编辑于 2024-07-27 - 来自专栏魔都程序缘
RocketMQ5 PopAck源码拆解
内容较多建议PC上对照代码查看，手机你可能会晕” 目录 一、RocketMQ5 架构 1. RocketMQ5.X架构 2. RocketMQ5.X为什么发明Pop 二、 Pop流程 1. OrderCountInfo 三、Ack流程 proxy提交ack请求 内存标记消费进度 持久化ack到revive topic 异步标记消费进度 可见时间过后，消息恢复消费 四、结语 01 — RocketMQ5 各大云厂商也推出支持RocketMQ5.X版本的产品，在介绍Pop，ack之前需要先了解RocketMQ5的架构。 1. - 05 gRPC client：RocketMQ5的新客户端，使用gRpc协议访问RocketMQ Proxy。 注意：社区很多朋友咨询这个客户端是否可以访问4.X 集群，答案是不支持。
30810编辑于 2023-11-27 - 来自专栏腾讯云中间件的专栏
RocketMQ5 PopAck源码拆解
内容较多建议 PC 上对照代码查看，手机你可能会晕” 目录 一、RocketMQ5 架构 1. RocketMQ5.X 架构 2.
44510编辑于 2023-12-02 - 来自专栏后端开发随笔
RocketMQ5部署单节点服务
关于RocketMQ的单节点部署官方文档已经描述得非常清楚了，这里只是做一个简单的备忘。 如下安装步骤均基于最新的Apache RocketMQ 5.3.0实现。
57310编辑于 2024-09-09 - 来自专栏码匠的流水账
聊聊rocketmq5的顺序消息队列选择
序本文主要研究一下rocketmq5的顺序消息的队列选择SendMessageActivityproxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/ return candidate; } } }guava的consistentHash使用LinearCongruentialGenerator来生成double小结rocketmq5
25000编辑于 2024-08-09 - 来自专栏码匠的流水账
聊聊rocketmq5的顺序消息队列选择
本文主要研究一下rocketmq5的顺序消息的队列选择 SendMessageActivity proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2 return candidate; } } } 复制 guava的consistentHash使用LinearCongruentialGenerator来生成double 小结 rocketmq5
29310编辑于 2024-08-12 - 来自专栏码匠的流水账
聊聊PushConsumer与SimpleConsumer拉取消息的区别
序 本文主要研究一下rocketmq5的PushConsumer与SimpleConsumer拉取消息的区别 ProcessQueueImpl org/apache/rocketmq/client/java longPollingTimeout)这几个参数 区别在于一个是setAutoRenew为true且设置了attemptId，一个是setAutoRenew为false且设置了invisibleDuration 小结 rocketmq5
34110编辑于 2024-08-12 - 来自专栏码匠的流水账
聊聊PushConsumer与SimpleConsumer拉取消息的区别
序本文主要研究一下rocketmq5的PushConsumer与SimpleConsumer拉取消息的区别ProcessQueueImplorg/apache/rocketmq/client/java/ longPollingTimeout)这几个参数区别在于一个是setAutoRenew为true且设置了attemptId，一个是setAutoRenew为false且设置了invisibleDuration小结rocketmq5
34410编辑于 2024-08-11
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号