数据交互方法、装置、非易失性存储介质及计算机设备与流程

1.本发明涉及智能车领域，具体而言，涉及一种数据交互方法、装置、非易失性存储介质及计算机设备。


背景技术：

2.随着车联网的普及，越来越多的车主习惯通过终端设备的车辆控制app查看车辆的状态，例如查看车辆的四门两盖、车窗车锁的状态。受限于车况上报频率和app获取车况的方式，车主无法实时准确的获取最新的车况信息。该过程中的技术问题包括：受限于车载sim卡流量限制和云平台车况并发处理的压力限制，车辆按照一定周期上报车况。由于车辆不能按照特别高的频率上报车况，所以云端收到车辆上报的车况无法做到实时反映车辆当前的状态；或者，传统的车况查看功能，需要用户在app的车况界面，通过手动刷新按钮才能获得最新的车况，才能知道车况是否发生了变化，无法做到实时的在界面上动态感知车况的变化。
3.针对上述的问题，目前尚未提出有效的解决方案。


技术实现要素：

4.本发明实施例提供了一种数据交互方法、装置、非易失性存储介质及计算机设备，以至少解决车端用户的终端设备接收的车辆的车况推送信息有时不准确的技术问题。
5.根据本发明实施例的一个方面，提供了一种数据交互方法一，包括：与终端建立可以连续通讯的第一长连接；响应所述终端通过所述第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过所述第二长连接向所述车辆发送车况上报指令，其中，所述车况实时查询请求用于请求查询所述车辆的车况；接收所述车辆通过所述第二长连接返回的车况信息；控制目标进程根据所述车况信息生成车况推送信息，其中，所述目标进程与所述车辆对应，所述目标进程用于将所述车辆的车况信息同步至所述终端；通过所述第一长连接向所述终端发送所述车况推送信息。
6.可选地，所述控制目标进程根据所述车况信息生成车况推送信息之前，还包括：响应所述车况实时查询请求，创建所述目标进程，其中，所述目标进程用于存储所述车辆的历史车况信息；根据所述历史车况信息和所述车况信息生成所述车况推送信息以及向所述终端发送所述车况推送信息。
7.可选地，所述控制目标进程根据所述车况信息生成车况推送信息，包括：所述目标进程比较所述车况信息以及所述历史车况信息，得到车况比较结果；在所述车况比较结果表示所述车况信息与所述历史车况信息存在区别的情况下，生成所述车辆的车况推送信息，其中，所述车况推送信息用于表示所述车况信息与所述历史车况信息的区别。
8.可选地，所述目标进程比较所述车况信息以及所述历史车况信息，得到车况比较结果，包括：所述目标进程调用规则引擎，基于所述规则引擎比较所述车况信息和所述历史车况信息，得到所述车况比较结果，其中，所述规则引擎根据所述车辆的唯一标识码生成并
内置于所述目标进程中。
9.可选地，所述响应所述车况实时查询请求，创建所述目标进程，包括：根据所述车况实时查询请求，获取所述车况实时查询请求对应的车辆的唯一标识码；根据所述唯一标识码，确定所述与所述车辆对应的所述规则引擎；根据所述规则引擎，创建所述目标进程，其中，所述目标进程采用所述规则引擎进行数据处理。
10.可选地，所述接收所述车辆通过所述第二长连接返回的车况信息之后，还包括：将所述车况信息存入所述目标进程的内存空间。
11.根据本发明实施例的另一方面，还提供了一种数据交互方法二，包括：与云端平台建立可以连续通讯的第一长连接；通过所述第一长连接向所述云端平台发送车况实时查询请求，请求所述云端平台与车辆建立可以连续通讯的第二长连接，并请求所述云端平台通过所述第二长连接向所述车辆发送车况上报指令，其中，所述车况实时查询请求用于请求查询所述车辆的车况；接收所述车辆通过所述第二长连接返回的车况信息；通过所述第一长连接，接收所述云端平台返回的车况推送信息，其中，所述车况推送信息为所述云端平台的目标进程根据车况信息生成，所述车况信息为所述云端平台通过所述第二长连接接收的所述车辆返回的信息，所述目标进程与所述车辆对应，所述目标进程用于将所述车辆的车况信息同步至所述终端。
12.根据本发明实施例的另一方面，还提供了一种数据交互装置一，包括：第一建立模块，用于与终端建立可以连续通讯的第一长连接；第二建立模块，用于响应所述终端通过所述第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过所述第二长连接向所述车辆发送车况上报指令，其中，所述车况实时查询请求用于请求查询所述车辆的车况；第一接收模块，用于接收所述车辆通过所述第二长连接返回的车况信息；生成模块，用于控制目标进程根据所述车况信息生成车况推送信息，其中，所述目标进程与所述车辆对应，所述目标进程用于将所述车辆的车况信息同步至所述终端；发送模块，用于通过所述第一长连接向所述终端发送所述车况推送信息。
13.根据本发明实施例的另一方面，还提供了一种数据交互装置二，包括：第三建立模块，用于与云端平台建立可以连续通讯的第一长连接；请求模块，用于通过第一长连接向云端平台发送车况实时查询请求，请求云端平台与车辆建立可以连续通讯的第二长连接，并请求云端平台通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；第二接收模块，用于接收车辆通过第二长连接返回的车况信息；第三接收模块，用于通过第一长连接，接收云端平台返回的车况推送信息，其中，车况推送信息为云端平台的目标进程根据车况信息生成，车况信息为云端平台通过第二长连接接收的车辆返回的信息，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端。
14.根据本发明实施例的又一方面，还提供了一种非易失性存储介质，所述非易失性存储介质包括存储的程序，其中，在所述程序运行时控制所述非易失性存储介质所在设备执行上述任意一项所述数据交互方法。
15.根据本发明实施例的再一方面，还提供了一种计算机设备，所述计算机设备包括存储器和处理器，所述存储器用于存储程序，所述处理器用于运行所述存储器存储的程序，其中，所述程序运行时执行上述任意一项所述数据交互方法。
16.在本发明实施例中，采用在云端为用户创建专属于其车辆的进程的方式，由云端
与车辆用户的终端建立可以连续通讯的第一长连接；响应终端通过第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；接收车辆通过第二长连接返回的车况信息；控制目标进程根据车况信息生成车况推送信息，其中，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端；通过第一长连接向终端发送车况推送信息，达到了保持用户车辆的车况信息可以持续不断地推送到用户的终端上的目的，从而实现了车辆状态在用户终端设备上的快速实时更新的技术效果，进而解决了车端用户的终端设备接收的车辆的车况推送信息有时不准确的技术问题。
附图说明
17.此处所说明的附图用来提供对本发明的进一步理解，构成本技术的一部分，本发明的示意性实施例及其说明用于解释本发明，并不构成对本发明的不当限定。在附图中：
18.图1示出了一种用于实现数据交互方法的计算机终端的硬件结构框图；
19.图2是根据本发明实施例提供的数据交互方法一的流程示意图；
20.图3是根据本发明可选实施例提供的车况信息推送系统的示意图；
21.图4是根据本发明可选实施例提供的车况镜像进程的工作架构示意图；
22.图5是根据本发明可选实施例提供的车况镜像进程的工作流程示意图；
23.图6是根据本发明可选实施例提供的手机车联网app查询车况的流程示意图；
24.图7是根据本发明可选实施例提供的手机车辆网app的架构示意图；
25.图8是根据本发明实施例提供的数据交互方法二的流程示意图；
26.图9是根据本发明实施例提供的数据交互装置一的结构框图；
27.图10是根据本发明实施例提供的数据交互装置二的结构框图。
具体实施方式
28.为了使本技术领域的人员更好地理解本发明方案，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分的实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都应当属于本发明保护的范围。
29.需要说明的是，本发明的说明书和权利要求书及上述附图中的术语”第一”、”第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便这里描述的本发明的实施例能够以除了在这里图示或描述的那些以外的顺序实施。此外，术语”包括”和”具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元，而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。
30.根据本发明实施例，提供了一种数据交互方法实施例，需要说明的是，在附图的流程图示出的步骤可以在诸如一组计算机可执行指令的计算机系统中执行，并且，虽然在流程图中示出了逻辑顺序，但是在某些情况下，可以以不同于此处的顺序执行所示出或描述
的步骤。
31.本技术实施例一所提供的方法实施例可以在移动终端、计算机终端或者类似的运算装置中执行。图1示出了一种用于实现数据交互方法的计算机终端的硬件结构框图。如图1所示，计算机终端10可以包括一个或多个(图中采用102a、102b，
……
，102n来示出)处理器(处理器可以包括但不限于微处理器mcu或可编程逻辑器件fpga等的处理装置)、用于存储数据的存储器104。除此以外，还可以包括：显示器、输入/输出接口(i/o接口)、通用串行总线(usb)端口(可以作为bus总线的端口中的一个端口被包括)、网络接口、电源和/或相机。本领域普通技术人员可以理解，图1所示的结构仅为示意，其并不对上述电子装置的结构造成限定。例如，计算机终端10还可包括比图1中所示更多或者更少的组件，或者具有与图1所示不同的配置。
32.应当注意到的是上述一个或多个处理器和/或其他数据处理电路在本文中通常可以被称为”数据处理电路”。该数据处理电路可以全部或部分的体现为软件、硬件、固件或其他任意组合。此外，数据处理电路可为单个独立的处理模块，或全部或部分的结合到计算机终端10中的其他元件中的任意一个内。如本技术实施例中所涉及到的，该数据处理电路作为一种处理器控制(例如与接口连接的可变电阻终端路径的选择)。
33.存储器104可用于存储应用软件的软件程序以及模块，如本发明实施例中的数据交互方法对应的程序指令/数据存储装置，处理器通过运行存储在存储器104内的软件程序以及模块，从而执行各种功能应用以及数据处理，即实现上述的应用程序的数据交互方法。存储器104可包括高速随机存储器，还可包括非易失性存储器，如一个或者多个磁性存储装置、闪存、或者其他非易失性固态存储器。在一些实例中，存储器104可进一步包括相对于处理器远程设置的存储器，这些远程存储器可以通过网络连接至计算机终端10。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。
34.显示器可以例如触摸屏式的液晶显示器(lcd)，该液晶显示器可使得用户能够与计算机终端10的用户界面进行交互。
35.相关技术中，车辆用户从终端设备中看到的车辆的状态存在滞后性，车主需要手动刷新终端设备上的车况以获得车辆的最新车况，导致车主看到的车况信息的实时性无法保证。本技术提供了如下技术方案，通过建立双向长连接链路并在云端为车辆分配对应的进程，实现将车辆的最新车况实施推送给车主的终端设备。
36.图2是根据本发明实施例提供的数据交互方法一的流程示意图，本数据交互方法一可以应用于管理车联网系统的云端平台中，车主的车辆以及终端设备可以分别与云端平台通信以实现信息的交互，云端平台也可以称为车联网云平台。如图2所示，该方法可以包括如下步骤：
37.步骤s202，与终端建立可以连续通讯的第一长连接。
38.其中，终端可以是车主用于查看车辆的车况状态的终端设备，终端设备通过车联网云端平台与车辆进行信息交互。可选地，终端可以是车主的移动终端设备，例如安装有车辆控制app的智能手机、智能平板，也可以是专门用于操控车辆的操控板、操控手柄等，终端的具体类型在此可以不做限定。可选地，第一长连接和下述的第二长连接可以为基于长连接协议建立的长连接通讯通道，长连接协议可以包括基于tcp协议的长连接，也可以采用消息队列遥测传输mqtt长连接协议。其中，mqtt协议是一种基于发布/订阅范式的消息协议，
其工作在tcp/ip协议族上，mqtt协议轻量、简便，因而可以应用于车联网系统中，例如应用到终端与车联网云平台、车辆与车联网云平台之间的信息收发过程中。
39.步骤s204，响应终端通过第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况。
40.步骤s206，接收车辆通过第二长连接返回的车况信息。
41.可选地，车况实时查询请求可以是车主用户通过终端向云端平台发送的请求，用于请求云端平台将车辆的车况反馈到终端上，进而使得用户可以通过终端的显示屏幕观看到车辆的车况，或者通过终端的播音装置听到车辆的车况播报。车辆与云端平台建立的第二长连接可以使得车辆与云端平台之间保持不中断的通信联系，使得车辆可以实时将车况信息反馈到云端平台中，避免车辆向云端平台反馈信息不及时造成车主的终端无法获知车辆的最新车况。可选地，车况信息可以包括车辆的各个部件的状态信息，例如，可以包括车辆的车门、车盖的开闭信息，还可以包括车辆的发动机状态、燃油储备状态或者电池状态等。
42.步骤s208，控制目标进程根据车况信息生成车况推送信息，其中，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端。
43.需要说明的是，目标进程可以是云端平台为上述车辆专门开辟的进程，例如目标进程可以是专门用于处理上述车辆的车况信息更新工作而创建的一个镜像进程。可选地，云端平台可以通过多进程管理机制，为车联网系统中的每辆车分别创建一个云端车况镜像进程，在进程内部内置推送信息的规则引擎，由规则引擎判定是否要将云端车况镜像进程收到的车辆通过长连接发送的车况信息推送给用户的终端，减少无效的车况推送数据，节约通信流量。
44.作为一种可选的实施例，控制目标进程根据车况信息生成车况推送信息之前，还可以包括如下步骤：响应车况实时查询请求，创建目标进程，其中，目标进程用于存储车辆的历史车况信息；根据历史车况信息和车况信息生成车况推送信息以及向终端发送车况推送信息。其中，历史车况信息可以包括车辆在上一时刻下的车况信息，因此可以根据目标进程当前收到的车况信息和历史车况信息判断该车辆的车况是否发生了变化，进而判断是否需要向终端推送新的车辆的状态。
45.作为一种可选的实施例，控制目标进程根据车况信息生成车况推送信息，包括：目标进程比较车况信息以及历史车况信息，得到车况比较结果；在车况比较结果表示车况信息与历史车况信息存在区别的情况下，生成车辆的车况推送信息，其中，车况推送信息用于表示车况信息与历史车况信息的区别。
46.作为一种可选的实施例，目标进程比较车况信息以及历史车况信息，得到车况比较结果，包括：目标进程调用规则引擎，基于规则引擎比较车况信息和历史车况信息，得到车况比较结果，其中，规则引擎根据车辆的唯一标识码生成并内置于目标进程中。
47.其中，车况信息与车况推送信息的区别可以在于，目标进程中内置的规则引擎可以判断进程当前收到的车况信息与前一时刻下车辆的车况信息是否相同，若两个时刻下的车况信息完全相同，则不像终端推送新的信息，若进程当前收到的车况信息与前一时刻下车辆的车况信息不同，则可以将两个时刻下的区别信息打包为车况推送信息并发送至终
端，使得在终端上可以及时更新车辆的状态。
48.步骤s210，通过第一长连接向终端发送车况推送信息。
49.上述步骤中，采用在云端为用户创建专属于其车辆的进程的方式，由云端与车辆用户的终端建立可以连续通讯的第一长连接；响应终端通过第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；接收车辆通过第二长连接返回的车况信息；控制目标进程根据车况信息生成车况推送信息，其中，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端；通过第一长连接向终端发送车况推送信息，达到了保持用户车辆的车况信息可以持续不断地推送到用户的终端上的目的，从而实现了车辆状态在用户终端设备上的快速实时更新的技术效果，进而解决了车端用户的终端设备接收的车辆的车况推送信息有时不准确的技术问题。
50.作为一种可选的实施例，响应车况实时查询请求创建目标进程时，可以包括如下过程：根据车况实时查询请求，获取车况实时查询请求对应的车辆的唯一标识码；根据唯一标识码，确定与车辆对应的规则引擎；根据规则引擎，创建目标进程，其中，目标进程采用规则引擎进行数据处理。其中，车辆的唯一标识码可以是车辆的车辆身份标识码(vehicle identification number，简称vin)，可以用于表征车辆的型号、特征等基本信息，因此可以基于vin调用与该车辆对应的规则引擎，避免采用与车辆不符的规则引擎导致推送消息的处理过程出现错误。
51.作为一种可选的实施例，接收车辆通过第二长连接返回的车况信息之后，还包括如下步骤：将车况信息存入目标进程的内存空间。可选地，可以将车况信息写入目标进程中的历史车况信息中，使得车辆在下一时刻受到新的车况信息时，可以将下一时刻下的新的车况信息与历史车况信息中的当前时刻下的车况信息进行比对，以判断是否在下一时刻向终端推送车况信息。
52.可选地，基于上述实施例或可选实施例，可以提供一种车况信息推送系统。图3是根据本发明可选实施例提供的车况信息推送系统的示意图，如图3所示，该系统可以由以下若干部分组成：1、车载通信终端；2、手机车联网app；3、车联网云端平台，其中，云端平台可以包括物联网网关、上下行消息分发引擎、上下行消息中间件、车况镜像系统、单车车况镜像进程创建/销毁管理、数据库。
53.上述系统中，车载通信终端用于与车联网云平台建立长连接，变频上报最新车况信息，接收并执行云端下发的指令；手机车联网app用于接收云端下发的最新车况，并更新展示给用户；物联网网关用于车联网云平台与车载通信终端和手机车联网app建立通信长连接；上行消息分发引擎，用于识别车况消息所属车辆，并通过进程间通信，定向推送到制定车辆的车况镜像进程；下行消息分发引擎，用于识别车况消息所属车辆的用户，选择对应的用户的app长连接通路，推送最新的车况信息；上下行消息中间件用于服务间的大通量的消息分发与流转；车况镜像系统用于接收车辆最新的车况信息，并通过内置的规则引擎，加载规则，判定是否满足车况推送的条件；单车车况镜像进程创建/销毁管理，用于收到车辆的在线、离线消息后，及时对每一台车的车况镜像进程进行创建和销毁。
54.基于图3所示的车况信息推送信息，车辆的车况信息可以通过如下方式持续不断地推送至用户的手机车联网app中：
55.步骤1)手机app监测用户进入到车况查询页面，手机app与云端平台建立长连接，通知云端平台并间接通知车辆的车载通信单元；步骤2)云端平台为此车辆创建一个车况镜像进程，该镜像进程专门服务于本车辆，具体用于车况检测、规则满足判断及车况推送信息的推送；步骤3)车辆的车载通信单元接到通知后，提高频率向云端平台上报车况信息；步骤4)手机车联网app收到云端推送的实时更新的车况推送消息，刷新app的显示界面，将更新后的车况显示给车主。
56.上述车况信息的推送过程至少具有如下优点：
57.优点1：传统车况查询功能，更新车况需要车主手动刷新车况，实时性无法保证；本系统通过车联网app与车联网云平台建立的双向长连接链路，实时获取云端推送的最新车况，app端根据推送结果实时更新车况显示内容，用户体验优秀；按照此种方式，app端无需长时间高频主动轮询车况更新接口，减少云服务查询接口处理量。
58.优点2：车主进入app车况查询页面，主动通知车端，车端才会进入高频上车况报模式，无需时刻保持车况高频上报模式，节约流量、带宽和云端计算资源。
59.优点3：云端平台通过多进程管理机制，为每辆车单独创建云端单车车况镜像进程，进程内置规则引擎，判定是否要通知车联网app更新最新车况，减少无变化/无效车况推送更新，节约流量。
60.优点4：单车车况镜像进程创建时，自动加载历史车况到进程的内存中，全生命周期内通过高速内存的读写，快速完成规则引擎的计算，减少数据库的读写耗时开销和数据库不稳定对系统的影响；并在车辆离线后，及时销毁进程，减少服务器无用的开销。
61.图4是根据本发明可选实施例提供的车况镜像进程的工作架构示意图，如图4所示，由于系统可以为每一个接入云端平台的车辆创建一个车况镜像进程，因此进程也可以称为单车车况镜像进程，进程的创建/销毁管理可以包括：
62.上行消息中间件，可以采用kafka、rabbitmq等高吞吐量的大数据中间件，传递车辆的在线和上线消息；消息处理规则引擎，在收到上线消息后，解析出车辆唯一识别标识vin码，基于最新的历史车况和规则配置表，创建此台车的车况镜像进程，记录车况镜像进程的id号，用于后续管理；消息处理规则引擎，在收到下线消息后，解析出车辆唯一识别标识vin码，创通过vin码查询此台车的车况镜像进程id号，还可以通过进程间通信模块销毁此进程。
63.图5是根据本发明可选实施例提供的车况镜像进程的工作流程示意图，如图5所示，车况镜像进程可以由高并发的开发架构、语言实现。其中，系统在进程之外可以包括上行消息分发引擎，引擎收到上行消息中间件的车况信息，解析出此条信息对应的vin码；根据vin码查询车辆对应的车况镜像进程id，通过进程间通信机制，将最新的车况信息快速传给指定车辆的车况镜像进程；进程内可以包括车况规则引擎，该引擎根据既定的车况判定规则，在内存中读取历史车况信息，结合历史车况信息和最新一帧的车况信息进行判断，如果满足推送规则，则可以通过进程间通信，通知下行消息分发引擎，将车况推送信息推送到指定的用户车联网app；系统还可以包括下行消息分发引擎，根据vin码查询当前登录的app设备的长连接通道id，拼装消息报文下发到车联网app中。
64.图6是根据本发明可选实施例提供的手机车联网app查询车况的流程示意图，图7是根据本发明可选实施例提供的手机车辆网app的架构示意图。如图6和图7所示，用户可以
通过手机车联网app主动查询车况，并通过刷新app，通过app的前端ui展示模块查看到车况的最新状态。该过程中，手机车联网app端在检测到车主用户进入到app车况查询界面，首先通知云端平台；云端平台收到通知后，通过远控消息，告知车载通信终端，进行车况信息的高频上报。手机app实现高频刷新车况的逻辑为：物联网网关通过下行消息中间件，接收车联网app的下行消息指令，将最新的车况下发到指定的车内；车联网app端收到最新的车况报文，更新app内置的车况镜像系统，存储最新的车况信息；刷新app的前端ui显示，给用户展示最新的车况信息。
65.可选地，下面提供一种车况消息推送的具体实施例，该实施例的详述流程包括如下的若干个具体流程步骤：
66.(1)车辆上线流程：
67.车载通信终端与云端物联网网关建立长连接；
68.物联网网关识别到连接完成，通过“上行消息中间件”通知“单车车况镜像进程创建/销毁管理模块”；
[0069]“单车车况镜像进程创建/销毁管理模块”接收到上线车辆的vin码后，携带车型的规则配置信息、历史车况等数据，通过进程间通信通知车况镜像系统创建此台车的车况镜像进程；
[0070]
记录此台车的车况进程的进程id；
[0071]
用户进入车联网app车况查询页面流程：
[0072]
用户操作车联网app进入车况查询页面；
[0073]
车联网app与物联网网关建立长连接通信，物联网网关记录app当前长连接通道id和车辆vin码的对应关系；
[0074]
车联网app通过长连接通道通知云端，用户进入车况查询页面；
[0075]
云端收到通知后，通过远控通知功能，通知车载通信终端提高车况上报频率；
[0076]
(2)车况更新流程：
[0077]
上行消息分发引擎，收到最新的车况报文，识别车况报文所属的车辆vin码；
[0078]
通过vin码查找到此台车对应的车况镜像进程id，将最新的报文传给对应的进程；
[0079]
更新进程内存中的历史车况，并存储在数据库中进行持久化；
[0080]
车况镜像进程结合历史车况和最新的车况报文，并根据规则引擎进行车况推送报文识别，例如：门、所等开关量发生变化，油量变化大于5％，进行最新车况推送；
[0081]
将满足规则的车况信息通过进程间通信，通知下行消息分发引擎，下行消息分发引擎通过vin码查找对应的车联网app长连接id，组包后没通过下行消息中间件和物联网网关下发给指定的车联网app；
[0082]
车联网app接收到最新的车况信息后，刷新ui显示信息；
[0083]
(3)车辆下线流程：
[0084]
用户操作车联网app退出车况查询页面；
[0085]
车联网app与物联网网关断开长连接通信；
[0086]
车联网app通知车载通信终端降频上报车况；
[0087]
(4)车辆下线流程：
[0088]
物联网网关识别到连接断开，通过“上行消息中间件”通知“单车车况镜像进程创
建/销毁管理模块”；
[0089]“单车车况镜像进程创建/销毁管理模块”接收到下线车辆的vin码后，通过vin码查询此台车的车况镜像进程id；
[0090]
通过进程间通信通知车况镜像系统销毁此台车的车况镜像进程，释放计算资源。
[0091]
图8是根据本发明实施例提供的数据交互方法二的流程示意图，该方法可以应用于用户的终端中，用户通过终端向云端平台发送查询车辆状态的请求，并期望通过终端查看到车辆的实时状态。如图8所示，该方法包括如下步骤：
[0092]
步骤s802，与云端平台建立可以连续通讯的第一长连接；
[0093]
步骤s804，通过第一长连接向云端平台发送车况实时查询请求，请求云端平台与车辆建立可以连续通讯的第二长连接，并请求云端平台通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；
[0094]
步骤s806，接收车辆通过第二长连接返回的车况信息；
[0095]
步骤s808，通过第一长连接，接收云端平台返回的车况推送信息，其中，车况推送信息为云端平台的目标进程根据车况信息生成，车况信息为云端平台通过第二长连接接收的车辆返回的信息，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端。
[0096]
通过上述步骤，达到了保持用户车辆的车况信息可以持续不断地推送到用户的终端上的目的，从而实现了车辆状态在用户终端设备上的快速实时更新的技术效果，进而解决了车端用户的终端设备接收的车辆的车况推送信息有时不准确的技术问题。
[0097]
需要说明的是，对于前述的各方法实施例，为了简单描述，故将其都表述为一系列的动作组合，但是本领域技术人员应该知悉，本发明并不受所描述的动作顺序的限制，因为依据本发明，某些步骤可以采用其他顺序或者同时进行。其次，本领域技术人员也应该知悉，说明书中所描述的实施例均属于优选实施例，所涉及的动作和模块并不一定是本发明所必须的。
[0098]
通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到根据上述实施例的数据交互方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质(如rom/ram、磁碟、光盘)中，包括若干指令用以使得一台终端设备(可以是手机，计算机，服务器，或者网络设备等)执行本发明各个实施例的方法。
[0099]
根据本发明实施例，还提供了一种用于实施上述数据交互方法一的数据交互装置一，图9是根据本发明实施例提供的数据交互装置一的结构框图，如图9所示，该数据交互装置一包括：第一建立模块91，第二建立模块92，第一接收模块93，生成模块94和发送模块95，下面对该数据交互装置一进行说明。
[0100]
第一建立模块91，用于与终端建立可以连续通讯的第一长连接；
[0101]
第二建立模块92，用于响应所述终端通过所述第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过所述第二长连接向所述车辆发送车况上报指令，其中，所述车况实时查询请求用于请求查询所述车辆的车况；
[0102]
第一接收模块93，用于接收所述车辆通过所述第二长连接返回的车况信息；
[0103]
生成模块94，用于控制目标进程根据所述车况信息生成车况推送信息，其中，所述
目标进程与所述车辆对应，所述目标进程用于将所述车辆的车况信息同步至所述终端；
[0104]
发送模块95，用于通过所述第一长连接向所述终端发送所述车况推送信息。
[0105]
此处需要说明的是，上述第一建立模块91，第二建立模块92，第一接收模块93，生成模块94和发送模块95对应于实施例中的步骤s202至步骤s210，多个模块与对应的步骤所实现的实例和应用场景相同，但不限于上述实施例所公开的内容。需要说明的是，上述模块作为装置的一部分可以运行在实施例提供的计算机终端10中。
[0106]
根据本发明实施例，还提供了一种用于实施上述数据交互方法二的数据交互装置二，图10是根据本发明实施例提供的数据交互装置二的结构框图，如图10所示，该装置包括：第三建立模块12，请求模块14，第二接收模块16和第三接收模块18，下面对该数据交互装置二进行说明。
[0107]
第三建立模块12，用于与云端平台建立可以连续通讯的第一长连接；
[0108]
请求模块14，用于通过第一长连接向云端平台发送车况实时查询请求，请求云端平台与车辆建立可以连续通讯的第二长连接，并请求云端平台通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；
[0109]
第二接收模块16，用于接收车辆通过第二长连接返回的车况信息；
[0110]
第三接收模块18，用于通过第一长连接，接收云端平台返回的车况推送信息，其中，车况推送信息为云端平台的目标进程根据车况信息生成，车况信息为云端平台通过第二长连接接收的车辆返回的信息，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端。
[0111]
此处需要说明的是，上述第三建立模块12，请求模块14，第二接收模块16和第三接收模块18对应于实施例中的步骤s802至步骤s808，多个模块与对应的步骤所实现的实例和应用场景相同，但不限于上述实施例所公开的内容。需要说明的是，上述模块作为装置的一部分可以运行在实施例提供的计算机终端10中。
[0112]
本发明的实施例可以提供一种计算机设备，可选地，在本实施例中，上述计算机设备可以位于计算机网络的多个网络设备中的至少一个网络设备。该计算机设备包括存储器和处理器。
[0113]
其中，存储器可用于存储软件程序以及模块，如本发明实施例中的数据交互方法和装置对应的程序指令/模块，处理器通过运行存储在存储器内的软件程序以及模块，从而执行各种功能应用以及数据处理，即实现上述的数据交互方法。存储器可包括高速随机存储器，还可以包括非易失性存储器，如一个或者多个磁性存储装置、闪存、或者其他非易失性固态存储器。在一些实例中，存储器可进一步包括相对于处理器远程设置的存储器，这些远程存储器可以通过网络连接至计算机终端。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。
[0114]
处理器可以通过传输装置调用存储器存储的信息及应用程序，以执行下述步骤：与终端建立可以连续通讯的第一长连接；响应终端通过第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；接收车辆通过第二长连接返回的车况信息；控制目标进程根据车况信息生成车况推送信息，其中，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端；通过第一长连接向终端发送车况推送信息。
[0115]
可选的，上述处理器还可以执行如下步骤的程序代码：控制目标进程根据车况信息生成车况推送信息之前，还包括：响应车况实时查询请求，创建目标进程，其中，目标进程用于存储车辆的历史车况信息；根据历史车况信息和车况信息生成车况推送信息以及向终端发送车况推送信息。
[0116]
可选的，上述处理器还可以执行如下步骤的程序代码：控制目标进程根据车况信息生成车况推送信息，包括：目标进程比较车况信息以及历史车况信息，得到车况比较结果；在车况比较结果表示车况信息与历史车况信息存在区别的情况下，生成车辆的车况推送信息，其中，车况推送信息用于表示车况信息与历史车况信息的区别。
[0117]
可选的，上述处理器还可以执行如下步骤的程序代码：目标进程比较车况信息以及历史车况信息，得到车况比较结果，包括：目标进程调用规则引擎，基于规则引擎比较车况信息和历史车况信息，得到车况比较结果，其中，规则引擎根据车辆的唯一标识码生成并内置于目标进程中。
[0118]
可选的，上述处理器还可以执行如下步骤的程序代码：响应车况实时查询请求，创建目标进程，包括：根据车况实时查询请求，获取车况实时查询请求对应的车辆的唯一标识码；根据唯一标识码，确定与车辆对应的规则引擎；根据规则引擎，创建目标进程，其中，目标进程采用规则引擎进行数据处理。
[0119]
可选的，上述处理器还可以执行如下步骤的程序代码：接收车辆通过第二长连接返回的车况信息之后，还包括：将车况信息存入目标进程的内存空间。
[0120]
处理器可以通过传输装置调用存储器存储的信息及应用程序，以执行下述步骤：与云端平台建立可以连续通讯的第一长连接；通过第一长连接向云端平台发送车况实时查询请求，请求云端平台与车辆建立可以连续通讯的第二长连接，并请求云端平台通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；接收车辆通过第二长连接返回的车况信息；通过第一长连接，接收云端平台返回的车况推送信息，其中，车况推送信息为云端平台的目标进程根据车况信息生成，车况信息为云端平台通过第二长连接接收的车辆返回的信息，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端。
[0121]
本领域普通技术人员可以理解上述实施例的各种方法中的全部或部分步骤是可以通过程序来指令终端设备相关的硬件来完成，该程序可以存储于一非易失性存储介质中，存储介质可以包括：闪存盘、只读存储器(read-only memory，rom)、随机存取器(random access memory，ram)、磁盘或光盘等。
[0122]
本发明的实施例还提供了一种非易失性存储介质。可选地，在本实施例中，上述非易失性存储介质可以用于保存上述实施例所提供的数据交互方法所执行的程序代码。
[0123]
可选地，在本实施例中，上述非易失性存储介质可以位于计算机网络中计算机终端群中的任意一个计算机终端中，或者位于移动终端群中的任意一个移动终端中。
[0124]
可选地，在本实施例中，非易失性存储介质被设置为存储用于执行以下步骤的程序代码：与终端建立可以连续通讯的第一长连接；响应终端通过第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；接收车辆通过第二长连接返回的车况信息；控制目标进程根据车况信息生成车况推送信息，其中，目标进程与车辆对
应，目标进程用于将车辆的车况信息同步至终端；通过第一长连接向终端发送车况推送信息。
[0125]
可选地，在本实施例中，非易失性存储介质被设置为存储用于执行以下步骤的程序代码：控制目标进程根据车况信息生成车况推送信息之前，还包括：响应车况实时查询请求，创建目标进程，其中，目标进程用于存储车辆的历史车况信息、根据历史车况信息和车况信息生成车况推送信息以及向终端发送车况推送信息。
[0126]
可选地，在本实施例中，非易失性存储介质被设置为存储用于执行以下步骤的程序代码：控制目标进程根据车况信息生成车况推送信息，包括：目标进程比较车况信息以及历史车况信息，得到车况比较结果；在车况比较结果表示车况信息与历史车况信息存在区别的情况下，生成车辆的车况推送信息，其中，车况推送信息用于表示车况信息与历史车况信息的区别。
[0127]
可选地，在本实施例中，非易失性存储介质被设置为存储用于执行以下步骤的程序代码：目标进程比较车况信息以及历史车况信息，得到车况比较结果，包括：目标进程调用规则引擎，基于规则引擎比较车况信息和历史车况信息，得到车况比较结果，其中，规则引擎根据车辆的唯一标识码生成并内置于目标进程中。
[0128]
可选地，在本实施例中，非易失性存储介质被设置为存储用于执行以下步骤的程序代码：响应车况实时查询请求，创建目标进程，包括：根据车况实时查询请求，获取车况实时查询请求对应的车辆的唯一标识码；根据唯一标识码，确定与车辆对应的规则引擎；根据规则引擎，创建目标进程，其中，目标进程采用规则引擎进行数据处理。
[0129]
可选地，在本实施例中，非易失性存储介质被设置为存储用于执行以下步骤的程序代码：接收车辆通过第二长连接返回的车况信息之后，还包括：将车况信息存入目标进程的内存空间。
[0130]
可选地，在本实施例中，非易失性存储介质被设置为存储用于执行以下步骤的程序代码：与云端平台建立可以连续通讯的第一长连接；通过第一长连接向云端平台发送车况实时查询请求，请求云端平台与车辆建立可以连续通讯的第二长连接，并请求云端平台通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；接收车辆通过第二长连接返回的车况信息；通过第一长连接，接收云端平台返回的车况推送信息，其中，车况推送信息为云端平台的目标进程根据车况信息生成，车况信息为云端平台通过第二长连接接收的车辆返回的信息，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端。
[0131]
上述本发明实施例序号仅仅为了描述，不代表实施例的优劣。
[0132]
在本发明的上述实施例中，对各个实施例的描述都各有侧重，某个实施例中没有详述的部分，可以参见其他实施例的相关描述。
[0133]
在本技术所提供的几个实施例中，应该理解到，所揭露的技术内容，可通过其它的方式实现。其中，以上所描述的装置实施例仅仅是示意性的，例如单元的划分，可以为一种逻辑功能划分，实际实现时可以有另外的划分方式，例如多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，单元或模块的间接耦合或通信连接，可以是电性或其它的形式。
[0134]
作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。
[0135]
另外，在本发明各个实施例中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。
[0136]
集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个非易失性取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可为个人计算机、服务器或者网络设备等)执行本发明各个实施例方法的全部或部分步骤。而前述的存储介质包括：u盘、只读存储器(rom，read-only memory)、随机存取存储器(ram，random access memory)、移动硬盘、磁碟或者光盘等各种可以存储程序代码的介质。
[0137]
以上仅是本发明的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也应视为本发明的保护范围。

