首页 > 代码库 > ranch分析学习(四)
ranch分析学习(四)
经过的前面的梳理，整个ranch框架的结构，大致有了一个清晰的脉络，即使我说的不是很清楚大家也基本能阅读懂源码。下面我继续分析剩下的的几个文件。
7.ranch_transport.erl
这个文件是一个自定义的的erlang行为模式，主要规范实现这个行为模式的子类必须要实现那个函数，整个函数分为行为callback的定义,模块函数的定义. 模块函数的实现sendfile. 具体实现了这个行为模式定义的callback的模块有（ranch_tcp.erl,ranch_ssl.erl） 这两个文件。看对应的名字都能大致明白什么功能和作用。这两个文件我觉得是整个框架传输处理的核心模块。也是把gen_tcp 和ssl 两种 传输协议做了一个统一的对外的接口，便于对整个框架结构的处理。也便于对传输协议的扩展。在协议扩展后仍然能再框架下稳定运行起重要作用。假设我们要ranch 支持gen_udp 协议的话 也只需要一个模块使用gen_udp 对整个协议封装处理即可。ranch_transport 整个回调木块对网络传输块做了如下的高度抽象。连接，监听，应答，参数设置，数据接收，发送，文件发送，断开，关闭 等接口做了高度抽象的概括。可以说cowboy 从 http 到 https 轻松无缝切换，都得益于整个行为模式的抽象处理。
8.ranch_acceptor.erl
start_link(LSocket, Transport, ConnsSup) -> Pid = spawn_link(?MODULE, loop, [LSocket, Transport, ConnsSup]), {ok, Pid}.
首先我们来看看start_link 的几个参数 第一个参数 连接监听的socket,第二个参数选择的传输协议 第三个参数连接监督，然后采用链接的方式开启一个线程。
flush() -> receive Msg -> error_logger:error_msg( "Ranch acceptor received unexpected message: ~p~n",[Msg]), flush() after 0 -> ok end.
这个文件中为什么会有flush()这个函数呢？首先这个函数主要是处理接受我们消息处理中不需要的消息，把消息信箱中比如攻击消息，等等其余无用的消息从消息信箱中移除，然后再几率日志。整个接受过程是一个0超时处理。如果整个没有这个刷新过程的话都存在一些垃圾消息存在于信箱，导致信箱消息不停的增大，内存不停的增加，最后导致内存消耗宕机。
最后我们来看看整个主循环
1 loop(LSocket, Transport, ConnsSup) -> 2 _ = case Transport:accept(LSocket, infinity) of 3 {ok, CSocket} -> 4 Transport:controlling_process(CSocket, ConnsSup), 5 %% This call will not return until process has been started 6 %% AND we are below the maximum number of connections. 7 ranch_conns_sup:start_protocol(ConnsSup, CSocket); 8 %% Reduce the accept rate if we run out of file descriptors. 9 %% We can‘t accept anymore anyway, so we might as well wait10 %% a little for the situation to resolve itself.11 {error, emfile} ->12 receive after 100 -> ok end;13 %% We want to crash if the listening socket got closed.14 {error, Reason} when Reason =/= closed ->15 ok16 end,17 flush(),18 ?MODULE:loop(LSocket, Transport, ConnsSup).
整个过程包括三个处理部分：第一步部分对socket accept 等待客户端连接，如果连接上以后启动一个连接处理的进程类。第二步清理消息信箱用无用的垃圾消息。第三部整个函数尾递归调用，继续等待客户端连接处理。
明天学习剩下的模块，并对整个零散的思维进行整体的梳理。