月归档:2015年04月

RocketMQ学习(三):rocketmq-namesrv介绍

刚刚拉了最新的代码,版本是3.2.6,直接NamesrvStartup类的main()方法启动,不需要带启动参数,启动序列图如下: 当broker,producer,consumer都运行后,namesrv一共有8类线程: 1.ServerHouseKeepingService:守护线程,本质是ChannelEventListener,监听broker的channel变化来更新本地的RouteInfo。 2.NSScheduledThread1:定时任务线程,定时跑2个任务,第一个是,每隔10分钟扫描出不活动的broker,然后从routeInfo中删除,第二个是,每个10分钟定时打印configTable的信息。 3.NettyBossSelector_1:Netty的boss线程(Accept线程),这里只有一根线程。 4.NettyEventExecuter:一个单独的线程,监听NettyChannel状态变化来通知ChannelEventListener做响应的动作。

发表在 编程语言 | 标签为 , | Comments Off on RocketMQ学习(三):rocketmq-namesrv介绍

RocketMQ学习(二):依赖关系和模块功能介绍

现在看的代码版本还是3.2.2 develop。先看张内部结构代码图: 从依赖层次再来看,越是被依赖的,越在底层: rocketmq包含9个子模块:

发表在 编程语言 | 标签为 , | Comments Off on RocketMQ学习(二):依赖关系和模块功能介绍