关键词：
源码分析rocketmq系列索引
1、RocketMQ源码分析之NameServer2、RocketMQ源码分析之Broker概述与同步消息发送原理与高可用设计及思考3、源码分析RocketMQ之CommitLog消息存储机制4、源码分析RocketMQ之消息消费5、源码分析RocketMQ消息消费机制----消费者拉取消息机制6、... 查看详情
rocketmq源码—rocketmq源码调试环境准备(代码片段)
详细介绍了RocketMQ4.9.3分支的源码调试环境搭建等一系列准备工作。RocketMQ的源码这么多，我们肯定不会全部看完的，我们的源码分析主要会涉及到namesrv、broker、client、remoting、store等模块，也就是生产者、消费者、name... 查看详情
如何保障消息中间件100%消息投递成功？如何保证消息幂等性？
...言我们小伙伴应该都听说够消息中间件MQ，如：RabbitMQ，RocketMQ，Kafka等。引入中间件的好处可以起到抗高并发，削峰，业务解耦的作用。 如上图：（1）订单服务投递消息给MQ中间件（2）物流服务监听MQ中间件消息，从而... 查看详情
rocketmq源码—十rocketmq顺序消息(代码片段)
RocketMQ本身支持顺序消息，在使用上发送顺序消息和非顺序消息有所区别发送顺序消息SendResultsendResult=producer.send(msg,newMessageQueueSelector()@OverridepublicMessageQueueselect(List<MessageQueue>mqs,Messagemsg,Objectarg)Integeri 查看详情
rocketmq源码—十rocketmq顺序消息(代码片段)
RocketMQ本身支持顺序消息，在使用上发送顺序消息和非顺序消息有所区别发送顺序消息SendResultsendResult=producer.send(msg,newMessageQueueSelector()@OverridepublicMessageQueueselect(List<MessageQueue>mqs,Messagemsg,Objectarg)Integeri 查看详情
源码合集
-----------------------Unity3D板块16年11月源码资源合集----------------------- Unity3D暴力摩托游戏源码下载http://www.9miao.com/thread-112885-1-1.html 国外经营农场游戏支持iosandroid已经测试！！！良心推介http://www.9miao.c 查看详情
rocketmq源码—八rocketmq消息重试(代码片段)
RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。producer发送消息重试producer在发送消息的时候如果发送失败了，RocketMQ会自动重试。privateSendResultsendDefaultImpl(Messagemsg,finalCommunicationModecommunicationMode,finalSendCal... 查看详情
44源码：从github拉取rocketmq源码以及导入intellijidea中
1.从Github上拉取RocketMQ源码进入RocketMQ的github网站，地址为：https://github.com/apache/rocketmq进入上述url地址后，可以看到一个“cloneordownload”的按钮，在里面点击“DownloadZIP”，就可以下载RocketMQ的源码了。下载到本... 查看详情
rocketmq源码—nameserver启动流程源码解析(代码片段)
详细介绍了RocketMQ的NameServer启动流程源码解析，包括RocketMQ的RPC通信模型。文章目录0NameServer概述1NamesrvStartup启动入口2createNamesrvController创建NamesrvController2.1newNamesrvController创建控制器3start启动NamesrvController3.1initia 查看详情
rocketmq源码阅读
RocketMQ是一款开源的消息中间件，采用Java实现，设计思想来自于Kafka（Scala实现）,在具体设计时体现了自己的选择和需求，具体差别可以看RocketMQ与Kafka对比。接下来是自己阅读源码的一些探索。650)this.width=650;"alt="IMG_256"... 查看详情
rocketmq源码阅读
RocketMQ是一款开源的消息中间件，采用Java实现，设计思想来自于Kafka（Scala实现）,在具体设计时体现了自己的选择和需求，具体差别可以看RocketMQ与Kafka对比。接下来是自己阅读源码的一些探索。650)this.width=650;"alt="IMG_256"... 查看详情
rocketmq源码学习笔记(代码片段)
一、环境配置1.1、下载源码下载地址：https://github.com/apache/rocketmqgitclonehttps://github.com/apache/rocketmq.git1.2、导入maven工程到IDE1.3、准备启动的配置1）在下载的rocketmq根目录创建新文件夹conf2）把rocketmq\\distribution 查看详情
rocketmq源码—rocketmq高可用(代码片段)
高可用究竟指的是什么？请参考：关于高可用的系统RocketMQ做了以下的事情来保证系统的高可用多master部署，防止单点故障消息冗余（主从结构），防止消息丢失故障恢复（本篇暂不讨论）那么问题来了：怎么支持多broker的写？... 查看详情
深度挖掘rocketmq底层源码「底层源码挖掘系列」透彻剖析贯穿rocketmq的消费者端的运行核心的流程（上篇）(代码片段)
精华推荐|【深入浅出RocketMQ原理及实战】「底层源码挖掘系列」透彻剖析贯穿RocketMQ的消费者端的运行核心的流程上篇：分析对应总体消费流程的判断和校验以及限流控制和回调等处理流程分析下篇：分析基于上篇的总体... 查看详情
rocketmq源码(16)—消费者负载均衡服务rebalanceservice入口源码(代码片段)
基于RocketMQrelease-4.9.3，深入的介绍了消费者负载均衡服务RebalanceService入口源码。上一篇文章我们学习了RocketMQ源码(15)—消费者DefaultMQPushConsumer启动主要流程源码。RocketMQ一个消费者组中可以有多个消费者，在集群模式下... 查看详情
rocketmq源码解析-nameserver篇(代码片段)
...NameServer是怎样保存topic、broker、cluster这些信息的。一、rocketmq-namesrv模块基本介绍可以看到在它的源码中，namesrv其只有这些类(当然也有使用rocketMQ源码的其他的模块)。NamesrvController完成netty连接的初始化，然后DefaultReque... 查看详情
rocketmq基础概念剖析，并分析一下producer的底层源码
这篇博客聊聊关于RocketMQ相关的东西，主要聊的点有RocketMQ的功能使用、RocketMQ的底层运行原理和部分核心逻辑的源码分析。至于我们为什么要用MQ、使用MQ能够为我们带来哪些好处、MQ在社区有哪些实现、社区的各个MQ的优劣对比... 查看详情
（转）rocketmq源码学习--消息存储篇
...tp://www.tuicool.com/articles/umQfMzA1.序言今天来和大家探讨一下RocketMQ在消息存储方面所作出的努力，在介绍RocketMQ的存储模型之前，可以先探讨一下MQ的存储模型选择。2.MQ的存储模型选择个人看来，从MQ的类型来看，存储模型分两种：... 查看详情