基于智能交通云控制系统的信息处理方法及装置

摘要

本发明涉及道路交通控制领域，特别涉及基于智能交通云控制系统的信息处理方法及装置。该方法为：第一节点向控制服务器发布订阅消息，当控制服务器确定满足订阅消息指示的预设条件时，将IP化现场设备采集信息以及相应处理结果返回给第一节点，第一节点针对返回的IP化现场设备采集信息以及相应处理结果生成相应的协同控制策略或本地控制策略。由于第一节点可以按需获取各个控制服务器的IP化现场设备采集信息以及相应处理结果，那么，这样就可以提高某一区域内交通状况的调节效果，同时也降低了智能交通云控制系统的整体信息传输量，从而，就不会导致信息传输拥堵，在保证了传输效率的同时，也降低了中心系统的信息存储量以及信息计算量。

说明书

技术领域

本发明涉及道路交通控制领域，特别涉及基于智能交通云控制系统的信息处理方法及装置。

背景技术

随着经济的不断发展，城市人口和机动车辆数量迅猛增长，这种增长造成了城市路口交通情况越发复杂，这就对交通控制系统的数据信息交互和处理能力提出了更高的要求。

参阅图1所示，交通控制系统包括一个中心系统和若干交通信号机。

交通信号机与中心系统之间通信时，交通信号机将采集的现场数据信息传输至中心系统，然后，中心系统对各个交通信号机采集的数据信息进行存储、计算和处理。由于各个交通信号机同时给中心系统传输实时信息，这样就会导致中心系统接收的数据信息量大，而且，此种数据信息处理方法数据传输时传输速率缓慢，中心系统数据信息存储量大、计算负担重，同时中心系统对各个交通信号机的控制实时性也较差。

目前，在上述处理方法的基础上开发了分布式交通控制系统，分布式交通控制系统包括一个中心系统和若干交通云节点，所谓分布式交通控制系统，即是在云计算模式下，大量的分布式交通云节点在云节点本地对数据信息进行计算和处理，多个交通云节点区域分组构成微云构架，单个交通云节点对数据信息进行存储、分析、处理和交互，以完成整个交通控制系统的数据信息处理，通过车流量等车辆信息进行信号灯的管理。

然而，采用此种数据信息处理方法，仍存在不足之处。

数据信息仅限制于在单个交通云节点上进行计算和处理，缺乏上层中心系统全局掌控，这样，区域内各交通云节点之间的协调控制效果就较差，且云节点与云节点，及云节点与中心系统之间数据信息交互没有选择性，这样，就会导致中心系统存储量大、计算负担重。

发明内容

本发明实施例提供基于智能交通云控制系统的信息处理方法，用以解决现有技术中存在的交通控制系统中各控制服务器之间的协调控制效果较差，以及中心系统数据信息存储量大、计算负担重的问题。

本发明实施例提供的具体技术方案如下：

基于智能交通云控制系统的信息处理方法，所述智能交通云控制系统至少包括若干控制服务器、若干IP化现场设备，或者，至少包括若干控制服务器、若干IP化现场设备和中心系统，其中，中心系统和控制服务器之间通过网络方式连接，IP化现场设备和控制服务器之间通过基于IP地址的宽带总线连接，其中，所述方法包括：

第一节点向控制服务器发布订阅消息，其中，所述订阅消息用于指示控制服务器在确定满足预设条件时，向所述第一节点返回控制服务器本地的IP化现场设备采集信息以及相应处理结果，所述第一节点为中心系统或者为任意一控制服务器；

第一节点接收控制服务器返回的IP化现场设备采集信息以及相应处理结果；

第一节点对获得的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果，生成相应的控制策略。

可选的，在第一节点向各个控制服务器发布订阅消息之前，进一步包括：

各个控制服务器收集各自本地的IP化现场设备采集信息以及相应处理结果并进行保存。

可选的，第一节点向控制服务器发布订阅消息，包括：

若第一节点为中心系统，则第一节点向全部控制服务器发布订阅消息；

若第一节点为控制服务器，则第一节点向指定的其他控制服务器发布订阅消息。

可选的，第一节点向一个控制服务器发布订阅消息，包括：

第一节点基于所述一个控制服务器的地理位置，向所述一个控制服务器发布相应的订阅消息；或者，

第一节点基于所述一个控制服务器的周边交通状况，向所述一个控制服务器发布相应的订阅消息；或者，

第一节点基于所述一个控制服务器的节点类型，向所述一个控制服务器发布相应的订阅消息。

可选的，第一节点接收一个控制服务器返回的IP化现场设备采集信息以及相应处理结果，包括：

第一节点接收所述一个控制服务器返回的IP化现场设备采集信息以及相应处理结果，其中，所述IP化现场设备采集信息以及相应处理结果是所述一个控制服务器确定满足预设条件后向所述第一节点发送的；

其中，所述预设条件包括以下条件中一种或任意组合：

所述一个控制服务器的周边发生拥堵；

所述一个控制服务器的周边发生交通事故；

所述一个控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值；

所述一个控制服务器或所述第一节点的周边发生紧急事件。

可选的，第一节点对获得的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果，生成相应的控制策略，包括：

若所述第一节点为中心系统，则所述第一节点对获得的各个控制服务器返回的IP化现场设备采集信息以及相应处理结果进行云计算分析，并基于分析结果，生成相应的协同控制策略；

若所述第一节点为控制服务器，则所述第一节点对获得的各个其他控制服务器返回的IP化现场设备采集信息以及相应处理结果进行边缘计算分析，并基于分析结果，生成相应的本地控制策略。

可选的，进一步包括：

若第一节点确定生成的控制策略执行失败，则通知中心系统，由中心系统针对所述控制策略重新收集相应的IP化现场设备采集信息以及相应处理结果，并生成相应的优化策略。

