首页 > TAG信息列表 > queueId
Rocketmq消费面试总结
1 事务消息 并不是真正意义上分布式事务的实现，确保生产者本地事务完成后，一定会把消息发送到broker节点，至于该消息什么时候消费，生产者无法控制。 适合的业务场景：生产者发送 半消息，发送成功后得到消息的UNIQ_ID作为事务ID，半消息就是broker会将原topic和queueid保存到properties里，然通过非docker的方式进行RocketMQ的安装
部署安装 下载 下载地址：https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.3.2/rocketmq-all-4.3.2-bin-release.zip 版本使用目前最新版：4.3.2 非Docker安装 cd /haoke unzip rocketmq-all-4.3.2-bin-release.zip cd rocketmq-all-4.3.2-bin-release #启动nameserver bi4. RocketMQ顺序消息
什么事顺序消息 消息顺序（Message Order）有两种：顺序消费（Orderly）和并行消费（Concurrently）。顺序消费表示消息消费的顺序同生产者为每个消息队列发送的顺序一致，所以如果正在处理全局顺序是强制性的场景，需要确保使用的主题只有一个消息队列。并行消费不再保证消息顺序，消费的最大并rocketmq源码解析消息拉取处理器②
说在前面 消息拉取处理器 源码解析 进入到这个方法，根据offset找到映射文件，org.apache.rocketmq.store.MappedFileQueue#findMappedFileByOffset(long, boolean)上面介绍过了。 往上返回到这个方法，根据offset找到下个映射文件，org.apache.rocketmq.store.CommitLog#rollNextFrocketmq源码解析之管理请求获取最大的offset
说在前面 本次继续解析管理请求，GET_MAX_OFFSET 获取最大的offset 源码解析 进入到这个方法org.apache.rocketmq.broker.processor.AdminBrokerProcessor#getMaxOffset获取最大的offset private RemotingCommand getMaxOffset(ChannelHandlerContext ctx, RemotingCrocketmq源码解析之管理请求获取最小的offset
说在前面 管理请求 GET_MIN_OFFSET 获取最小的offset 源码解析 进入这个方法org.apache.rocketmq.broker.processor.AdminBrokerProcessor#getMinOffset 获取最小的offset private RemotingCommand getMinOffset(ChannelHandlerContext ctx, RemotingCommand requ