技术特征：
1.一种数据交互方法，其特征在于，包括：与终端建立可以连续通讯的第一长连接；响应所述终端通过所述第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过所述第二长连接向所述车辆发送车况上报指令，其中，所述车况实时查询请求用于请求查询所述车辆的车况；接收所述车辆通过所述第二长连接返回的车况信息；控制目标进程根据所述车况信息生成车况推送信息，其中，所述目标进程与所述车辆对应，所述目标进程用于将所述车辆的车况信息同步至所述终端；通过所述第一长连接向所述终端发送所述车况推送信息。2.根据权利要求1所述的方法，其特征在于，所述控制目标进程根据所述车况信息生成车况推送信息之前，还包括：响应所述车况实时查询请求，创建所述目标进程，其中，所述目标进程用于存储所述车辆的历史车况信息；根据所述历史车况信息和所述车况信息生成所述车况推送信息以及向所述终端发送所述车况推送信息。3.根据权利要求2所述的方法，其特征在于，所述控制目标进程根据所述车况信息生成车况推送信息，包括：所述目标进程比较所述车况信息以及所述历史车况信息，得到车况比较结果；在所述车况比较结果表示所述车况信息与所述历史车况信息存在区别的情况下，生成所述车辆的车况推送信息，其中，所述车况推送信息用于表示所述车况信息与所述历史车况信息的区别。4.根据权利要求3所述的方法，其特征在于，所述目标进程比较所述车况信息以及所述历史车况信息，得到车况比较结果，包括：所述目标进程调用规则引擎，基于所述规则引擎比较所述车况信息和所述历史车况信息，得到所述车况比较结果，其中，所述规则引擎根据所述车辆的唯一标识码生成并内置于所述目标进程中。5.根据权利要求4所述的方法，其特征在于，所述响应所述车况实时查询请求，创建所述目标进程，包括：根据所述车况实时查询请求，获取所述车况实时查询请求对应的车辆的唯一标识码；根据所述唯一标识码，确定所述与所述车辆对应的所述规则引擎；根据所述规则引擎，创建所述目标进程，其中，所述目标进程采用所述规则引擎进行数据处理。6.根据权利要求1所述的方法，其特征在于，所述接收所述车辆通过所述第二长连接返回的车况信息之后，还包括：将所述车况信息存入所述目标进程的内存空间。7.一种数据交互方法，其特征在于，包括：与云端平台建立可以连续通讯的第一长连接；通过所述第一长连接向所述云端平台发送车况实时查询请求，请求所述云端平台与车辆建立可以连续通讯的第二长连接，并请求所述云端平台通过所述第二长连接向所述车辆发送车况上报指令，其中，所述车况实时查询请求用于请求查询所述车辆的车况；接收所述车辆通过所述第二长连接返回的车况信息；通过所述第一长连接，接收所述云端平台返回的车况推送信息，其中，所述车况推送信
息为所述云端平台的目标进程根据车况信息生成，所述车况信息为所述云端平台通过所述第二长连接接收的所述车辆返回的信息，所述目标进程与所述车辆对应，所述目标进程用于将所述车辆的车况信息同步至所述终端。8.一种数据交互装置，其特征在于，包括：第一建立模块，用于与终端建立可以连续通讯的第一长连接；第二建立模块，用于响应所述终端通过所述第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过所述第二长连接向所述车辆发送车况上报指令，其中，所述车况实时查询请求用于请求查询所述车辆的车况；第一接收模块，用于接收所述车辆通过所述第二长连接返回的车况信息；生成模块，用于控制目标进程根据所述车况信息生成车况推送信息，其中，所述目标进程与所述车辆对应，所述目标进程用于将所述车辆的车况信息同步至所述终端；发送模块，用于通过所述第一长连接向所述终端发送所述车况推送信息。9.一种非易失性存储介质，其特征在于，所述非易失性存储介质包括存储的程序，其中，在所述程序运行时控制所述非易失性存储介质所在设备执行权利要求1至7中任意一项所述数据交互方法。10.一种计算机设备，其特征在于，所述计算机设备包括存储器和处理器，所述存储器用于存储程序，所述处理器用于运行所述存储器存储的程序，其中，所述程序运行时执行权利要求1至7中任意一项所述数据交互方法。

技术总结
本发明公开了一种数据交互方法、装置、非易失性存储介质及计算机设备。其中，该方法包括：与终端建立可以连续通讯的第一长连接；响应终端通过第一长连接发送的车况实时查询请求，与车辆建立可以连续通讯的第二长连接，并通过第二长连接向车辆发送车况上报指令，其中，车况实时查询请求用于请求查询车辆的车况；接收车辆通过第二长连接返回的车况信息；控制目标进程根据车况信息生成车况推送信息，其中，目标进程与车辆对应，目标进程用于将车辆的车况信息同步至终端；通过第一长连接向终端发送车况推送信息。本发明解决了车端用户的终端设备接收的车辆的车况推送信息有时不准确的技术问题。确的技术问题。确的技术问题。


技术研发人员：王唯正 陈涛 孙玉洋 姜大力 田鹤
受保护的技术使用者：中国第一汽车股份有限公司
技术研发日：2023.03.15
技术公布日：2023/6/27