基于分布式框架的大规模实时交通指数服务方法与系统

摘要

基于分布式框架的大规模实时交通指数服务方法与系统。系统分为资源层、指数计算层、用户服务层、应用调度层、信息交互与展示层；资源层提供了基础设施资源；指数计算层调用资源层中计算资源的多个计算节点，利用分布式框架处理交通指数数据源数据，经过计算后存储到非结构化数据库中；用户服务层调用资源层存储的用户数据，完成相应的用户服务内容；应用调度层接收信息交互与展示层发送的各类用户请求，调用指数计算层以及用户服务层，完成用户请求，将请求结果反馈给信息交互与展示层。方法包括交通指数实时计算、用户服务接口响应、应用服务请求与分发、信息展示服务四个步骤。本发明为广大出行用户提供更为准确、实用的交通信息服务。

主权项

一种基于分布式框架的大规模实时交通指数服务系统，所述系统分为资源层、指数计算层、用户服务层、应用调度层、信息交互与展示层，所述资源层提供了服务系统的基础设施资源，包括计算资源、结构化数据库、非结构化数据库以及交通指数数据源。其中，计算资源是实现分布式计算的计算节点、结构化数据库用于存储用户路径等结构化数据、非结构化数据库用于存储发布段交通指数等非结构化数据，交通指数数据源是由交通信息中心提供的实时交通流量数据；所述指数计算层调用资源层中计算资源的多个计算节点，利用分布式框架处理交通指数数据源数据，经过计算后存储到非结构化数据库中。该层包括指数更新模块、和守护线程模块，其中：所述指数更新模块，根据守护线程模块的调用完成资源层中存储于结构化数据库中的实时交通流量数据的更新，同时根据存储于结构化数据库中的道路发布段信息，通过多个计算节点组成的分布式集群完成各条道路及各发布段交通指数计算过程，将结果存储于非结构化数据库中。所述守护线程模块，根据资源层交通指数数据源提供的实时数据的更新周期，定时调用指数更新模块更新资源层中数据库中数据，同时监控指数更新模块的运行状态，处理异常信息；所述用户服务层调用资源层结构化数据库中存储的用户数据，完成相应的用户服务内容。该层它包括用户管理模块、路径管理模块、数据缓存模块,其中：所述用户管理模块，实现对系统用户的创建、修改、删除等管理工作。所述路径管理模块，实现对于路径信息相关数据的管理。所述数据缓存模块，处理用户路径交通指数信息的缓存数据，防止在一次交通指数数据源更新周期内用户多次请求的重复计算；所述应用调度层接收信息交互与展示层发送的各类用户请求，调用指数计算层以及用户服务层，完成用户请求，同时将请求结果反馈给信息交互与展示层。该层它包括指数数据获取模块、用户数据获取模块、服务请求接收与分发模块,其中：所述指数数据获取模块，主要包括：通用交通指数获取服务：根据具体查询获取单一路段或者发布段的交通指数信息；所述路径指数获取模块，根据维护的路径信息，获取计算后的路径交通指数信息；所述用户数据获取模块，根据查询和计算需求获取用户的结构化存储数据，包括用户的账户信息，用户路径信息等；所述服务请求接收与分发模块，接收来自信息交互与展示层的用户请求和系统请求，分发到分布式集群节点进行具体的服务处理过程；所述信息交互与展示层提供用户基于地图的交通信息指数的实时展示，进行交通指数信息管理。该层它包括地图服务模块、信息展示模块，其中：所述地图服务模块，又包括：地图展示模块：道路地图放大、缩小、拖动、显示等。GIS服务模块：提供地理信息的查询；所述信息展示模块，又包括：动态路况展示模块：基于交通指数的实时路况(重点路况、指定区域、指定路段)，路况显示采用指数信息结合颜色定量表示路段，红色表示拥塞，黄色表示拥挤，绿色表示畅通；交通指数查询模块：提供各个路段及发布段的交通指数实时查询，同时实时给出一定数量的最为拥堵的路段的交通指数信息；路径查询模块：提供指定路径的交通指数信息。