《RocketMQ源码系列》mq启动流程
nameserver 创建nameserver 可以看到我们启动 nameserver，就是执行 NamesrvStartup 类的main方法。看起来比较简单，应该就是创建了一个namese ...
原文：RocketMQ Remoting模块系列之NettyRemotingServer源码浅析
写在前面 RocketMQ Remoting模块也是整个代码中比较简单的一个模块，在掌握基本的Netty知识之后就可以尝试对源码进行简单的阅读分析，我也是结合源码分析来进行Netty应用的学习。 该模块主要有两个类NettyRemotingServer 和NettyRemotingClient 。分别对应服务端和客户端，服务端主要在Broker和NameService中使用。 本文是对NettyR ...
2020-07-01 17:58 0 573 推荐指数：
相关推荐
.14-浅析webpack源码之Watchpack模块
解决掉了最头疼的DirectoryWatcher内部实现，这一节可以结束NodeWatchFileSystem模块。 关于watch的应用场景，仔细思考了下，这不就是热重载的核心嘛。 首先是监视文件，触发文件change事件后收集变动文件信息，重新进行打包，更新JS后触发页面重新 ...
spring源码分析之spring-web remoting模块概况及基本概念
spring-web总体分为三部分：caucho、httpinvoker、jaxws，其总体构造图如下： uml结构： 先看看网上搜索到的上述实现的原理吧：Spring RMI，He ...
.6-浅析webpack源码之validateSchema模块
validateSchema模块 首先来看错误检测： 可以注意到，这里传了两个参数，其实第一个参数来源于一个JSON文件： 这个JSON文件非常大，可以观察一下部分内容： 从描述可以猜测，这里的key对应options中 ...
【原】Spring源码浅析系列-导入源码到Eclipse
用了Spring几年,平时也断断续续在项目里看过一些源码，大多都是比较模糊的,因为一旦从一个地方进去就找不到方向了，只能知道它大概是做了什么事能达到这个功能或者效果,至于细节一般没有太深入去研究。后来才知道是学习方式有误，正常的应该是从它最原始的地方下手,至于学习Spring源码原因 ...
深入剖析 RocketMQ 源码 - 消息存储模块
一、简介 RocketMQ 是阿里巴巴开源的分布式消息中间件，它借鉴了 Kafka 实现，支持消息订阅与发布、顺序消息、事务消息、定时消息、消息回溯、死信队列等功能。RocketMQ 架构上主要分为四部分，如下图所示： Producer：消息生产者，支持分布式集群方式部署 ...
org.apache.rocketmq.remoting.exception.RemotingTimeoutException: invokeSync call timeout
==问题== 在本地Debug调试Flink消费RocketMQ数据的时候，提示如下错误 ==解决办法== RocketMQ集群版本是：4.6.1 程序中依赖的客户端版本也是4.6.1 有网友建议降低客户端版本为4.5.0，尝试了一下，确实可以解决 ...