基于智能交通云控制系统的信息处理装置，所述智能交通云控制系统至少包括若干控制服务器、若干IP化现场设备，或者，至少包括若干控制服务器、若干IP化现场设备和中心系统，其中，中心系统和控制服务器之间通过网络方式连接，IP化现场设备和控制服务器之间通过基于IP地址的宽带总线连接，其中，所述装置包括：

发布单元，用于向控制服务器发布订阅消息，其中，所述订阅消息用于指示控制服务器在确定满足预设条件时，向所述第一节点返回控制服务器本地的IP化现场设备采集信息以及相应处理结果，所述第一节点为中心系统或者为任意一控制服务器；

接收单元，用于接收控制服务器返回的IP化现场设备采集信息以及相应处理结果；

生成单元，用于对获得的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果，生成相应的控制策略。

可选的，在向各个控制服务器发布订阅消息之前，所述装置进一步包括：

收集单元，用于收集各自本地的IP化现场设备采集信息以及相应处理结果并进行保存。

可选的，向控制服务器发布订阅消息时，所述发布单元用于：

若所述装置为中心系统，则向全部控制服务器发布订阅消息；

若所述装置为控制服务器，则向指定的其他控制服务器发布订阅消息。

可选的，向一个控制服务器发布订阅消息时，所述发布单元进一步用于：

基于所述一个控制服务器的地理位置，向所述一个控制服务器发布相应的订阅消息；或者，

基于所述一个控制服务器的周边交通状况，向所述一个控制服务器发布相应的订阅消息；或者，

基于所述一个控制服务器的节点类型，向所述一个控制服务器发布相应的订阅消息。

可选的，接收一个控制服务器返回的IP化现场设备采集信息以及相应处理结果时，所述接收单元用于：

接收所述一个控制服务器返回的IP化现场设备采集信息以及相应处理结果，其中，所述IP化现场设备采集信息以及相应处理结果是所述一个控制服务器确定满足预设条件后向所述第一节点发送的；

其中，所述预设条件包括以下条件中一种或任意组合：

所述一个控制服务器的周边发生拥堵；

所述一个控制服务器的周边发生交通事故；

所述一个控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值；

所述一个控制服务器或所述第一节点的周边发生紧急事件。

可选的，对获得的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果，生成相应的控制策略时，所述生成单元用于：

若所述装置为中心系统，则对获得的各个控制服务器返回的IP化现场设备采集信息以及相应处理结果进行云计算分析，并基于分析结果，生成相应的协同控制策略；

若所述装置为控制服务器，则对获得的各个其他控制服务器返回的IP化现场设备采集信息以及相应处理结果进行边缘计算分析，并基于分析结果，生成相应的本地控制策略。

可选的，所述生成单元进一步用于：

若确定生成的控制策略执行失败，则通知中心系统，由中心系统针对所述控制策略重新收集相应的IP化现场设备采集信息以及相应处理结果，并生成相应的优化策略。

综上所述，本发明实施例中，在智能交通云控制系统进行数据信息处理的过程中，第一节点向控制服务器分别发布订阅消息，控制服务器接收到第一节点发布的订阅消息，当控制服务器确定满足上述订阅消息指示的预设条件时，将上述订阅消息指示的IP化现场设备采集信息以及相应处理结果返回给第一节点，第一节点针对返回的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果生成相应的协同控制策略或本地控制策略。若第一节点为中心系统，则中心系统将生成的协同控制策略下发给相应的控制服务器，若第一节点为第一控制服务器，则第一控制服务器执行生成的本地控制策略。

此信息处理方法，各个控制服务器各自采集并存储IP化现场设备采集信息以及相应处理结果，这样，就实现了信息的分布式存储，只有当控制服务器确定满足订阅消息指示的预设条件时，才需将订阅消息指示的IP化现场设备采集信息以及相应处理结果返回第一节点，这样，就降低了智能交通云控制系统的整体信息传输量，从而，保证了系统的传输效率。在此信息处理方法中，当第一节点为中心节点时，中心系统可以针对指定的多个控制服务器生成相应的协同控制策略，这样就可以提高某一区域内交通路况的调节效果，同时也降低了中心系统的信息存储量以及信息计算量；当第一节点为第一控制服务器时，第一控制服务器可以获取任一个指定的其他控制服务器的IP化现场设备采集信息以及相应处理结果，这样第一控制服务器可以实现自管理，从而降低了中心系统的信息运算量，同时也实现了各个控制服务器之间的信息共享；此信息处理方法，通过结合消息订阅发布机制、数据分布式存储共享、云计算、边缘计算等技术，现场控制服务器存储本地数据、中心系统需求订阅数据，为实现交通系统数据的合理存储，快速共享，实时处理提供了解决方案。

附图说明

图1为传统交通控制系统结构图；

图2为智能交通云控制系统结构图；

图3为控制服务器通过基于IP地址的宽带总线与IP化现场设备进行连接示意图；

图4为本发明实施例中，第一节点为中心系统时，智能交通云控制系统的信息处理详细流程图；

图5为本发明实施例中，第一节点为控制服务器时，智能交通云控制系统的信息处理详细流程图；

图6为本发明实施例中，信息处理装置的结构示意图。

具体实施方式

下面将结合附图对本发明优选的实施方式作出进一步详细说明。

在实际应用中，基于智能交通云控制系统可以至少包括若干控制服务器、若干IP化现场设备；也可以至少包括若干控制服务器、若干IP化现场设备和中心系统。

参阅图2所示，智能交通云控制系统包括至少一个中心系统以及若干控制服务器，如，智能交通云控制系统的总服务器相当于中心系统，每个路口的服务器相当于一个控制服务器，中心系统与控制服务器以及各个控制服务器之间通过网络连接。

本实施例仅是本发明一种优选的实施方式，其中，本实施例中的中心系统仅是若干种中心系统类型中的一种，本实施例中的控制服务器也仅是若干种控制服务器类型中的一种。

当然，本发明可以采用以下实施例，但并不仅限于采用以下实施例来实现。

