摘要 |
本发明涉及一种大规模实时交通数据的并行处理系统和大规模实时交通数据的并行处理方法。其中,大规模实时交通数据的并行处理系统包括通信服务器组,用于接收前端监测设备采集的实时交通数据,对接收到的实时交通数据进行校验与解析,分拣不同类型实时交通数据并向交通数据发布/订阅器进行转发;交通数据发布/订阅器,用于建立实时交通数据发布/订阅消息队列,接收并缓存由通信服务器组转发的实时交通数据,向订阅实时交通数据的不同的分发目的地进行实时交通数据的分发。本发明的大规模实时交通数据的并行处理系统和处理方法能,能够增强交通数据实时采集及海量交通数据处理的能力,同时满足交通业务发展下的扩展性需求。 |
