rabbitmq 是tcp 还是http

rabbitMQ的网络层用tcp协议，那么接下来我们分析一下是怎么实现的。

接src/rabbit.erl中tcp listeners启动项：

我们进入src/rabbit_networking.erl中，start/0函数中启动了tcp_client_sup监控树，该监控树是simple_one_for_one，用于开启协议接收模块（rabbit_reader）。simple_one_for_one、one_for_one、one_for_all这几钟监控策略（还有一种rest_for_one），简单以项目实例来举例，每个client连接服务器时都会有一个socket进程，关闭连接后进程消亡，这种需要频繁地动态创建、销毁进程的时候，就用simple_one_for_one；tcp_accept、tcp_listener间相互合作、缺一不可时，使用one_for_all，只要其中一个进程挂掉，就会重启该监控树下的全部进程；其他一些模块如果是独自动作、互不干扰的情况，则使用one_for_one策略。关于erlang监控策略.

ebin/rabbit.app中，{tcp_listeners, [{"0.0.0.0", 5672}]的IP端口是一个list，可以开启多个端口监听socket连接。src/rabbit_networking:start_tcp_listener中，开启tcp_listener监听进程，图：

这里开启了多个acceptor进程（防止多个客户端同时连接时出现阻塞），当接收到socket连接请求时，src/tcp_acceptor.erl模块就会生成一个新的client进程，并把socket控制权交出（下图，src/rabbit_networking.erl代码片段）。

socket连上后，协议交互的逻辑处理就根据自己定的规则在rabbit_tcp_client_sup模块中完善（该模块缺省）。

src/tcp_acceptor.erl中用到了prim_inet:async_accept/2函数

以上全属个人意见。

鹏仔微信 15129739599 鹏仔QQ344225443 鹏仔前端 pjxi.com 共享博客 sharedbk.com