参阅图3所示，控制服务器通过基于IP地址的宽带总线与IP化现场设备实现连接。

所谓IP化现场设备，指的是分布在各个交通路口的，用于采集交通路口数据、对路口交通状态进行实时监测、控制等等功能的设备(如、交通信号灯、检测设备以及视频与违法监测设备等等)。

具体的，IP化现场设备又可以分为第一类IP化现场设备和第二IP类化现场设备，其中，第一类IP化现场设备指的是可以直接与基于IP地址的宽带总线连接的IP化现场设备(如，视频检测与违法监测设备等等)，而第二类IP化现场设备指的是需要通过相应的驱动设备才能与基于IP地址的宽带总线进行连接的IP化现场设备(如，交通信号灯、检测设备等等)。

本发明实施例中，所谓分布式存储，指的是智能交通云控制系统的各个控制服务器收集各自本地的IP化现场设备采集信息以及相应处理结果并进行保存，其中，上述相应处理结果指的是各个控制服务器针对收集的IP化现场设备采集信息进行处理后得到的已处理数据。

换言之，本发明实施例中，智能交通云控制系统中的各个控制服务器通过各个IP化现场设备收集的IP化现场设备采集信息以及相应处理结果，可以在各个控制服务器上进行分布式存储。

例如：智能交通云控制系统中的控制服务器A收集通过现场的视频与违法监测设备(如，视频摄像头等)采集的IP化现场设备采集信息(如，视频监测信息等)，并将此IP化现场设备采集信息以及相应处理结果在控制服务器A上进行存储；智能交通云控制系统中的控制服务器B收集通过现场的视频与违法监测设备(如，视频摄像头等)采集的IP化现场设备采集信息(如，视频监测信息等)，并将此IP化现场设备采集信息以及相应处理结果在控制服务器B上进行存储等等。

本发明实施例中，第一节点向控制服务器发布订阅消息，其中，该订阅消息用于指示控制服务器在确定满足预设条件时，向第一节点返回控制服务器本地的IP化现场设备采集信息以及相应处理结果。

然而，第一节点可以为中心系统或者为任意一控制服务器。

下面将结合附图对本发明实施例中，基于智能交通云控制系统至少包括若干智能云节点、和若干IP化现场设备和中心系统，且第一节点为中心系统时的情况进行详细介绍。

实际应用中，中心系统用于与多个控制服务器通过网络实现数据交互，共享与其连接的控制服务器存储的数据，并通过对共享的数据进行分析、处理，得到分析结果；根据分析结果，生成协同控制策略，并将协同控制策略发送给相应的控制服务器。控制服务器还用于通过云计算从中心系统获得协同控制策略，并根据协同控制策略执行相应的操作。

参阅图4所示，本发明实施例中，第一节点为中心系统时，智能交通云控制系统的信息处理详细流程图。

步骤401：中心系统与各个控制服务器之间建立网络连接。

步骤402：中心系统向各个控制服务器发布订阅消息。

若第一节点为中心系统时，中心系统向各个控制服务器发布订阅消息，此类订阅消息指示控制服务器返回的IP化现场设备采集信息以及相应处理结果是比较粗略、全局化的，具体可以包括“车流量”、“人流量”、“拥堵路段名称”等等，中心系统可以基于获取的各个控制服务器返回的IP化现场设备采集信息以及相应处理结果进行云计算分析，并基于分析结果针对各个控制服务器生成相应的协同控制策略。

中心系统会基于各个控制服务器的不同条件(如，地理位置、周边交通状况以及控制服务器的节点类型等等)，分别向各个控制服务器发布相应的订阅消息，其中，该订阅消息用于指示控制服务器在确定满足预设条件时，向中心系统返回IP化现场设备采集信息以及相应处理结果。

具体的，所谓控制服务器的不同条件，包含但不限于以下三种情况：

第一种情况为：中心系统会基于各个控制服务器的地理位置的不同，而分别向各个控制服务器发布相应的订阅消息。

