一种分布式行情数据处理系统及方法
摘要:
本发明公开了一种分布式行情数据处理系统及方法,系统包括:实时数据采集模块用于采集和存储实时行情数据;历史数据存储模块用于对行情数据进行处理与存储;整合服务模块用于整合基础行情数据及处理行情数据;订阅模块用于接收用户关注的实时行情信息及查询信息;推送模块用于根据所述用户关注的实时行情信息和/或查询信息,向实时数据采集模块发送用户关注的实时行情信息,和/或向整合服务模块发送查询信息,并接收实时行情信息和/或查询结果,并返回给订阅模块。本发明对于实时性高的数据采用socket直连,保证数据第一时间传递到终端,高效、稳定、低延迟;对于需要处理的数据,放入队列,采用多通道分布式数据处理服务进行消费处理后放入缓存。
公开/授权文献
0/0