emq简介

emq为mqtt的erlang实现，看了官方文档总觉得不太给力，所以决定开始emq代码探索之旅，能力有限，如有错误请大家指正。今天是第一站，emqtt源码学习（1）—初识emq.

emq的启动

emqttd_app.erl ：

start(_Type, _Args) ->
%% emq启动时会打印提示信息
print_banner(),
%% ekka是一个类zookeeper的东东，emq集群相关功能基于该应用
ekka:start(),
%% 启动emq监控进程，该进程下会挂载许多emq核心功能进程
{ok, Sup} = emqttd_sup:start_link(),
%% 在emq监控进程下，启动核心功能进程
start_servers(Sup),
%% cli：commnad line interface，该语句实现命令行功能，如用户通过 emqttd start 启动程序，事实上该命令将会转换为对应的erlang调用。该模块实现通过命令行对emq application中的参数进行设置查询，提供一种在程序运行过程中实时修改相关参数的接口，比如修改mqtt.client.max_publish_rate。
emqttd_cli:load(),
%% 加载acl认证模块
register_acl_mod(),
%% 该语句做两个事情，第一，绑定ekka模块的回调函数，包括prepar以及reboot的回调函数，可以认为该语句实现了ekka的一些配置。第二，如需要启动相应的插件，如校验插件，这里的插件指的是erlang 的application。第三，也是最重要的是启动了服务监听端口，包括tcp（esocked），加密tcp，web socket，加密websocket，这些监听模块都是第三方开源框架
start_autocluster(),
%% 注册名字
register(emqttd, self()),
%%打印版本信息
print_vsn(),
{ok, Sup}.

我第一次看这部分代码的时候对ekka产生了浓厚的兴趣，因为之前了解过zookeeper，初步认定这个ekka也是类似的吧，大概看了ekka的代码，基本证实了我的认定。

ekka和emq什么关系

先上个图：

如上图所示，emq基于ekka，ekka又基于mnesia，不同层作用也不一样，以mnesia为例，该应用其实就是erlang的分布式数据库，ekka就是通过mneisa进行集群管理，比如调用mnesia:system_info(running_db_nodes) 可以获取当前健康的mnesia节点，调用mnesia:system_info(db_nodes)可以获取mnesia包含的所有节点db_nodes > running_db_nodes时就表明有节点故障了。

下一站我们会游览emq其他核心功能模块（挂在在emqttd监控树下的进程）