例如：控制服务器A所在的位置为市区中心，通过路口的机动车、非机动车以及行人较多，那么，中心系统向控制服务器A发布的订阅消息就包含相应的信息内容，该订阅消息包含的信息内容包括：控制服务器A定时向中心系统返回IP化现场设备采集信息以及相应处理结果的时间间隔更短(如，控制服务器A每隔5分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回给中心系统的IP化现场设备采集信息以及相应处理结果内容更多(如，30分钟内通过路口的车流量、上一次绿灯时车辆通过路口的车辆数以及平均车速、红灯时车辆的拥堵距离以及视频监控信息等等)等等；控制服务器B所在的位置为城市郊区，经过路口的机动车、非机动车以及行人较少，那么，中心系统向控制服务器B发布的订阅消息就会包含有相应的信息内容，该订阅消息包含的信息内容包括：控制服务器B定时向中心系统返回的IP化现场设备采集信息以及相应处理结果的时间间隔更长(如，控制服务器B每隔30分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回的IP化现场设备采集信息以及相应处理结果内容更少(如、只需上传30分钟内通过路口的车流量)等等。

第二种情况为：中心系统会基于各个控制服务器的周边交通状况的不同，而分别向各个控制服务器发布相应的订阅消息。

例如：控制服务器A所在的路口的周边交通状况良好时(如，非上下班时间段，通过路口的机动车、非机动车以及行人数量不多时)，中心系统向控制服务器A发布的订阅消息包含有相应的消息，该订阅消息包含的信息内容包括：内容控制服务器A定时向中心系统返回IP化现场设备采集信息以及相应处理结果的时间间隔更长(如，控制服务器A每隔30分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回的IP化现场设备采集信息以及相应处理结果内容更少(如、只需上传30分钟内通过路口的车流量)等等；控制服务器A所在的路口的周边交通状况较差时(如，上下班时间段，通过路口的机动车、非机动车以及行人数量较多时)，中心系统向控制服务器A发布的订阅消息就会包含有相应的消息内容，该订阅消息包含的信息内容包括：控制服务器B定时向中心系统返回IP化现场设备采集信息以及相应处理结果的时间间隔更长(如，控制服务器B每隔30分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回的IP化现场设备采集信息以及相应处理结果内容更少(如、只需上传30分钟内通过路口的车流量)等等。

第三种情况为：中心系统会基于各个控制服务器的节点类型的不同，分别向各个控制服务器发布相应的订阅消息。

例如：控制服务器A连接的IP化现场设备为测速设备，那么，中心系统向控制服务器A发布相应的订阅消息(如，该订阅消息用于指示控制服务器A将某一时间段T1内，监测到的所有车辆在通过监测设备时的实时速度信息返回给中心系统)，其中，T1的取值可以根据实际情况任意取值；控制服务器B为车流量统计设备，那么，中心系统向控制服务器B发布相应的订阅消息(如，该订阅消息用于指示控制服务器B将某一时间段T2内，通过该车流量统计设备的所有车辆的数量信息返回给中心系统)其中，T2的取值可以根据实际情况任意取值。

步骤403：控制服务器接收到中心系统发布的订阅消息。

控制服务器接收中心系统基于控制服务器不同条件(如，地理位置、周边交通状况以及控制服务器的节点类型等等)发布的订阅消息。

具体的，所谓控制服务器不同条件，包含但不限于以下三种情况：

第一种情况：控制服务器接收到中心系统基于控制服务器的地理位置，而发布的订阅消息；

例如：控制服务器A所在的位置为市区中心，通过路口的机动车、非机动车以及行人较多，那么，控制服务器A接收到中心系统向控制服务器A发布的订阅消息，该订阅消息包含的信息内容包括：控制服务器A定时向中心系统返回IP化现场设备采集信息以及相应处理结果的时间间隔更短(如，控制服务器A每隔5分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回给中心系统的IP化现场设备采集信息以及相应处理结果内容更多(如，30分钟内通过路口的车流量、上一次绿灯时车辆通过路口的车辆数以及平均车速、上一次红灯时车辆的拥堵距离以及视频监控信息等等)等等；控制服务器B所在的位置为城市郊区，经过路口的机动车、非机动车以及行人较少，那么，控制服务器B接收中心系统向控制服务器B发布的订阅消息，该订阅消息包含的信息内容包括：控制服务器B定时向中心系统返回IP化现场设备采集信息以及相应处理结果的时间间隔更长(如，控制服务器B每隔30分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回的IP化现场设备采集信息以及相应处理结果内容更少(如、只需上传30分钟内通过路口的车流量)等等。

第二种情况：控制服务器接收到中心系统基于控制服务器的周边交通状态，而发布的订阅消息；

例如：控制服务器A所在的路口的周边交通状况良好时(如，非上下班时间段，通过路口的机动车、非机动车以及行人数量不多时)，控制服务器A接收中心信息向控制服务器A发布的订阅消息，该订阅消息包含的信息内容包括：控制服务器A定时向中心系统返回IP化现场设备采集信息以及相应处理结果的时间间隔更长(如，控制服务器A每隔30分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回的IP化现场设备采集信息以及相应处理结果内容更少(如、只需上传30分钟内通过路口的车流量)等等；控制服务器A所在的路口的周边交通状况较差时(如，上下班时间段，通过路口的机动车、非机动车以及行人数量较多时)，控制服务器A接收中心系统向控制服务器A发布的订阅消息，该订阅消息包含的信息内容包括：控制服务器B定时向中心系统返回IP化现场设备采集信息以及相应处理结果的时间间隔更长(如，控制服务器B每隔30分钟向中心系统返回一次IP化现场设备采集信息以及相应处理结果)、控制服务器所需返回的IP化现场设备采集信息以及相应处理结果内容更少(如、只需上传30分钟内通过路口的车流量)等等。

第三种情况：控制服务器接收到中心系统基于控制服务器的节点类型，而发布的订阅消息。

例如：控制服务器A连接的IP化现场设备为测速设备，那么，控制服务器A接收中心系统向控制服务器A发布的订阅消息(如，该订阅消息用于指示控制服务器A将某一时间段T1内，监测到的所有车辆在通过监测设备时的实时速度信息上传给中心系统)，其中，T1的取值可以根据实际情况任意取值；控制服务器B为车流量统计设备，那么，控制服务器B接收中心系统向控制服务器B发布的订阅消息(如，该订阅消息用于指示控制服务器B将某一时间段T2内，通过该车流量统计设备的所有车辆的数量信息上传给中心系统)其中，T2的取值可以根据实际情况任意取值。

步骤404：控制服务器确定满足订阅消息指示的预设条件时，将IP化现场设备采集信息以及相应处理结果返回中心系统。

控制服务器收集IP化现场设备采集信息，并将收集的IP化现场设备采集信息在控制服务器进行分析处理，得到处理结果，并将IP化现场设备采集信息以及相应处理结果在本地进行分布式存储。

控制服务器确定订阅消息指示的预设条件满足时(如，控制服务器确定控制服务器周边发生拥堵、发生交通事故或者控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值、控制服务器周边发生紧急事件时)，控制服务器将IP化现场设备采集信息以及相应处理结果返回中心系统，其中，此IP化现场设备采集信息以及相应处理结果的信息内容是订阅消息指示的。

具体的，包括但不限于以下四种情况以及四种情况的任意组合：

第一种情况：当控制服务器的周边发生拥堵时，将IP化现场设备采集信息以及相应处理结果返回中心系统；

例如：控制服务器A收集通过视频监测设备(如，视频摄像头等)采集的IP化现场设备采集信息(如，车速、车流量等等)，控制服务器A针对收集的IP化现场设备采集信息进行分析处理，得到相应处理结果，控制服务器A根据获取的IP化现场设备采集信息以及相应处理结果，确定控制服务器A的周边发生拥堵，那么，控制服务器A将IP化现场设备采集信息以及相应处理结果返回中心系统，其中，返回的IP化现场设备采集信息以及相应处理结果的信息内容是订阅消息指示的。

第二种情况：当控制服务器的周边发生交通事故时，将IP化现场设备采集信息以及相应处理结果返回中心系统；

例如：控制服务器A收集通过视频监测设备(如，视频摄像头等)采集的IP化现场设备采集信息，针对获取的收集的IP化现场设备采集信息进行分析处理，得到相应处理结果(如，车流量信息、上一次红灯时车辆拥堵距离、上一次绿灯时通过路口车辆的平均速度等等)，控制服务器A根据获取的IP化现场设备采集信息以及相应处理结果得到上次一绿灯时，通过路口的车辆数N较少(如，N＜5辆)，且上一次绿灯时通过路口车辆的平均速度V较慢(如，V＜5km/h)，而上一次红灯时车辆拥堵距离S却较长(如，S＞80米)，那么，控制服务器A就确定周边发生交通事故，从而，将IP化现场设备采集信息以及相应处理结果返回给中心系统，其中，N、S以及V的取值可以根据实际情况任意取值。

第三种情况：当控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值时，将IP化现场设备采集信息以及相应处理结果返回中心系统。

例如：控制服务器A收集通过IP化现场设备(如，视频摄像头等)采集的IP化现场设备采集信息(如，视频监控信息、违法闯红灯车辆的照片、每一次绿灯时通过路口的车辆数等等)，并对收集的IP化现场设备采集信息进行分析处理，得到相应处理结果(如，车流量信息、每一次红灯时车辆的拥堵距离等等)，控制服务器A将收集的IP化现场设备采集信息以及相应处理结果在控制服务器A上进行存储，当控制服务器A检测到IP化现场设备采集信息以及相应处理结果存储量大于设定阈值M时，控制服务器A将存储在本地的IP化现场设备采集信息以及相应处理结果返回中心系统，其中，M的取值可以根据需要任意取值。

第四种情况：当控制服务器的周边发生紧急事件时，将IP化现场设备采集信息以及相应处理结果返回中心系统。

具体的，当控制服务器周边发生紧急事件时，如，中心系统接收到管理员通知，确定管辖区域内有紧急事件发生，如“缉查布控”或者“有救护车通行”等等紧急事件时，各个控制服务器需要将IP化现场设备采集信息以及相应处理结果返回中心系统。

例如：假设中心系统接收到管理员通知，管辖区域内有救护车经过，且，上述救护车路过的路段有拥堵状况，则中心系统获取各个控制服务器的IP化现场设备采集信息以及相应处理结果，并进行交通调整，以确保救护车及时到达目的地点。

又例如：中心系统接收到管理员下发的“缉查布控”命令时，其中，上述“缉查布控”又可以包括“搜捕案件嫌疑车辆”或者“查找套牌车辆”等等。

具体的，假设中心系统接收到管理员下发的“缉查布控”命令中的“搜捕案件嫌疑车辆”时，中心系统向管辖区域内的各个控制服务器发布订阅消息，上述订阅消息可以包括“车辆的车牌号码的照片”“车辆所在道路的名称”、“车辆经过的具体时间”、“车辆驾驶员的人脸图像”等等，各个控制服务器会基于获得的订阅消息向中心系统返回相应的IP化现场设备采集信息以及相应处理结果，以确保“搜捕案件嫌疑车辆”紧急事件及时解决。

假设中心系统接收到管理员下发的“缉查布控”命令中的“查找套牌车辆”时，中心系统向管辖区域内的各个控制服务器发布订阅消息，上述订阅消息可以包括“车辆的车牌号码的照片”，“车辆所在道路的名称”、“车辆经过的具体时间”等等，当中心系统根据各个控制服务器返回的IP化现场设备采集信息以及相应处理结果，确定至少两个以上的路段在同一时间内出现了同一车牌号的车辆，则确定查找到套牌车辆，以确保“查找套牌车辆”紧急事件及时解决。

步骤405：中心系统接收到控制服务器返回的IP化现场设备采集信息以及相应处理结果。

中心系统接收控制服务器返回的IP化现场设备采集信息以及相应处理结果，其中，该IP化现场设备采集信息以及相应处理结果是控制服务器确定满足预设条件(如，控制服务器的周边发生拥堵、控制服务器的周边发生交通事故、控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值、控制服务器的周边发生紧急事件等等)后向中心系统返回的。

其中，该预设条件包含但不限于以下四种情况以及四种情况的任意组合：

第一种情况：控制服务器确定控制服务器周边发生拥堵时，向中心系统发送IP化现场设备采集信息以及相应处理结果；

具体的，控制服务器基于收集的IP化现场设备采集信息以及对IP化现场设备采集信息进行分析处理后得到相应处理结果，确定控制服务器周边发生拥堵，那么，控制服务器向中心系统返回IP化现场设备采集信息以及相应处理结果。

第二种情况：控制服务器确定控制服务器周边发生交通事故时，向中心系统返回IP化现场设备采集信息以及相应处理结果；

具体的，控制服务器基于IP化现场设备采集信息，以及对IP化现场设备采集信息进行分析处理后得到相应处理结果，确定控制服务器周边发生交通事故，那么，控制服务器向中心系统返回IP化现场设备采集信息以及相应处理结果。

第三种情况：控制服务器确定IP化现场设备采集信息以及相应处理结果存储量大于设定阈值时，向中心系统发送IP化现场设备采集信息以及相应处理结果。

具体的，当控制服务器检测到本地存储的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值M1时，控制服务器将存储在本地的IP化现场设备采集信息以及相应处理结果返回中心系统，其中，M1的取值可以根据需要任意取值。

第四种情况：控制服务器确定周边发生紧急事件时，向中心系统发送IP化现场设备采集信息以及相应处理结果。具体参阅步骤404所述，在此不再赘述。

步骤406：中心系统对获取的指定的多个控制服务器返回的IP化现场设备采集信息以及相应处理结果进行云计算分析，并基于分析结果，生成相应的协同控制策略。

所谓云计算分析，指的是中心系统可以根据需要任意获取指定的多个控制服务器(可以是指定的部分控制服务器，也可以是全部控制服务器)通过IP化现场设备采集的IP化现场设备采集信息以及相应处理结果，并针对获取的各个IP化现场设备采集信息以及相应处理结果进行综合分析，得到分析结果，并基于分析结果针对指定的多个控制服务器生成协同控制策略。

具体的，中心系统对获取的指定的多个控制服务器基于订阅消息指示返回的IP化现场设备采集信息以及相应处理结果进行云计算分析，得到分析结果，并基于分析结果，针对指定的多个控制服务器生成相应的协同控制策略。

例如：中心系统获取控制服务器A的IP化现场设备采集信息以及相应处理结果(如，视频监控信息、车流量信息等)，中心系统获取控制服务器B的IP化现场设备采集信息以及相应处理结果(如，车速信息、人流量信息等、)，等等，中心系统对获取的控制服务器A和控制服务器B的IP化现场设备采集信息以及相应处理结果进行云计算分析，并基于分析结果，针对控制服务器A和控制服务器B生成相应的协同控制策略。

步骤407：中心系统将生成的协同控制策略下发给相应的控制服务器。

中心系统将基于指定的多个控制服务器返回的IP化现场设备采集信息以及相应处理结果生成的协同控制策略分别下发给指定的多个控制服务器。

步骤408：控制服务器接收并执行中心系统下发的协同控制策略。

控制服务器接收并执行中心系统下发的协同控制策略，其中，该协同控制策略是中心系统基于指定的多个控制服务器返回的IP化现场设备采集信息以及相应处理结果生成的。

若中心系统针对指定的多个控制服务器生成的协调控制策略执行失败，则通知中心系统，中心系统再次获取上述指定的多个控制服务器返回的IP化现场设备采集信息以及相应处理结果，并对再次获取的所有IP化现场设备采集信息以及相应处理结果进行云计算分析，以及基于分析结果，对指定的多个控制服务器生成相应的优化协同控制策略。

下面将结合附图对本发明实施例中，基于智能交通云控制系统至少包括若干控制服务器和若干IP化现场设备，第一节点为第一控制服务器时的情况进行详细介绍。

实际应用中，控制服务器用于集中处理IP化现场设备采集的数据，并通过边缘计算实现对本地区域交通的控制，和/或，

控制服务器用于确定满足预设触发条件时，在该控制服务器所属的预先组建的自定义区域中，若该控制服务器为主控制服务器，则主控制服务器通过自我学习和边缘计算生成协同控制策略实现对自定义区域的协同控制；若该控制服务器为从控制服务器，则从控制服务器通过云计算从主控制服务器获得协同控制策略。

参阅图5所示，本发明实施例中，第一节点为第一控制服务器时，智能交通云控制系统的信息处理详细流程图。

步骤501：第一控制服务器与其他各个控制服务器之间建立网络连接。

步骤502：第一控制服务器向指定的其他控制服务器发布订阅消息。

若第一节点为控制服务器时，控制服务器向指定的其他控制服务器(以下简称为其他控制服务器)发布订阅消息，此类订阅消息指示其他控制服务器返回的IP化现场设备采集信息以及相应处理结果是比较细致、有针对性的，具体可以包括“车流量”、“人流量”，还可以包括“拥堵路段名称”，“故障摄像头数目”、“故障交通灯数目”、“拥堵路段交通灯数量及切换时长”等等具体信息，第一控制服务器可以针对获取的其他控制服务器返回的IP化现场设备采集信息以及相应处理结果进行计算分析，并基于分析结果生成本地控制策略。

其中，上述指定的其他控制服务器可以是智能交通云控制系统中任一个控制服务器，且第一控制服务器也可以是智能交通云控制系统中任一个控制服务器，那么，显而易见，智能交通云控制系统内的控制服务器之间可以实现信息共享。

第一控制服务器会基于其他控制服务器的不同条件(如，地理位置、周边交通状况以及控制服务器的节点类型等等)，分别向其他控制服务器发布相应的订阅消息，其中，该订阅消息用于指示控制服务器在确定满足预设条件时，向第一控制服务器返回IP化现场设备采集信息以及相应处理结果。

具体的，包含但不限于以下三种情况：

第一种情况为：第一控制服务器会基于各个其他控制服务器的地理位置的不同，而分别向各个其他控制服务器发布相应的订阅消息。

具体的，第一控制服务器会根据各个其他控制服务器的地理位置(如，市区中心位置、城市郊区等等)的不同，而向上述各个其他控制服务器分别发布相应的订阅消息，该订阅消息的消息内容可以基于其他控制服务器的地理位置不同而不同。

第二种情况为：第一控制服务器会基于各个其他控制服务器的周边交通状况的不同，而分别向各个其他控制服务器发布相应的订阅消息。

具体的，第一控制服务器会根据各个其他控制服务器的周边交通状态(交通状况良好时、交通状况较差时等等)的不同，而向上述各个指定的控制服务器分别发布相应的订阅消息。该订阅消息的消息内容可以基于其他控制服务器的周边交通状况的不同而不同。

第三种情况为：第一控制服务器会基于各个其他控制服务器的节点类型的不同，分别向各个其他控制服务器发布相应的订阅消息。

具体的，第一控制服务器会根据各个其他控制服务器的节点类型的不同，而向上述各个指定的控制服务器分别发布相应的订阅消息。该订阅消息的消息内容可以基于其他控制服务器的节点类型的不同而不同。

步骤503：其他控制服务器接收到第一控制服务器发布的订阅消息。

其他控制服务器接收第一控制服务器基于其他控制服务器不同条件(如，地理位置、周边交通状况以及控制服务器的节点类型等等)发布的订阅消息。具体参阅步骤502所述，在此不再赘述。

步骤504：其他控制服务器确定满足订阅消息指示的预设条件时，将IP化现场设备采集信息以及相应处理结果返回第一控制服务器。

其他控制服务器确定订阅消息指示的预设条件满足时(如，控制服务器确定控制服务器周边发生拥堵、发生交通事故或者控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值、控制服务器周边发生紧急事件时)，其他控制服务器会将本地收集的IP化现场设备采集信息以及相应处理结果返回第一控制服务器，其中，此IP化现场设备采集信息以及相应处理结果的信息内容是订阅消息指示的。

具体的，包括但不限于以下四种情况以及四种情况的任意组合：

第一种情况：当其他控制服务器的周边发生拥堵时，将IP化现场设备采集信息以及相应处理结果返回第一控制服务器；

例如，其他控制服务器收集通过视频监测设备采集的IP化现场设备采集信息，该其他控制服务器针对收集的IP化现场设备采集信息进行分析处理，得到相应处理结果，并基于获取的IP化现场设备采集信息以及相应处理结果，确定该其他控制服务器的周边发生拥堵，那么，该其他控制服务器就将IP化现场设备采集信息以及相应处理结果返回第一控制服务器。

第二种情况：当其他控制服务器的周边发生交通事故时，将IP化现场设备采集信息以及相应处理结果返回第一控制服务器；

例如，其他控制服务器收集通过视频监测设备采集的IP化现场设备采集信息，并对该其他控制服务器针对收集的IP化现场设备采集信息进行分析处理，得到相应处理结果，并基于获取的IP化现场设备采集信息以及相应处理结果，确定该其他控制服务器的周边发生交通事故，那么，该其他控制服务器就将IP化现场设备采集信息以及相应处理结果返回第一控制服务器。

第三种情况：当其他控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值时，将IP化现场设备采集信息以及相应处理结果返回第一控制服务器；

例如，其他控制服务器收集通过IP化现场设备采集的IP化现场设备采集信息以及相应处理结果，并将收集的IP化现场设备采集信息以及相应处理结果在本地进行存储，当该其他控制服务器检测到IP化现场设备采集信息以及相应处理结果存储量大于设定阈值M2时，该其他控制服务器将存储在本地的IP化现场设备采集信息以及相应处理结果返回第一控制服务器，其中，M2的取值可以根据需要任意取值。

第四种情况：当第一控制服务器的周边发生紧急事件时，将IP化现场设备采集信息以及相应处理结果返回第一控制服务器。

具体的，当第一控制服务器周边发生紧急事件时，如，第一控制服务器接收到管理员通知，确定管辖区域内有紧急事件发生，如“缉查布控”或者“有救护车通行”等等紧急事件时，其他控制服务器需要将IP化现场设备采集信息以及相应处理结果返回第一控制服务器。

例如：假设第一控制服务器接收到管理员通知，管辖区域内有救护车经过，且，上述救护车路过的路段有拥堵状况，则第一控制服务器获取其他控制服务器的IP化现场设备采集信息以及相应处理结果，并进行交通调整，以确保救护车及时到达目的地点。

又例如：第一控制服务器接收到管理员下发的“缉查布控”命令时，其中，“缉查布控”又可以包括“搜捕案件嫌疑车辆”或者“查找套牌车辆”等等。

具体的，假设第一控制服务器接收到管理员下发的“缉查布控”命令中的“搜捕案件嫌疑车辆”时，第一控制服务器向管辖区域内的所有其他控制服务器发布订阅消息，上述订阅消息可以包括“车辆的车牌号码的照片”“车辆所在道路的名称”、“车辆经过的具体时间”、“车辆驾驶员的人脸图像”等等，其他控制服务器会基于获得的订阅消息向第一控制服务器返回相应的IP化现场设备采集信息以及相应处理结果，以确保“搜捕案件嫌疑车辆”紧急事件及时解决。

假设第一控制服务器接收到管理员下发的“缉查布控”命令中的“查找套牌车辆”时，第一控制服务器向所属区域内的所有其他控制服务器发布订阅消息，上述订阅消息可以包括“车辆的车牌号码的照片”，“车辆所在道路的名称”、“车辆经过的具体时间”等等，当第一控制服务器根据其他控制服务器返回的IP化现场设备采集信息以及相应处理结果，确定至少两个以上的路段在同一时间内出现了同一车牌号的车辆，则会确定查找到套牌车辆，以确保“查找套牌车辆”紧急事件及时解决。

步骤505：第一控制服务器接收到其他控制服务器返回的IP化现场设备采集信息以及相应处理结果。

第一控制服务器接收其他控制服务器返回的IP化现场设备采集信息以及相应处理结果，其中，该IP化现场设备采集信息以及相应处理结果是其他控制服务器确定满足预设条件(如，控制服务器的周边发生拥堵、控制服务器的周边发生交通事故、控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值、控制服务器的周边发生紧急事件等等)后向第一控制服务器返回的。具体参阅步骤504所述，在此不再赘述。

步骤506：第一控制服务器对获得的其他控制服务器返回的IP化现场设备采集信息以及相应处理结果进行边缘计算分析，并基于分析结果，生成相应的本地控制策略。

所谓边缘计算分析，指的是第一控制服务器可以根据自身的使用需求，获取其他控制服务器通过各自的IP化现场设备收集的IP化现场设备采集信息以及相应处理结果，并针对获取的其他控制服务器返回的IP化现场设备采集信息以及相应处理结果进行计算分析，得到分析结果，并基于分析结果生成相应的本地控制策略。

步骤507：第一控制服务器执行生成的本地控制策略。

第一控制服务器执行基于其他控制服务器返回的IP化现场设备采集信息以及相应处理结果生成的本地控制策略。

若第一控制服务器执行上述本地控制策略失败，则通知中心系统，由中心系统获取上述其他控制服务器最新的IP化现场设备采集信息以及相应处理结果，对获取的所有IP化现场设备采集信息以及相应处理结果进行分析，基于分析结果，针对第一控制服务器生成相应的优化策略，并将优化策略下发给第一控制服务器，即在第一控制服务器自管理失败时，由中心系统进行代管。

参阅图6所示，基于智能交通云控制系统的信息处理装置，所述智能交通云控制系统至少包括若干控制服务器、若干IP化现场设备，或者，至少包括若干控制服务器、若干IP化现场设备、和中心系统，中心系统和控制服务器之间通过网络方式连接，IP化现场设备和控制服务器之间通过基于IP地址的宽带总线连接，其中，所述装置至少包括收集单元60、发布单元61、接收单元62和生成单元63，其中，

发布单元61，用于向控制服务器发布订阅消息，其中，所述订阅消息用于指示控制服务器在确定满足预设条件时，向所述第一节点返回控制服务器本地的IP化现场设备采集信息以及相应处理结果，所述第一节点为中心系统或者为任意一控制服务器；

接收单元62，用于接收控制服务器返回的IP化现场设备采集信息以及相应处理结果；

生成单元63，用于对获得的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果，生成相应的控制策略。

可选的，在向各个控制服务器发布订阅消息之前，所述装置进一步包括：

收集单元60，用于收集各自本地的IP化现场设备采集信息以及相应处理结果并进行保存。

可选的，向控制服务器发布订阅消息时，发布单元61用于：

若所述装置为中心系统，则向全部控制服务器发布订阅消息；

若所述装置为控制服务器，则向指定的其他控制服务器发布订阅消息。

可选的，向一个控制服务器发布订阅消息时，发布单元61进一步用于：

基于所述一个控制服务器的地理位置，向所述一个控制服务器发布相应的订阅消息；或者，

基于所述一个控制服务器的周边交通状况，向所述一个控制服务器发布相应的订阅消息；或者，

基于所述一个控制服务器的节点类型，向所述一个控制服务器发布相应的订阅消息。

可选的，接收一个控制服务器返回的IP化现场设备采集信息以及相应处理结果时，接收单元62用于：

接收所述一个控制服务器返回的IP化现场设备采集信息以及相应处理结果，其中，所述IP化现场设备采集信息以及相应处理结果是所述一个控制服务器确定满足预设条件后向所述第一节点发送的；

其中，所述预设条件包括以下条件中一种或任意组合：

所述一个控制服务器的周边发生拥堵；

所述一个控制服务器的周边发生交通事故；

所述一个控制服务器的IP化现场设备采集信息以及相应处理结果存储量大于设定阈值；

所述一个控制服务器或所述第一节点的周边发生紧急事件。

可选的对获得的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果，生成相应的控制策略时，生成单元63用于：

若所述装置为中心系统，则对获得的各个控制服务器返回的IP化现场设备采集信息以及相应处理结果进行云计算分析，并基于分析结果，生成相应的协同控制策略；

若所述装置为控制服务器，则对获得的各个其他控制服务器返回的IP化现场设备采集信息以及相应处理结果进行边缘计算分析，并基于分析结果，生成相应的本地控制策略。

可选的，所述生成单元63进一步用于：

若确定生成的控制策略执行失败，则通知中心系统，由中心系统针对所述控制策略重新收集相应的IP化现场设备采集信息以及相应处理结果，并生成相应的优化策略。

综上所述，本发明实施例中，在智能交通云控制系统进行数据信息处理的过程中，第一节点向控制服务器分别发布订阅消息，控制服务器接收到第一节点发布的订阅消息，当控制服务器确定满足上述订阅消息指示的预设条件时，将上述订阅消息指示的IP化现场设备采集信息以及相应处理结果返回给第一节点，第一节点针对返回的IP化现场设备采集信息以及相应处理结果进行分析，并基于分析结果生成相应的协同控制策略或本地控制策略。若第一节点为中心系统，则中心系统将生成的协同控制策略下发给相应的控制服务器；若第一节点为第一控制服务器，则第一控制服务器执行生成的本地控制策略。

采用上述信息处理方法，各个控制服务器各自采集并存储IP化现场设备采集信息以及相应处理结果，这样，就实现了信息的分布式存储。而只有当控制服务器确定满足订阅消息指示的预设条件时，才需将订阅消息指示的IP化现场设备采集信息以及相应处理结果返回第一节点，这样，就降低了智能交通云控制系统的整体信息传输量，从而，保证了系统的传输效率。

另一方面，在上述信息处理方法中，当第一节点为中心节点时，中心系统可以针对指定的多个控制服务器生成相应的协同控制策略，这样就可以提高某一区域内交通路况的调节效果，同时也降低了中心系统的信息存储量以及信息计算量；当第一节点为第一控制服务器时，第一控制服务器可以获取指定的其他控制服务器的IP化现场设备采集信息以及相应处理结果，这样第一控制服务器可以实现自管理，从而降低了中心系统的信息运算量，同时也实现了各个控制服务器之间的信息共享；此信息处理方法，通过结合消息订阅发布机制、数据分布式存储共享、云计算、边缘计算等技术，现场控制服务器存储本地数据、中心系统需求订阅数据，为实现交通系统数据的合理存储，快速共享，实时处理提供了解决方案。

本领域内的技术人员应明白，本发明的实施例可提供为方法、系统、或计算机程序产品。因此，本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。

本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。

这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。

这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。

尽管已描述了本发明的优选实施例，但本领域内的技术人员一旦得知了基本创造性概念，则可对这些实施例作出另外的变更和修改。所以，所附权利要求意欲解释为包括优选实施例以及落入本发明范围的所有变更和修改。

显然，本领域的技术人员可以对本发明实施例进行各种改动和变型而不脱离本发明实施例的精神和范围。这样，倘若本发明实施例的这些修改和变型属于本发明权利要求及其等同技术的范围之内，则本发明也意图包含这些改动和变型在内。