ejabberd:route去向

ejabberd_local在init中注册了一个服务，pid(self())和MODULE:FUNCTION保存在route表中。

ejabberd_router:route

ejabberd_router:do_route 判断domain (1)是路由还是(2)交给本地处理

(1)ejabberd_local:do_route:(1.1)用户不为空,(1.2)用户为空且资源为空，(1,3)其它路由返回错误

(2)ejabberd_sm:do_route:(2.1)bare JID,(2.2)full JID

 

ejabberd_route: 代码片段
319             case mnesia:dirty_read(route, LDstDomain) of                                                                                                 
320                 [] ->
321                     ejabberd_s2s:route(From, To, Packet);     %%处理不同域
322                 [R] ->
323                     Pid = R#route.pid,             %%处理同域 pid是ejabberd_local 的sefl(),MODULE是ejabberd_local.erl
324                     if
325                         node(Pid) == node() ->             
326                             case R#route.local_hint of         
327                                 {apply, Module, Function} ->       
328                                     Module:Function(From, To, Packet);                                                                                   
329                                 _ ->                               
330                                     Pid ! {route, From, To, Packet}                                                                                      
331                             end;                       
332                         is_pid(Pid) ->                     
333                             Pid ! {route, From, To, Packet};
334                         true ->                            
335                             drop                   
336                     end;
                             .......................处理集群.............

 

 

 

do_route(From, To, Packet) 

TO（JID）没有user由ejabberd_local处理

                    有user没有资源由ejabberd_sm处理

                    有user和资源由 直接发送

 

ejabberd_local:代码片段：

do_route(From, To, Packet) ->
    ?DEBUG("local route~n\tfrom ~p~n\tto ~p~n\tpacket ~P~n",
           [From, To, Packet, 8]),
    if
        To#jid.luser /= "" ->
            ejabberd_sm:route(From, To, Packet);
        To#jid.lresource == "" ->
            {xmlelement, Name, _Attrs, _Els} = Packet,
            case Name of
                "iq" ->
                    process_iq(From, To, Packet);
                "message" ->
                    ok;
                "presence" ->
                    ok;
                _ ->
                    ok
            end;
        true ->
            {xmlelement, _Name, Attrs, _Els} = Packet,
            case xml:get_attr_s("type", Attrs) of
                "error" -> ok;
                "result" -> ok;
                _ ->
                    ejabberd_hooks:run(local_send_to_resource_hook,
                                       To#jid.lserver,
                                       [From, To, Packet])
            end
        end.

评论

1 楼 yjl49 2011-09-19  

jabber:iq:roster 添加路由的时候是用jabberd_sm:process_iq ，但在取的时候却是jabberd_local ?

gen_iq_handler:add_iq_handler(ejabberd_sm, Host, ?NS_ROSTER,
  ?MODULE, process_iq, IQDisc).


{From, To, Packet} ->
    LDstDomain = To#jid.lserver,
    case mnesia:dirty_read(route, LDstDomain) of
[] ->
    ejabberd_s2s:route(From, To, Packet);
[R] ->
    Pid = R#route.pid,
    if
node(Pid) == node() ->
    case R#route.local_hint of
{apply, Module, Function} ->
    Module:Function(From, To, Packet);