- 浏览: 167948 次
- 性别:
- 来自: 深圳
文章分类
最新评论
-
dd18349182956:
你这是哪个版本的smack?
smack 源码分析- PacketWriter (android上实现长连接) -
wangshunfan:
跟着思路走,可以写出来!非常感谢!
Android开发笔记-EditText自动补全功能 -
337240552:
...
smack 源码分析- PacketReader (android上实现长连接) -
vasuer:
String jsonStr = request.getPar ...
前台如何将多个json对象传入java后台 -
ly_50:
下载Android SDK时出现Site Authentica ...
在线下载更新Android SDK提示Site Authentication
smack 源码分析- PacketReader (android上实现长连接)
- 博客分类:
- Android
smack 源码分析- PacketWriter (android上实现长连接) 介绍完PacketWriter 之后, 接下来分析PacketReader. PacketReader的作用主要用来接收云端推送的消息并解析然后调用相应的监听器完成相关的操作.
什么都别说, 先看代码:
//构造函数 protected PacketReader(final XMPPConnection connection) { this.connection = connection; this.init(); } /** * Initializes the reader in order to be used. The reader is initialized * during the first connection and when reconnecting due to an abruptly * disconnection. */ protected void init() { done = false; connectionID = null; //开辟一个线程, 解析收到的数据包 readerThread = new Thread() { public void run() { parsePackets(this); } }; readerThread.setName("Smack Packet Reader (" + connection.connectionCounterValue + ")"); readerThread.setDaemon(true); // Create an executor to deliver incoming packets to listeners. We'll // use a single // thread with an unbounded queue. listenerExecutor = Executors.newSingleThreadExecutor(new ThreadFactory() { public Thread newThread(Runnable runnable) { Thread thread = new Thread(runnable, "Smack Listener Processor (" + connection.connectionCounterValue + ")"); thread.setDaemon(true); return thread; } }); resetParser(); } /** * Parse top-level packets in order to process them further. * * @param thread the thread that is being used by the reader to parse * incoming packets. */ private void parsePackets(Thread thread) { try { int eventType = parser.getEventType(); do { if (eventType == XmlPullParser.START_TAG) { if (parser.getName().equals("message")) { processPacket(PacketParserUtils.parseMessage(parser)); } else if (parser.getName().equals("iq")) { processPacket(PacketParserUtils.parseIQ(parser, connection)); } else if (parser.getName().equals("presence")) { processPacket(PacketParserUtils.parsePresence(parser)); }
构造函数和init()方法PacketWriter一样, 不多说了. 直接看parsePackets(). 在parsePackets()是直接调用processPacket()方法解析, 我们再来看processPacket()方法:
/** * Processes a packet after it's been fully parsed by looping through the * installed packet collectors and listeners and letting them examine the * packet to see if they are a match with the filter. * * @param packet the packet to process. */ private void processPacket(Packet packet) { if (packet == null) { return; } // Loop through all collectors and notify the appropriate ones. for (PacketCollector collector : connection.getPacketCollectors()) { collector.processPacket(packet); } // Deliver the incoming packet to listeners. listenerExecutor.submit(new ListenerNotification(packet)); }
在processPacket()的最后一行是通过ExecutorService类型的一个listenerExecutor实例执行一个线程ListenerNotification完成的. 接下来:
/** * A runnable to notify all listeners of a packet. */ private class ListenerNotification implements Runnable { private Packet packet; public ListenerNotification(Packet packet) { this.packet = packet; } public void run() { //循环读取注册了的监听器并通知处理packet for (ListenerWrapper listenerWrapper : connection.recvListeners.values()) { listenerWrapper.notifyListener(packet); } } }
在ListenerNotification的run方法中, 是循环读取connection.recvListeners.values()获取ListenerWrapper .
那么ListenerWrapper 是什么呢? 我们首先来看这里connection.recvListeners.values(), 这connection实际上
是一个XMPPConnection的一个实例, 而XMPPConnection继承了Connection, recvListeners实际上是Connection
的一个成员变量. 然后再来看ListenerWrapper类:
/** * A wrapper class to associate a packet filter with a listener. * */ protected static class ListenerWrapper { private PacketListener packetListener; private PacketFilter packetFilter; /** * Create a class which associates a packet filter with a listener. * * @param packetListener the packet listener. * @param packetFilter the associated filter or null if it listen for * all packets. */ public ListenerWrapper(PacketListener packetListener, PacketFilter packetFilter) { this.packetListener = packetListener; this.packetFilter = packetFilter; } /** * Notify and process the packet listener if the filter matches the * packet. * @param packet the packet which was sent or received. */ public void notifyListener(Packet packet) { if (packetFilter == null || packetFilter.accept(packet)) { packetListener.processPacket(packet); } } }
ListenerWrapper类实际上是一个包装类, 该类的作用是将packetListener 和packetFilter关联在一起. 那么
packetListener 和packetFilter分别是什么嗯, 查看smack帮助文档可知:
Smack提供灵活的框架来通过两种构造处理收到的 packet:
- org.jivesoftware.smack.PacketCollector —— 一个让您同步等待新packet的类。
- org.jivesoftware.smack.PacketListener —— 一个异步通知您引入的packet的接口。
packet监听器用于事件样式的编程,而packet收集器有一个可以做轮询和阻塞操作的packet的结果队列。 所以, 当您想对一个有可能随时到来的packet采取一些操作时,使用packet监听器;而当您想等待一个特别的packet到来 时,使用packet收集器。您可以使用XMPPConnection实例创建packet收集器和监听器。
org.jivesoftware.smack.filter.PacketFilter 接口决定哪个特别的将会被传递 到PacketCollector或PacketListener。org.jivesoftware.smack.filter package包中有许多预定义的过滤器。
packetListener 是一个能够处理随时可能到了的packet监听器, packetFilter能够判断packet是否由该packetListener处理
是的话则调用processPacket()方法处理packet. 至此整个过程处理完成
发表评论
-
判断Android系统时间是否是24小时制
2012-05-07 12:04 6283次方法判断Android系统时间是否是24小时制: ... -
rm failed for Gallery3D.apk, Read-only file system
2012-05-02 18:31 0如果你获取了ROOT权限, 使用命令删除系统apk的时候也会报 ... -
在线下载更新Android SDK提示Site Authentication
2012-04-16 18:43 6247在线下载更新Android SDK时会提示:Site Aut ... -
使用AXMLPrinter2.jar批量反编译xml文件
2012-02-25 23:56 9132使用AXMLPrinter2.jar批量反编译xml文件. ... -
eclipse导入的Android项目没有android.jar包并报错
2012-02-15 11:35 9143从网上下载一个项目, 报错. 发现没有导入android.j ... -
[转载]Android UI 的更新及其线程模型
2012-02-06 11:00 1431让我们通过一个交通状 ... -
smack 源码分析- PacketWriter (android上实现长连接)
2012-01-11 16:36 3092上一篇smack 源码分析一(android上实现长连接) ... -
smack 源码分析一(android上实现长连接)
2012-01-11 15:35 8026前段时间应一个项目需求: 要求给终端短信, 联系人信息做一个 ... -
smack 源码分析一
2012-01-11 14:44 2前段时间应一个项目需求: 要求给终端短信, 联系人信息做一个 ... -
解决SipDroid导入Eclipse报错问题
2012-01-10 11:16 19801. 准备工具: SVN , ANT 2. 操作步骤: ... -
android sqlite查询数据时报错: get field slot from row 0 col -1 failed
2011-12-14 15:02 5067android sqlite查询数据时报错: get f ... -
Android开发笔记-签名认证
2011-10-08 12:32 1637一个android项目开发完成之后要安装到设备上或者放到电子市 ... -
Android开发笔记-EditText自动补全功能
2011-09-08 18:04 15360项目开发之需要, 根据用户拼音或代码检索出用户信息. 现在有 ... -
android开发笔记-sqllite数据库的操作
2011-09-08 17:01 33671.SQLLite简介: 在Android平 ... -
android开发笔记-ListView动态加载数据
2011-08-06 12:31 6951项目开发之需要, 做一个ListView分页显示, 动态加载数 ... -
android开发笔记-Handler的理解
2011-07-25 16:35 8341.Handler的定义: 在主线程中创建, 用于接收子 ... -
android开发笔记-Handler的理解
2011-07-25 16:32 9221.Handler的定义: 在主线程中创建, 用于接收子 ... -
Android常见组件属性详解
2011-07-20 16:07 6151. TextView 属性详解: http://www.cm ... -
Android常见错误代码
2011-07-20 15:50 11961.Installation error: INSTALL_F ... -
基于Google Map API的android地图开发
2011-05-23 22:37 29391. 因为Google Map 类库不是android sdk ...
相关推荐
sqlbuilder.zip,一个用于构建和执行SQL Stasks.SQL Builder库的轻量级库
smack4.1.0的依赖包minidns.jar。可用于smack4.1.3,亲测可用!
peon.zip,一种牡丹,它在后台执行你想扔给它的任何体力劳动任务;一种爪哇牡丹,它在后台执行你想扔给它的任何体力劳动任务。
[Cloud Frameworks]SMACK Big Data Architecture - user guide / [云框架]SMACK大数据架构-用户指南
smack用于android移动端的开发,可以结合openfire使用,进行im通信
jxmpp-core-0.5.0-alpha7 jxmpp-util-cache-0.5.0-alpha7 smack-android-4.1.6 smack-core-4.1.6 smack-extensions-4.1.6 smack-im-4.1.6 smack-sasl-provided-4.1.6 smack-tcp-4.1.6
smack 在4.1.0以后支持android上使用,demo里集成了smack4.1.9在android的使用
smack源码下载,java版下载,smack源码下载
common-jetty-testrunner.zip,此包提供两个测试运行程序-一个用于集成测试(初始化
Smack是一个用于实现和XMPP服务器即时通讯的类库,功能包括即时通信和群聊。
smack源码
smack-im-4.2.2.jar smack-tcp-4.2.2.jar smack-extensions-4.2.2.jar smack-core-4.2.2.jar smack-android-extensions-4.2.2.jar jxmpp-jid-0.6.0.jar jxmpp-core-0.6.0.jar jxmpp-util-cache-0.6.0.jar等jar包
Smack源码,要的拿走,有需要的可以看看,多看源码帮助很大
fast-video-view.zip,用于Android的基于TextureView的VideoView实现。用于Android的基于TextureView的VideoView实现。
smack工具,经修改可以使用.smackcipso smackload smackaccess smackctl
smack源码 android-open-project Google Code开源项目 1、 ZXing 条形码、二维码 2、 K-9 Mail 邮件客户端 3、 Sipdroid SIP/VoIP 客户端 4、 Openintents 提供了大量的应用程序,使用intent,简化开发 5、 Libgdx ...
timplus-smack-tcp-netty 使用Netty网络框架的TCP smack连接的实现。 该库的目的是用于在现有实现与TIM +服务提供者之间建立桥接服务的系统。 在许多情况下,网桥服务可能需要与TIM +服务建立数百个(如果不是数千...
Smack-Openfire im with Android, include heartbeat and auto reconnect 图文详情地址: Smack是一个开源,易于使用的XMPP(jabber)客户端类库。优点:简单的,功能强大,给用户发送信息只需三行代码便可完成。...