一种美股多交易所行情处理方法及系统

摘要

本发明提供了一种美股多交易所行情处理方法及系统，该方法包括以下步骤:S1、定时线程生成异步事件；S2、主线程执行异步事件，批量订阅证券代码行情；S3、行情回调处理线程执行行情消息处理逻辑，将行情消息放入对应的消息队列；S4、行情解码线程解析行情消息，获取实时行情和延时行情，延时行情放入缓存队列，并判断该实时行情是否为盘中行情，若是盘中行情，则将该实时行情放入缓存队列，若是盘前或盘后行情，则将该实时行情放入行情消息队列；S5、行情合并线程对缓存队列中的实时行情和延时行情进行合并，合并结果放入行情消息队列；S6、行情发送线程将行情消息队列中的消息转换成protobuf格式，并发送到kafka流式系统，供下游消费者使用。