曾经有一个同学，在网上问我，如果想androidpn添加额外的xmpp协议的方法在怎么加呢？我当时很迷惑，后来经过一翻仔细研究androidpn发现，其实每一种处理xmpp协议方法，必须有一个Handler实现。具体可以参考org.androidpn.server.xmpp.handler中。

针对每一个Handler对应的xml拥有不同的命名空间，每一个命名空间在xmpp中都有定义，因为传输的xml的格式是一定的。

例如：

IQAuthHandler：命名空间 String NAMESPACE = "jabber:iq:auth";

IQRegisterHandler：命名空间 String NAMESPACE = "jabber:iq:register";

IQRosterHandler：命名空间 String NAMESPACE = "jabber:iq:roster";

同时我们从Handler的实现可以看到每一个handler最好实现对应IQHandler类，但是为辅助类型的Handler那么可以不用，例如androidpn的状态更新处理器类PresenceUpdateHandler，不必要发送相关的消息到客户端。

所以如果要实现xmpp中如查看好友，用户分组等通信协议，那么你可能要实现相关的Handler并使用xmpp协议规定的相关的命名空间。

在androidpn中主要的业务处理类XmppIoHandler可以看出最终消息解析之后分发到IQRouter中。IQRouter用于处理消息的响应的消息。

IQRouter的源代码如下：

