适用于城市轨道交通的数据推送系统及方法

1.一种适用于城市轨道交通的数据推送系统，其特征在于，包括：
底层应用客户端、通信中间件客户端和ATS子系统的应用服务器；其中，所述应用服务器，用于统计与其相连接的第一通信中间件客户端的数量，以及与其相连接的第一底层应用客户端的数量，根据所述两个数量确定每一个第一底层应用客户端所应连接的第一通信中间件客户端，并将每一个第一底层应用客户端所应连接的第一通信中间件客户端的标识通过udp协议周期性的发送给该第一底层应用客户端，以使该第一底层应用客户端在未连接有通信中间件客户端时或在与当前连接的第一通信中间件客户端断开连接时，根据接收到的标识，与该标识对应的第一通信中间件客户端建立连接，所述第一通信中间件客户端为所述通信中间件客户端中与所述应用服务器相连接的通信中间件客户端，所述第一底层应用客户端为所述底层应用客户端中与所述应用服务器相连接的底层应用客户端，
所述应用服务器，还用于获取待推送数据，将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端。
2.根据权利要求1所述的适用于城市轨道交通的数据推送系统，其特征在于，所述应用服务器，包括：
判断单元，用于判断所述应用服务器是否满足数据推送条件；
推送单元，用于在所述判断单元确定出所述应用服务器满足数据推送条件时，将所述待推送数据推送给所述第一通信中间件客户端，以使所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据推送给与所述第一通信中间件客户端相连接的底层应用客户端。
3.根据权利要求2所述的适用于城市轨道交通的数据推送系统，其特征在于，所述判断单元，包括：
判断子单元，用于判断所述应用服务器是否为跨天运行或者是否从待推送数据数据库下载到新的待推送数据；
确定子单元，用于在所述判断子单元确定出所述应用服务器为跨天运行或者从所述待推送数据数据库下载到新的待推送数据时，确定出所述应用服务器满足数据推送条件。
4.根据权利要求1所述的适用于城市轨道交通的数据推送系统，其特征在于，所述第一通信中间件客户端，用于在其与所述应用服务器建立连接之后，向所述应用服务器发送第一数据请求，以使所述应用服务器根据所述第一数据请求将所述待推送数据反馈给所述第一通信中间件客户端，由所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据发送给与其连接的底层应用客户端，
所述第一底层应用客户端，用于在其与所述第一通信中间件客户端建立连接之后，向与其连接的第一通信中间件客户端发送第二数据请求，以使所述与其连接的第一通信中间件客户端根据所述第二数据请求将缓存的所述待推送数据反馈给所述第一底层应用客户端。
5.根据权利要求1所述的适用于城市轨道交通的数据推送系统，其特征在于，所述第一通信中间件客户端在与所述应用服务器第一次建立连接之前，还用于向所述应用服务器进行用户注册，
所述第一底层应用客户端在与与其连接的所述第一通信中间件客户端第一次建立连接之前，还用于向所述第一通信中间件客户端进行用户注册。
6.一种基于权利要求1-5中任一项所述的适用于城市轨道交通的数据推送系统的数据推送方法，其特征在于，包括：
由ATS子系统的应用服务器统计与其相连接的第一通信中间件客户端的数量，以及与其相连接的第一底层应用客户端的数量，根据所述两个数量确定每一个第一底层应用客户端所应连接的第一通信中间件客户端，并将每一个第一底层应用客户端所应连接的第一通信中间件客户端的标识通过udp协议周期性的发送给该第一底层应用客户端，以使该第一底层应用客户端在未连接有通信中间件客户端时或在与当前连接的第一通信中间件客户端断开连接时，根据接收到的标识，与该标识对应的第一通信中间件客户端建立连接，其中，所述第一通信中间件客户端为所述通信中间件客户端中与所述应用服务器相连接的通信中间件客户端，所述第一底层应用客户端为所述底层应用客户端中与所述应用服务器相连接的底层应用客户端；
由所述应用服务器获取待推送数据，将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端。
7.根据权利要求6所述的数据推送方法，其特征在于，所述将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端，包括：
判断所述应用服务器是否满足数据推送条件；
在所述应用服务器满足数据推送条件时，将所述待推送数据推送给所述第一通信中间件客户端，以使所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据推送给与所述第一通信中间件客户端相连接的底层应用客户端。
8.根据权利要求7所述的数据推送方法，其特征在于，所述判断所述应用服务器是否满足数据推送条件，包括：
判断所述应用服务器是否为跨天运行或者是否从待推送数据数据库下载到新的待推送数据；
在所述应用服务器为跨天运行或者从所述待推送数据数据库下载到新的待推送数据时，确定出所述应用服务器满足数据推送条件。
9.根据权利要求6所述的数据推送方法，其特征在于，所述将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端，包括：
由所述第一通信中间件客户端在其与所述应用服务器建立连接之后，向所述应用服务器发送第一数据请求，以使所述应用服务器根据所述第一数据请求将所述待推送数据反馈给所述第一通信中间件客户端，由所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据发送给与其连接的底层应用客户端；
由所述第一底层应用客户端在其与所述第一通信中间件客户端建立连接之后，向与其连接的第一通信中间件客户端发送第二数据请求，以使所述与其连接的第一通信中间件客户端根据所述第二数据请求将缓存的所述待推送数据反馈给所述第一底层应用客户端。
10.根据权利要求6所述的数据推送方法，其特征在于，在所述由ATS子系统的应用服务器统计与其相连接的第一通信中间件客户端的数量，以及与所述第一通信中间件客户端相连接的第一底层应用客户端的数量之前，还包括：
由所述第一通信中间件客户端向所述应用服务器进行用户注册，并在注册成功后，与所述应用服务器建立第一次连接；
由所述第一底层应用客户端向待与其相连接的第一通信中间件客户端进行用户注册，并在注册成功后，与所述待与其相连接的第一通信中间件客户端建立第一次连接。

