ejabberd源码流程梳理

ejabberd的工程主要通过ejabberd.app 组织起来

ejabberd.erl ：

application:start(ejabberd).

ejabberd_app.erl：

Mod：start(normal, _Args); 该函数中启动ejabberd_listener:start_listeners()

ejabberd_listener.erl

通过 conf 得到ejabberd_c2s，

开始listen

如果有连接,accpet之后

ejabberd_socket:start(Module, gen_tcp, Socket, Opts)

Receiver=ejabberd_receiver:start(

Socket,SockMod,none,MaxStanzaSize),

ejabberd_receiver.erl

ejabberd_receiver是一个gen_server进程(behaviour)，

receiver 收到数据（handle_info）发送到xml_stream.

xml_stream解析数据后发送到c2s状态机.

ejabber_c2s.erl

是一个gen_fsm(有限状态机)，维护一系列client和server之间的状态。gen_fsm的状态改变是由gen_fsm:send_event(FsmRef,Event)触发的。在ejabberd里，ejabberd_receiver通过xml_stream把事件和xml发送至ejabber_c2s改变其状态。
ejabber_c2s有限状态机的初始状态是wait_for_stream,其余的状态有：
wait_for_auth,wait_for_feature_request,wait_for_sasl_response,wait_for_bind,wait_for_session,session_established

ejabberd官方文档中提到的那些关于xmpp收到的事件的hook，就是在c2s中实现的。

c2s中调用ejabberd_hooks:run_fold()来运行相应的hook。

1.Presence消息流程

用户登陆过程中：

在c2s的waitforsession中调用

{Fs, Ts} = ejabberd_hooks:run_fold(

roster_get_subscription_lists,

StateData#state.server,

{[], []},

[U, StateData#state.server]),

获取from、to好友列表，分别置入state. pres_f和state. pres_t中。

客户端登陆成功后，给服务器发送

</presence>

该presence没有目的地址（to）。

服务端收到该消息在c2s的session_established2中处理，

调用presence_update(FromJID, PresenceEl,StateData)

èpresence_broadcast_first(From, NewStateData, Packet);

（1）给state.pres_t中每个成员发送probe；

（2）给state.pres_f中每个成员发送presence

2.添加好友流程

以Lihengz 添加 admin 好友为例

下列状态值中第一项为“订阅（subscription）”，第二项为“挂起（ask）”

Lihengz的状态变化为：out_state_change(none,none, subscribe) -> {none, out};

Admin的状态变化为：in_state_change(none,none, subscribe) -> {none, in};

Admin接受请求后，状态变化：out_state_change(none,in, subscribed) -> {from, none};

Lihengz状态变化：in_state_change(none,out, subscribed) -> {to, none};

如果admin也加lihengz为好友：

admin状态变化：out_state_change(from,none, subscribe) -> {from, out};

lihengz状态变化: in_state_change(to, none, subscribe) -> {to, in};

lihengz接受请求后，状态变化：out_state_change(to, in, subscribed) -> {both, none};

admin状态变化：in_state_change(from,out, subscribed) -> {both, none};

3，在服务器上添加通讯录

在服务器上为mine添加mine1为好友（mine1未设置自动添加好友）

mine客户端会收到如下消息：

</query>

</iq>

如果mine1拒绝请求，mine客户端就收不到后续消息了。Roster表中一直维持挂起状态。

如果mine1设置为自动添加好友，mine客户端会收到：

</query>

</iq>