有效订阅数据源
Effective subscription to data feeds
如何在G-Wan中有效实现订阅机制?假设,我想让 g-wan 聚合来自各种代码的数据并进一步处理它。而且,显然,每个提要都以其独特的格式提供数据。
最直接的方法是在连接处理程序的 init() 函数中创建连接并订阅数据,然后从响应中解析源信息并从main() 函数到专用队列。但是这种方法似乎并没有利用G-Wan有效的任务调度引擎。那么,有没有专门的软件可以更快的解决问题呢?
另一种方法是为每个订阅创建专用的 servlet。为此,在连接处理程序的 main() 函数中,我需要重写 headers 并包括相应的 servlet 的名称。在这种情况下,我会使用整个 g-wan 机器。但是重写头文件不会否定 g-wan 的所有性能优势吗?
G-WAN 已经提供了一个简单的 publisher/subscriber
引擎,请参阅 Comet servlet 示例。
这适用于慢速(通常每秒更新 1 次)提要。
对于实时和大数据提要,除了使用 G-WAN protocol handlers
(绕过connection handler
重写并精确定义所需的 latency
).
这就是分发 150 million messages per second via 75,000 channels to 1.5 million subscribers 项目的情况。
我们还为 ORACLE OpenWorld expo in SFO 制作了一个(现在著名的)演示,该演示使用 G -WAN 作为 ORACLE noSQL 数据库的缓存(Java KV 存储)。
所以限制更多的是精确调整的问题,而不是 G-WAN 的核心引擎限制。
如何在G-Wan中有效实现订阅机制?假设,我想让 g-wan 聚合来自各种代码的数据并进一步处理它。而且,显然,每个提要都以其独特的格式提供数据。
最直接的方法是在连接处理程序的 init() 函数中创建连接并订阅数据,然后从响应中解析源信息并从main() 函数到专用队列。但是这种方法似乎并没有利用G-Wan有效的任务调度引擎。那么,有没有专门的软件可以更快的解决问题呢?
另一种方法是为每个订阅创建专用的 servlet。为此,在连接处理程序的 main() 函数中,我需要重写 headers 并包括相应的 servlet 的名称。在这种情况下,我会使用整个 g-wan 机器。但是重写头文件不会否定 g-wan 的所有性能优势吗?
G-WAN 已经提供了一个简单的 publisher/subscriber
引擎,请参阅 Comet servlet 示例。
这适用于慢速(通常每秒更新 1 次)提要。
对于实时和大数据提要,除了使用 G-WAN protocol handlers
(绕过connection handler
重写并精确定义所需的 latency
).
这就是分发 150 million messages per second via 75,000 channels to 1.5 million subscribers 项目的情况。
我们还为 ORACLE OpenWorld expo in SFO 制作了一个(现在著名的)演示,该演示使用 G -WAN 作为 ORACLE noSQL 数据库的缓存(Java KV 存储)。
所以限制更多的是精确调整的问题,而不是 G-WAN 的核心引擎限制。