适用于城市轨道交通的数据推送系统及方法\n技术领域\n[0001] 本发明涉及通信技术领域，具体涉及一种适用于城市轨道交通的数据推送系统及基于该系统的数据推送方法。\n背景技术\n[0002] 传统的通信平台，采用的是通过ATS(自动列车监控系统)子系统应用服务器依次为底层应用推送数据。传统通信平台全部建立在应用服务器上，实时保持只有一台应用服务器拥有推送功能，传统系统通信图参见图1。传统通信平台工作过程如下：(1)作为客户端的底层应用连接服务端成功后请求数据，服务端收到请求予以应答；(2)服务端从数据库获得新数据后及时将其推送给作为客户端的底层应用。\n[0003] 传统通信平台推送数据存在以下缺陷：(1)工作效率低：底层应用数量达到峰值时，推送延迟时间比较长；(2)扩展性差：通信平台只支持应用服务器作为服务端。\n发明内容\n[0004] 本发明的目的在于，提供一种适用于城市轨道交通的数据推送系统及基于该系统的数据推送方法，能够解决传统通信平台推送数据存在的工作效率低和扩展性差的缺陷。\n[0005] 为此目的，一方面，本发明提出一种适用于城市轨道交通的数据推送系统，包括：\n[0006] 底层应用客户端、通信中间件客户端和ATS子系统的应用服务器；其中，[0007] 所述应用服务器，用于统计与其相连接的第一通信中间件客户端的数量，以及与其相连接的第一底层应用客户端的数量，根据所述两个数量确定每一个第一底层应用客户端所应连接的第一通信中间件客户端，并将每一个第一底层应用客户端所应连接的第一通信中间件客户端的标识通过udp协议周期性的发送给该第一底层应用客户端，以使该第一底层应用客户端在未连接有通信中间件客户端时或在与当前连接的第一通信中间件客户端断开连接时，根据接收到的标识，与该标识对应的第一通信中间件客户端建立连接，所述第一通信中间件客户端为所述通信中间件客户端中与所述应用服务器相连接的通信中间件客户端，所述第一底层应用客户端为所述底层应用客户端中与所述应用服务器相连接的底层应用客户端，\n[0008] 所述应用服务器，还用于获取待推送数据，将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端。\n[0009] 另一方面，本发明提出一种基于适用于城市轨道交通的数据推送系统的数据推送方法，包括：\n[0010] 由ATS子系统的应用服务器统计与其相连接的第一通信中间件客户端的数量，以及与其相连接的第一底层应用客户端的数量，根据所述两个数量确定每一个第一底层应用客户端所应连接的第一通信中间件客户端，并将每一个第一底层应用客户端所应连接的第一通信中间件客户端的标识通过udp协议周期性的发送给该第一底层应用客户端，以使该第一底层应用客户端在未连接有通信中间件客户端时或在与当前连接的第一通信中间件客户端断开连接时，根据接收到的标识，与该标识对应的第一通信中间件客户端建立连接，其中，所述第一通信中间件客户端为所述通信中间件客户端中与所述应用服务器相连接的通信中间件客户端，所述第一底层应用客户端为所述底层应用客户端中与所述应用服务器相连接的底层应用客户端；\n[0011] 由所述应用服务器获取待推送数据，将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端。\n[0012] 本发明实施例所述的适用于城市轨道交通的数据推送系统及基于该系统的数据推送方法，底层应用客户端根据应用服务器根据通信中间件客户端数目和底层应用客户端数目确定的目标通信中间件客户端动态选择连接目标，并由目标通信中间件客户端向底层应用客户端转发应用服务器发送的数据，从而相较于由应用服务器到底层应用客户端的数据推送模式，本发明的推送延时较短，能够适应大量需要通信的设备场景，提升了工作效率，同时，本发明的通信中间件客户端启动数目不限，可以随时随地启动，因而相较于由应用服务器到底层应用客户端的数据推送模式，本发明扩展性较强。\n附图说明\n[0013] 图1为传统的系统通信示意图；\n[0014] 图2为本发明一种适用于城市轨道交通的数据推送系统一实施例的结构示意图；\n[0015] 图3为本发明一种适用于城市轨道交通的数据推送系统另一实施例所涉及的主动推送数据的流程示意图；\n[0016] 图4为本发明一种适用于城市轨道交通的数据推送系统又一实施例所涉及的请求-应答数据的流程示意图；\n[0017] 图5为本发明一种适用于城市轨道交通的数据推送系统又一实施例所涉及的实时指派的流程示意图；\n[0018] 图6为本发明一种适用于城市轨道交通的数据推送系统又一实施例所涉及的切换服务端连接的流程示意图；\n[0019] 图7为本发明一种数据推送方法一实施例的流程示意图。\n具体实施方式\n[0020] 为使本发明实施例的目的、技术方案和优点更加清楚，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。\n[0021] 参看图2，本实施例公开一种适用于城市轨道交通的数据推送系统，包括：\n[0022] 底层应用客户端1、通信中间件客户端2和ATS子系统的应用服务器3；其中，[0023] 所述应用服务器3，用于统计与其相连接的第一通信中间件客户端2的数量，以及与其相连接的第一底层应用客户端1的数量，根据所述两个数量确定每一个第一底层应用客户端1所应连接的第一通信中间件客户端2，并将每一个第一底层应用客户端1所应连接的第一通信中间件客户端2的标识通过udp协议(用户数据报协议)周期性的发送给该第一底层应用客户端1，以使该第一底层应用客户端1在未连接有通信中间件客户端2时或在与当前连接的第一通信中间件客户端2断开连接时，根据接收到的标识，与该标识对应的第一通信中间件客户端2建立连接，所述第一通信中间件客户端为所述通信中间件客户端中与所述应用服务器相连接的通信中间件客户端，所述第一底层应用客户端为所述底层应用客户端中与所述应用服务器相连接的底层应用客户端，\n[0024] 所述应用服务器3，还用于获取待推送数据，将所述待推送数据通过所述第一通信中间件客户端2推送给与所述第一通信中间件客户端2相连接的底层应用客户端1。\n[0025] 本发明实施例中，每个ATS应用所在设备中都可以对应部署一个通信中间件。通信中间件随ATS应用程序一起启动。应用服务器、底层应用客户端和通信中间件客户端集成相同的通信平台，只是使用平台的不同功能。\n[0026] 本发明实施例所述的适用于城市轨道交通的数据推送系统，底层应用客户端根据应用服务器根据通信中间件客户端数目和底层应用客户端数目确定的目标通信中间件客户端动态选择连接目标，并由目标通信中间件客户端向底层应用客户端转发应用服务器发送的数据，从而相较于由应用服务器到底层应用客户端的数据推送模式，本发明的推送延时较短，能够适应大量需要通信的设备场景，提升了工作效率，同时，本发明的通信中间件客户端启动数目不限，可以随时随地启动，因而相较于由应用服务器到底层应用客户端的数据推送模式，本发明扩展性较强。\n[0027] 可选地，在本发明适用于城市轨道交通的数据推送系统的另一实施例中，所述应用服务器，包括：\n[0028] 判断单元，用于判断所述应用服务器是否满足数据推送条件；\n[0029] 推送单元，用于在所述判断单元确定出所述应用服务器满足数据推送条件时，将所述待推送数据推送给所述第一通信中间件客户端，以使所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据推送给与所述第一通信中间件客户端相连接的底层应用客户端。\n[0030] 本发明数据转发方式可分为主动推送数据和请求-应答数据两种，应用服务器在两种情况下会主动推送数据：\n[0031] (1)应用服务器跨天运行后主动推送数据；\n[0032] (2)应用服务器从数据库下载到新数据后主动推送数据。\n[0033] 集成通信平台的应用程序全部启动后，具体主动推送流程图参见图3，整个系统推送数据步骤如下：\n[0034] (1)应用服务器满足推送条件；\n[0035] (2)推送数据到与它建立连接的客户端(通信中间件)；\n[0036] (3)通信中间件收到数据进行缓存；\n[0037] (4)通信中间件推送数据到与它建立连接的客户端(底层应用)。\n[0038] 可选地，在本发明适用于城市轨道交通的数据推送系统的另一实施例中，所述判断单元，包括：\n[0039] 判断子单元，用于判断所述应用服务器是否为跨天运行或者是否从待推送数据数据库下载到新的待推送数据；\n[0040] 确定子单元，用于在所述判断子单元确定出所述应用服务器为跨天运行或者从所述待推送数据数据库下载到新的待推送数据时，确定出所述应用服务器满足数据推送条件。\n[0041] 可选地，在本发明适用于城市轨道交通的数据推送系统的另一实施例中，所述第一通信中间件客户端，用于在其与所述应用服务器建立连接之后，向所述应用服务器发送第一数据请求，以使所述应用服务器根据所述第一数据请求将所述待推送数据反馈给所述第一通信中间件客户端，由所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据发送给与其连接的底层应用客户端，\n[0042] 所述第一底层应用客户端，用于在其与所述第一通信中间件客户端建立连接之后，向与其连接的第一通信中间件客户端发送第二数据请求，以使所述与其连接的第一通信中间件客户端根据所述第二数据请求将缓存的所述待推送数据反馈给所述第一底层应用客户端。\n[0043] 集成通信平台的应用程序全部启动后，具体请求-应答数据流程图参见图4，整个系统请求-应答步骤如下：\n[0044] (1)应用服务器与通信中间件建立连接后，作为客户端的通信中间件马上向应用服务器请求所需数据；\n[0045] (2)通信中间件接收到应用服务器应答的数据后，马上缓存数据并且主动推送数据到与它建立连接的客户端(底层应用)；\n[0046] (3)通信中间件与底层应用建立连接后，作为客户端的底层应用马上向通信中间件请求所需数据；\n[0047] (4)底层应用接收到通信中间件应答的数据进行相应处理。\n[0048] 集成通信平台的应用程序全部启动后，具体实时指派流程图参见图5，整个系统实时指派步骤如下：\n[0049] (1)应用服务器统计运行中底层应用的个数和与自己建立连接的通信中间件的个数；\n[0050] (2)应用服务器通过通信平台指派算法得到底层应用和通信中间件的连接关系；\n[0051] (4)应用服务器将底层应用要连接的通信中间件的编号周期性的发送给底层应用。\n[0052] 集成通信平台的应用程序全部启动后，切换服务端连接流程图参见图6，切换服务端连接步骤如下：\n[0053] (1)底层应用记录接收到应用服务器周期性发送来的通信中间件的编号；\n[0054] (2)底层应用发现与现有服务端(通信中间件)断开连接，那么转而连接到所记录编号对应的通信中间件。\n[0055] 可选地，在本发明适用于城市轨道交通的数据推送系统的另一实施例中，所述第一通信中间件客户端在与所述应用服务器第一次建立连接之前，还用于向所述应用服务器进行用户注册，\n[0056] 所述第一底层应用客户端在与与其连接的所述第一通信中间件客户端第一次建立连接之前，还用于向所述第一通信中间件客户端进行用户注册。\n[0057] 本发明实现通过缓存应用服务器发送的数据向底层应用进行转发，通信平台发现数据变化可及时推送，更新数据，提供主动推送数据和请求-应答数据两种工作方式，底层应用根据集成到应用服务器的通信平台中的指派算法提供的连接目标(通信中间件)进行动态选择连接目标，从而可以根据实际情况对客户端进行实时指派，三层推送机制可以大大减少推送延时，为应用服务器减轻数据推送压力，并且，客户端数量可以根据实际情况做到可配置化，整个系统更智能、更可靠，系统可以很轻松的适应大量需要通信的设备场景，提升了系统的工作效率。\n[0058] 参看图7，本实施例公开一种基于前述实施例所述的适用于城市轨道交通的数据推送系统的数据推送方法，包括：\n[0059] S1、由ATS子系统的应用服务器统计与其相连接的第一通信中间件客户端的数量，以及与其相连接的第一底层应用客户端的数量，根据所述两个数量确定每一个第一底层应用客户端所应连接的第一通信中间件客户端，并将每一个第一底层应用客户端所应连接的第一通信中间件客户端的标识通过udp协议周期性的发送给该第一底层应用客户端，以使该第一底层应用客户端在未连接有通信中间件客户端时或在与当前连接的第一通信中间件客户端断开连接时，根据接收到的标识，与该标识对应的第一通信中间件客户端建立连接，其中，所述第一通信中间件客户端为所述通信中间件客户端中与所述应用服务器相连接的通信中间件客户端，所述第一底层应用客户端为所述底层应用客户端中与所述应用服务器相连接的底层应用客户端；\n[0060] S2、由所述应用服务器获取待推送数据，将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端。\n[0061] 本发明实施例所述的数据推送方法，底层应用客户端根据应用服务器根据通信中间件客户端数目和底层应用客户端数目确定的目标通信中间件客户端动态选择连接目标，并由目标通信中间件客户端向底层应用客户端转发应用服务器发送的数据，从而相较于由应用服务器到底层应用客户端的数据推送模式，本发明的推送延时较短，能够适应大量需要通信的设备场景，提升了工作效率，同时，本发明的通信中间件客户端启动数目不限，可以随时随地启动，因而相较于由应用服务器到底层应用客户端的数据推送模式，本发明扩展性较强。\n[0062] 可选地，在本发明数据推送方法的另一实施例中，所述将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端，包括：\n[0063] 判断所述应用服务器是否满足数据推送条件；\n[0064] 在所述应用服务器满足数据推送条件时，将所述待推送数据推送给所述第一通信中间件客户端，以使所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据推送给与所述第一通信中间件客户端相连接的底层应用客户端。\n[0065] 可选地，在本发明数据推送方法的另一实施例中，所述判断所述应用服务器是否满足数据推送条件，包括：\n[0066] 判断所述应用服务器是否为跨天运行或者是否从待推送数据数据库下载到新的待推送数据；\n[0067] 在所述应用服务器为跨天运行或者从所述待推送数据数据库下载到新的待推送数据时，确定出所述应用服务器满足数据推送条件。\n[0068] 可选地，在本发明数据推送方法的另一实施例中，所述将所述待推送数据通过所述第一通信中间件客户端推送给与所述第一通信中间件客户端相连接的底层应用客户端，包括：\n[0069] 由所述第一通信中间件客户端在其与所述应用服务器建立连接之后，向所述应用服务器发送第一数据请求，以使所述应用服务器根据所述第一数据请求将所述待推送数据反馈给所述第一通信中间件客户端，由所述第一通信中间件客户端对所述待推送数据进行缓存，并将所述待推送数据发送给与其连接的底层应用客户端；\n[0070] 由所述第一底层应用客户端在其与所述第一通信中间件客户端建立连接之后，向与其连接的第一通信中间件客户端发送第二数据请求，以使所述与其连接的第一通信中间件客户端根据所述第二数据请求将缓存的所述待推送数据反馈给所述第一底层应用客户端。\n[0071] 可选地，在本发明数据推送方法的另一实施例中，在所述由ATS子系统的应用服务器统计与其相连接的第一通信中间件客户端的数量，以及与所述第一通信中间件客户端相连接的第一底层应用客户端的数量之前，还包括：\n[0072] 由所述第一通信中间件客户端向所述应用服务器进行用户注册，并在注册成功后，与所述应用服务器建立第一次连接；\n[0073] 由所述第一底层应用客户端向待与其相连接的第一通信中间件客户端进行用户注册，并在注册成功后，与所述待与其相连接的第一通信中间件客户端建立第一次连接。\n[0074] 虽然结合附图描述了本发明的实施方式，但是本领域技术人员可以在不脱离本发明的精神和范围的情况下做出各种修改和变型，这样的修改和变型均落入由所附权利要求所限定的范围之内。