分类目录归档：编程语言

源代码版本是3.2.6，还是直接跑源代码，启动配置参照前面写的《简介和quickstart》，启动顺序是namesrv，broker，filtersrv，filter和broker有顺序要求，如果filtersrv启动后找不到broker，则会System.exit()退出程序。 看下启动图： 看rocketmq-filtersrv代码，核心processor包下的只有一个Class类且只处理2种类型的请求，即DefaultRequestProcessor.processRequest()只处理RequestCode.REGISTER_MESSAGE_FILTER_CLASS和RequestCode.PULL_MESSAGE： REGISTER_MESSAGE_FILTER_CLASS：接收consumer端注册过来的filterClass源代码的请求。 PULL_MESSAGE：接收consumer端发出的拉消息的请求。

刚刚拉了最新的代码，版本是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做响应的动作。

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

RocketMQ是什么？ 引用官方描述： RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点： 支持严格的消息顺序 支持Topic与Queue两种模式 亿级消息堆积能力 比较友好的分布式特性 同时支持Push与Pull方式消费消息 历经多次天猫双十一海量消息考验 RocketMQ是纯java编写，基于通信框架Netty。 代码地址：https://github.com/alibaba/RocketMQ，目前分支是3.2.2 develop。 下载完代码后，将各个模块导入eclipse，本地尝试启动看看。 1.启动nameServer，运行rocketmq-namesrv的NamesrvStartup，运行之前需设置环境变量ROCKETMQ_HOME为RocketMQ项目的根目录，这样有一个作用是，指向logback的配置文件路径，保证在nameServer启动时，logback的正常初始化。我本机设置的是：ROCKETMQ_HOME=C:\Users\Administrator\git\RocketMQ。 The Name Server boot success. 表示启动成功。 2.启动brokerServer，运行rocketmq-broker的BrokerStartup，同样，运行之前需设置环境变量ROCKETMQ_HOME，然后启动参数需要带上【-n “192.168.0.109:9876″】，我本机的ip是192.168.0.109。如果不带-n的参数，那么broker会去访问http://jmenv.tbsite.net:8080/rocketmq/nsaddr获取nameServer的地址，这个地址不是我们自己的nameServer。 The broker[LENOVO-PC, 192.168.0.109:10911] boot success. and name server is 192.168.0.109:9876表示成功。 3.这个非必选项，不运行也可以。还可以启动rocketmq-srvutil的FiltersrvStartup，这是Consumer使用Java代码，在服务器做消息过滤。启动方式和broker一样，具体的过滤原理以后再详细的说。 到此就可以运行demo了。