ejabberd分析(5)+订阅/添加好友

ejabberd分析(五)+订阅/添加好友

模块ejabberd_c2s中，状态为session_established2。

用户发送iq set 消息到服务器

<iq id="M8QF3-52" type="set"><query xmlns="jabber:iq:roster"><item jid="1555215557@kinglong" name="1555215557"><group>Friends</group></item></query></iq>

服务器端匹配到

?<blockquote>上面这段代码需要注意ToJID的解析，发送给服务器的消息一般是默认不带to 属性的，这种情况下会自动将to 补上(这关系到包的路由)。</blockquote>ejabberd_hooks:run(user_send_packet 会记录用户发送的消息到日志。check_privacy_route 中对权限进行效验，通过后调用ejabberd_router:route(FromRoute, To, Packet) 进行路由。在ejabberd_router:route中调用do_route/3：?<textarea name="code" style="width: 644px; height: 59px;" style="width: 647px; height: 52px;" style="width: 645px; height: 122px;" style="width: 644px; height: 75px;" -> ejabberd_sm:route(From, To, Packet);

也就是说对于那些在session_established 之后发送的消息都会交由ejabberd_sm去路由。

在ejabberd_sm中由do_route/3 来处理：

ejabberd_sm 中有一张 sm_iqtable 里面记录了各个命名空间的消息最终由那个模块进行处理。?ejabberd_sm 是一个gen_server 当调用register_iq_handler 接口时会向sm_iqtable 插入记录。而这些命名空间处理模块的登记是由gen_iq_handler 模块的add_iq_handler/6 来进行的。<textarea name="code" style="width: 643px; height: 133px;" src="/img/2012/06/27/181527166.gif"> 在mod_roster:start/2 中有如下代码：?<textarea name="code" style="width: 641px; height: 55px;" style="width: 639px; height: 145px;" type="set">??<textarea name="code" style="width: 641px; height: 137px;" style="width: 640px; height: 514px;" class="java"> %% 如果是删除</pre> remove ->mnesia:delete({roster, {LUser, LServer, LJID}});
%%否则添加
_ ->mnesia:write(Item2)end,
%% If the item exist in shared roster, take the%% subscription information from there:
Item3 = ejabberd_hooks:run_fold(roster_process_item,LServer, Item2, [LServer]),
case roster_version_on_db(LServer)
oftrue -> mnesia:write(#roster_version{us = {LUser, LServer}, version = sha:sha(term_to_binary(now()))});
false -> okend,{Item, Item3}end,
case mnesia:transaction(F)
of{atomic, {OldItem, Item}} -> push_item(User, LServer, To, Item),
case Item#roster.subscription
ofremove -> send_unsubscribing_presence(From, OldItem),
ok;_ -> ok end;
E -> ?DEBUG("ROSTER: roster item set error: ~p~n", [E]), ok end end;

以上就是一条添加/订阅好友的iq 消息在ejabberd 中从接收到最终写入到数据库所经过的路径。

ejabberd分析(5)+订阅/添加好友

热点推荐