Receiver和ReceiverImpl 详解
Receiver 和ReceiverImpl的功能:它们是s4传输层到应用层的入口,首先将在传输层的Event(ByteBuffer message)反序列化生成Stream能够识别的Event,然后该Event添加到相应的Stream中。
ReceiverImpl 实现了Receiver接口的两个方法:
(1)Void receive (ByteBuffer message) ();
(2)int getPartitionId ();
由于方法(2)是调用底层的listener 的getPartitionId()方法得到,这里我们暂时不详细论述,之后讲述Listener(TCPListener、UDPListener)时再详细说明。
这里,我们主要论述方法(1),以及ReceiverImpl和stream的交互原理。
ReceiverImpl 维护一个Map<StreamName, Stream> map,通过addStream(Stream<? extends Event> stream)向map中添加stream。addStream 方法会在Stream的start()方法被调用,那么该Stream则被保存在map中。
在receive (ByteBuffer message)()中,先将收到的message反序列化生成Event,然后获得该Event对应的Stream的StreamName,从而在map中找到该Event所要到达的Stream,并调用该Stream的receiveEvent(Event event)方法以获取该event。接下来,该Stream会调用目标PE(ProcessingElement)的HandleInputEvent(Event event)方法,使得该event被相应的PE处理。总的来说,流程如下:
相关推荐
您可以使用 Windows 的“程序和功能”实用工具(添加/删除程序)卸载 Receiver。 注意:如果曾使用 Citrix Receiver Updater 安装 Receiver,请勿使用此方法。 在某些情况下,卸载 Receiver for Windows 不会删除...
citrix receiver for mac
Sender-receiver 消息 ,还是老话,学习JMS和activemq必看资料一直
simple FM receiver in Matlab
EventReceiver注册工具,Dll文件需要手动加入assembly文件里,然后重启IIS
syslog receiver syslog接收测试工具 MegaLogSyslogTestReceiverV2.zip
GNSS receiver and the receiver clock offset from measurements of at least four pseudoranges.
CitrixReceiver.dmg
CitrixReceiver.exe
最新版 Citrix Receiver,最新版 Citrix Receiver ,方便安装后完可以连接服务器。
本篇文章主要介绍了Android开发应用中Broadcast Receiver组件详解,想要学习的同学可以了解一下。
MirrorOp Win Receiver V 0.2.17.8
CitrixReceiver客户端支持xp系统,目前测试比较完美支持,xp系统需安装.net 2.0以上支持包
CitrixReceiver 的老版本,支持Xp 系统登录,官网获取。
Citrix Receiver卸载不了吗?请尝试下载该工具,可以轻松帮你卸载。
通过代码packmanager来管理manifest中receiver与activity和service
CitrixReceiver
Fast Shadow Receiver1.4.2 for unity3d 5
itrix Receiver是一种轻便的通用软件客户端,itrix Receiver(虚拟桌面软件)是一款非常优秀的专业的...这款虚拟桌面允许访问摄像头和麦克风、所在位置、本地应用程序等,兼容任何设备的Citrix产品,需要的朋友快来下载吧
GSM Receiver Simulation