【Openfire】Openfire Server presence在线状态消息处理流程
Presence处理是IM Server的核心,也是一个IM Server最复杂的部分。一个用户的状态发生变化,需要通过服务器自动投递给他所有在线的好友,因此Presence模块实际上等同一个消息处理服务器,可参看以前消息服务器相关文章ActiveMQ性能研究及与memcacheq比较。
Presence的复杂性体现在:
1.由于每个用户都有1到多个好友,服务器的处理量被放大。
2.分布式处理的复杂度,你的好友可能同时分布在n个服务器上,而且同时上线的好友没有规律。
3.请求量不均衡,可能瞬时非常大。比如你服务器刚重启所有的客户几乎同时自动重连过来。比如Twitter宕机都是在一些热点事件时,大家活跃度突然同时增大。所以系统必须按峰值的处理量设计。
4.缓存cache设计困难。每个用户的在线好友都不同,而且随时在变。
5.隐身同黑名单的业务逻辑很难高效处理。
OpenfireServer处理presence的流程如下,以3.6.0为准。
1.ConnectionHandler.messageReceived();
mina层面处理。
2.StanzaHander.process()=>processPresence
xmpp层面。处理所有xmpp包的方法,实际上只有login相关包在这里处理。其他类型的包交由相关逻辑类来处理。由于是个presence包,交由下面presence逻辑处理模块进行。(alsoaddfromtopacket)
3.PacketRouteImpl.route()//routepresence
4.PresenceRoute.route()=>handle()//routepresence
由于presence是一个需要路由的包,路由主要区分目标是本机还是远程,是component/server还是普通用户。
5.PresenceUpdateHandler.process()=>broadcastUpdate
//process()updatedbandupdatecache,
callsPresenceManager.userAvaliable();session.setPresence()...
6.Roster.broadcastPresence();
检查privacylist(隐身及黑名单用户)然后路由给所有在线好友。
7.RoutingTable.routePacket,routeTable.getRoutes()
真正的工作在这里,较慢。
8.session.process(),session.deliver
已经分发到相关用户了,调用该用户的session投递给此用户
9.nioconnection().deliver,delivertotheendusers
再回到MINA
因此Presence投递工作的核心是在6~7,不过其他的步骤也有不少细节的处理。Openfire中6~7的实现比较精简和优雅,但如果想作为一个大型的高效消息投递系统还是有改进的空间