赞
踩
(注:分析代码基于RabbitMQ 2.8.2)
网络层的启动也是作为上一篇文章中提到的一个启动步骤来启动的,入口为[$RABBIT_SRC/src/rabbit_networking.erl --> boot/0],代码如下:
boot() -> ok = start(), ok = boot_tcp(), ok = boot_ssl().
[$RABBIT_SRC/src/rabbit_networking.erl --> start/0]构建rabbit_client_sup子监控树,[$RABBIT_SRC/src/rabbit_networking.erl --> boot_tcp/0],启动TCP监听,并构建成tcp_listener_sup子监控树,这两个子树都属于rabbit最顶层监控结点rabbit_sup(SSL的类似)。最终的监控树如下:
(注:方框代表supervisor类型,圆角代表worker;虚线灰底的文字代表相应层子进程重启策略;各结点以各自所在的模块命名,实际监控树中的结点名有部分不同。)
[$RABBIT_SRC/src/tcp_listener.erl --> init/1]通过gen_tcp:listen/2启动监听,并根据ConcurrentAcceptorCount参数启动指定数量个tcp_acceptor(当前这个数量是1)。
[$RABBIT_SRC/src/tcp_acceptor.erl]通过prim_inet:async_accept/2开始异
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。