Java代码
  1. packageorg.androidpn.server.xmpp.router;
  2. importjava.util.ArrayList;
  3. importjava.util.List;
  4. importjava.util.Map;
  5. importjava.util.concurrent.ConcurrentHashMap;
  6. importorg.androidpn.server.xmpp.handler.IQAuthHandler;
  7. importorg.androidpn.server.xmpp.handler.IQHandler;
  8. importorg.androidpn.server.xmpp.handler.IQRegisterHandler;
  9. importorg.androidpn.server.xmpp.handler.IQRosterHandler;
  10. importorg.androidpn.server.xmpp.session.ClientSession;
  11. importorg.androidpn.server.xmpp.session.Session;
  12. importorg.androidpn.server.xmpp.session.SessionManager;
  13. importorg.apache.commons.logging.Log;
  14. importorg.apache.commons.logging.LogFactory;
  15. importorg.dom4j.Element;
  16. importorg.xmpp.packet.IQ;
  17. importorg.xmpp.packet.JID;
  18. importorg.xmpp.packet.PacketError;
  19. /**
  20. *ThisclassistorouteIQpacketstotheircorrespondinghandler.
  21. *
  22. *@authorSehwanNoh(devnoh@gmail.com)
  23. */
  24. publicclassIQRouter{
  25. privatefinalLoglog=LogFactory.getLog(getClass());
  26. privateSessionManagersessionManager;
  27. privateList<IQHandler>iqHandlers=newArrayList<IQHandler>();
  28. privateMap<String,IQHandler>namespace2Handlers=newConcurrentHashMap<String,IQHandler>();
  29. /**
  30. *ConstuctsapacketrouterregisteringnewIQhandlers.
  31. */
  32. publicIQRouter(){
  33. sessionManager=SessionManager.getInstance();
  34. iqHandlers.add(newIQAuthHandler());
  35. iqHandlers.add(newIQRegisterHandler());
  36. iqHandlers.add(newIQRosterHandler());
  37. }
  38. /**
  39. *RoutestheIQpacketbasedonitsnamespace.
  40. *
  41. *@parampacketthepackettoroute
  42. */
  43. publicvoidroute(IQpacket){
  44. if(packet==null){
  45. thrownewNullPointerException();
  46. }
  47. JIDsender=packet.getFrom();
  48. ClientSessionsession=sessionManager.getSession(sender);
  49. if(session==null
  50. ||session.getStatus()==Session.STATUS_AUTHENTICATED
  51. ||("jabber:iq:auth".equals(packet.getChildElement()
  52. .getNamespaceURI())
  53. ||"jabber:iq:register".equals(packet.getChildElement()
  54. .getNamespaceURI())||"urn:ietf:params:xml:ns:xmpp-bind"
  55. .equals(packet.getChildElement().getNamespaceURI()))){
  56. handle(packet);
  57. }else{
  58. IQreply=IQ.createResultIQ(packet);
  59. reply.setChildElement(packet.getChildElement().createCopy());
  60. reply.setError(PacketError.Condition.not_authorized);
  61. session.process(reply);
  62. }
  63. }
  64. privatevoidhandle(IQpacket){
  65. try{
  66. ElementchildElement=packet.getChildElement();
  67. Stringnamespace=null;
  68. if(childElement!=null){
  69. namespace=childElement.getNamespaceURI();
  70. }
  71. if(namespace==null){
  72. if(packet.getType()!=IQ.Type.result
  73. &&packet.getType()!=IQ.Type.error){
  74. log.warn("Unknownpacket"+packet);
  75. }
  76. }else{
  77. IQHandlerhandler=getHandler(namespace);
  78. if(handler==null){
  79. sendErrorPacket(packet,
  80. PacketError.Condition.service_unavailable);
  81. }else{
  82. handler.process(packet);
  83. }
  84. }
  85. }catch(Exceptione){
  86. log.error("Couldnotroutepacket",e);
  87. Sessionsession=sessionManager.getSession(packet.getFrom());
  88. if(session!=null){
  89. IQreply=IQ.createResultIQ(packet);
  90. reply.setError(PacketError.Condition.internal_server_error);
  91. session.process(reply);
  92. }
  93. }
  94. }
  95. /**
  96. *Sendatheerrorpackettotheoriginalsender
  97. */
  98. privatevoidsendErrorPacket(IQoriginalPacket,
  99. PacketError.Conditioncondition){
  100. if(IQ.Type.error==originalPacket.getType()){
  101. log.error("CannotreplyanIQerrortoanotherIQerror:"
  102. +originalPacket);
  103. return;
  104. }
  105. IQreply=IQ.createResultIQ(originalPacket);
  106. reply.setChildElement(originalPacket.getChildElement().createCopy());
  107. reply.setError(condition);
  108. try{
  109. PacketDeliverer.deliver(reply);
  110. }catch(Exceptione){
  111. //Ignore
  112. }
  113. }
  114. /**
  115. *AddsanewIQHandlertothelistofregisteredhandler.
  116. *
  117. *@paramhandlertheIQHandler
  118. */
  119. publicvoidaddHandler(IQHandlerhandler){
  120. if(iqHandlers.contains(handler)){
  121. thrownewIllegalArgumentException(
  122. "IQHandleralreadyprovidedbytheserver");
  123. }
  124. namespace2Handlers.put(handler.getNamespace(),handler);
  125. }
  126. /**
  127. *RemovesanIQHandlerfromthelistofregisteredhandler.
  128. *
  129. *@paramhandlertheIQHandler
  130. */
  131. publicvoidremoveHandler(IQHandlerhandler){
  132. if(iqHandlers.contains(handler)){
  133. thrownewIllegalArgumentException(
  134. "CannotremoveanIQHandlerprovidedbytheserver");
  135. }
  136. namespace2Handlers.remove(handler.getNamespace());
  137. }
  138. /**
  139. *ReturnsanIQHandlerwiththegivennamespace.
  140. */
  141. privateIQHandlergetHandler(Stringnamespace){
  142. IQHandlerhandler=namespace2Handlers.get(namespace);
  143. if(handler==null){
  144. for(IQHandlerhandlerCandidate:iqHandlers){
  145. if(namespace.equalsIgnoreCase(handlerCandidate.getNamespace())){
  146. handler=handlerCandidate;
  147. namespace2Handlers.put(namespace,handler);
  148. break;
  149. }
  150. }
  151. }
  152. returnhandler;
  153. }
  154. }

由以上的源代码可以看出，IQRouter在加载时候将各种处理器添加到回话管理器中，当消息分发到IQRouter中时候，根据命名空间的不同使用不同的处理处置即可。

