欢迎来到天天文库
浏览记录
ID:36297943
大小:1.79 MB
页数:46页
时间:2019-05-08
《xmpp协议的使用》由会员上传分享,免费在线阅读,更多相关内容在应用文档-天天文库。
1、在android里面用的smack包其实叫做asmack,该包提供了两种不同的连接方式:socket和httpclient。该并且提供了很多操作xmpp协议的API,也方便各种不同自定义协议的扩展。我们不需要自己重新去定义一套接收机制来扩展新的协议,只需继承然后在类里处理自己的协议就可以了。而本文今天主要说两点,一点就是消息是如何接收的,另一点就是消息是如何通知事件的。总的思路1.使用socket连接服务器2.将XmlPullParser的数据源关联到socket的InputStream3.启动线程不断循环处理消息4.将接收到的消息解析xml处理封装好成一个Pack
2、et包5.将包广播给所有注册事件监听的类逐步击破(声明在看下面的文章时,最好先理解一下smack的使用,这样才能达到深入的理解)(谨记:上图只显示本文章解释所要用到的类和方法,减缩了一些跟本文主题无关的代码,只留一条贯穿着从建立连接到接收消息的线。)解析这块东西打算从最初的调用开始作为入口,抽丝剥茧,逐步揭开。1.PacketListenerpacketListener=newPacketListener(){@OverridepublicvoidprocessPacket(Packetpacket){System.out.println("Activity----
3、processPacket"+packet.toXML());}};PacketFilterpacketFilter=newPacketFilter(){@Overridepublicbooleanaccept(Packetpacket){System.out.println("Activity----accept"+packet.toXML());returntrue;}};解释:创建包的监听以及包的过滤,当有消息到时就会广播到所有注册的监听,当然前提是要通过packetFilter的过滤。2.connection=newXMPPConnection();XMPP
4、Connection在这构造函数里面主要配置ip地址和端口(super(newConnectionConfiguration("169.254.141.109",9991));)3.connection.addPacketListener(packetListener,packetFilter);connection.connect();注册监听,开始初始化连接。4.publicvoidconnect(){//Stablishestheconnection,readersandwritersconnectUsingConfiguration(config);}5.p
5、rivatevoidconnectUsingConfiguration(ConnectionConfigurationconfig){Stringhost=config.getHost();intport=config.getPort();try{this.socket=newSocket(host,port);}catch(UnknownHostExceptione){e.printStackTrace();}catch(IOExceptione){e.printStackTrace();}initConnection();}通过之前设置的ip和端口,建立sock
6、et对象6.protectedvoidinitDebugger(){Class>debuggerClass=null;try{debuggerClass=Class.forName("com.simualteSmack.ConsoleDebugger");Constructor>constructor=debuggerClass.getConstructor(Connection.class,Writer.class,Reader.class);debugger=(SmackDebugger)constructor.newInstance(this,writ
7、er,reader);reader=debugger.getReader();}catch(ClassNotFoundExceptione1){//TODOAuto-generatedcatchblocke1.printStackTrace();}catch(Exceptione){thrownewIllegalArgumentException("Can'tinitializetheconfigureddebugger!",e);}}privatevoidinitReaderAndWriter(){try{reader=newBufferedReader(ne
此文档下载收益归作者所有