androidpn的学习研究（七）Androidpn-server的添加其他xmpp相关的协议（如查看好友列表等）...相关推荐

  1. BT源代码学习心得(七)：跟踪服务器(Tracker)的代码分析(HTTP协议处理对象) -- 转贴自 wolfenstein (NeverSayNever)

    BT源代码学习心得(七):跟踪服务器(Tracker)的代码分析(HTTP协议处理对象) author: wolfenstein (NeverSayNever) 上次我们分析了Tracker类初始化的 ...

  2. androidpn的学习研究（六）Androidpn-server的Mina编码和解码解析过程

    在许多网络应用中可能针对传输的数据进行加密操作,接收到数据之后进行解码操作. 在mina中提供许多加密和解密的解析方式: 1.带一定前缀的字符串的解析方式. 2.序列化对象的字符串解析方式. 3.分隔 ...

  3. androidpn的学习研究（二）androidpn-server服务端启动过程的理解分析

    在Androidpn的底层主要采用的mina和openfire两大框架,其中mina主要为底层数据传输的Socket框架.下面简单说明mina的框架. Apache Mina Server 是一个网络 ...

  4. androidpn的学习研究（八）androidpn 中业务类XmppIoHandler实现分析

    在androidpn中主要采用Mina进行网络通讯,其中Mina中IoHandler用来处理主要的业务逻辑. Mina 中源代码如下: Java代码   package org.apache.mina ...

  5. androidpn的学习研究（五）androidpn-client 常见BUG解决方法

    原文地址:http://phonepush.sinaapp.com/forum.php?mod=viewthread&tid=6&extra=page%3D1 最近有需要做手机推送方面 ...

  6. androidpn的学习研究（一）androidpn-server服务端相关配置的常识

    androidpn的一些基本常识: ANDROIDPN_HOME=C:\android-push\androidpn-server-0.5.0 启动androidpn服务端: %ANDROID_HOM ...

  7. androidpn的学习研究（四）androidpn-client客户端几个类说明

    在androidpn的客户端几个重要的类: ServiceManager:管理消息服务和加载相关的配置. ConnectivityReceiver:处理网络状态的广播. NotificationRec ...

  8. androidpn的学习研究（三）androidpn-server服务端几个类说明

    AndroidPN(Android Push Notification) 是一个基于XMPP协议的Java开源推送通知实现,它包含了完整的客户端和服务端. AndroidPN基于Openfire下的一 ...

  9. 强化学习实践七：给Agent添加记忆功能

    在<强化学习>第一部分的实践中,我们主要剖析了gym环境的建模思想,随后设计了一个针对一维离散状态空间的格子世界环境类,在此基础上实现了SARSA和SARSA(λ)算法.<强化学习& ...

最新文章

  1. tinyxml 读取文本节点_TinyXml 读写XML文件
  2. JavaScript之数据类型
  3. Php7安装pdo_pgsql，pgsql扩展
  4. 书籍推荐：《More Effective C#》
  5. html5响应式网站优势,响应式网站优势有哪些 真的利于排名优化么
  6. MATLAB二维数组的创建与元素提取
  7. java synoch 加锁_线程间通信 - HappyCowboy - 博客园
  8. python快速入门及进阶
  9. 项目管理：文档可测试化
  10. (转载)用C#实现MySQL建库及建表
  11. 解决清除浮动的最佳办法
  12. char 数组和 int 之间转化
  13. [转]Java 的强引用、弱引用、软引用、虚引用
  14. SAP License：ERP系统和OA系统的区别？
  15. 手把手带你将手机打造一台私人便捷服务器及私人云盘
  16. jQuery实现简单分页
  17. 凹入法写入指定目录至文档，并计算目录大小
  18. bootstrap table th内容太多表格撑破(自动换行)
  19. 参数方程求二阶导时候不能直接把y,x分别对t求二阶导然后再相除作为d²y/dx²的原因
  20. 黑白棋（Othello）

热门文章

  1. [转]nodejs npm常用命令
  2. 关于WEB集群中文件服务器的讨论
  3. 编译安装postfix+sasl+mysql+dovecot+extmail构建完成的邮件系统（一）
  4. 使用Java的代理机制进行日志输出
  5. 题解 P2610 【[ZJOI2012]旅游】
  6. 《区块链原理、设计与应用》一3.8　本章小结
  7. 【译】技能测试解决方案：Python中的数据科学（一）
  8. 野心勃勃的NoSQL新贵 MongoDB应用实战(5)
  9. svn in xcode5
  10. Sql Function defference returns and returns