CN116366619A - 数据传输方法、装置、设备及存储介质 - Google Patents

Abstract

本发明公开了一种数据传输方法、装置、设备及存储介质，属于数据处理技术领域，所述方法包括：在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。相较于现有的轮询方式，本方案中的服务器和终端设备只需要完成一次握手，就可以建立持久性的通信连接，之后双方都可以发送数据，体现了数据传输的实时性，从而可以避免浪费服务器连接资源，提高了数据传输效果。

Description

数据传输方法、装置、设备及存储介质

技术领域

本发明涉及数据处理技术领域，尤其涉及一种数据传输方法、装置、设备及存储介质。

背景技术

在服务器与前端浏览器进行直播数据传输时，需要实现实时数据的推送，之前的技术大部分采用的是轮询，轮询就是浏览器每隔一段时间向服务器发送http请求，然后服务器返回最新的数据给客户端，它分为短轮询和长轮询，短轮询指的是重复的发送http请求，查询目标事件是否完成，缺点为：浪费带宽和服务器资源，长轮询指的是在服务器hold住http请求的时候，等待目标事件发生(保持当前连接等待数据到来或者恰当的超时)，返回http响应。

可见，这两种轮询的共同点为：每次都需要发起请求，才可能获取到结果，它们具有一定的被动性。因此，现有的数据传输方式存在浪费服务器连接资源的问题。

上述内容仅用于辅助理解本发明的技术方案，并不代表承认上述内容是现有技术。

发明内容

本发明的主要目的在于提出一种数据传输方法、装置、设备及存储介质，旨在解决如何避免浪费服务器连接资源的技术问题。

为实现上述目的，本发明提供一种数据传输方法，所述数据传输方法包括：

在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；

在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；

通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

可选地，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备，包括：

检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据；

在所述目标通道中存在数据时，获取所述目标通道中的目标数据；

通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。

可选地，所述检测目标通道中是否存在数据，包括：

获取目标通道对应的目标通道信息；

根据所述目标通道信息确定所述目标通道对应的数据存储状态；

根据所述数据存储状态检测所述目标通道中是否存在数据。

可选地，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备之前，还包括：

进行定时任务协程操作，以检测第二通道中是否存在数据；

在所述第二通道中存在数据时，获取当前时间；

在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据；

将所述第一浏览器数据存入到目标通道中。

可选地，所述获取当前时间之后，还包括：

在所述当前时间符合第二预设时间条件时，从第二预设数据库获取与前端浏览器相关的第二浏览器数据；

将所述第二浏览器数据存入到目标通道中。

可选地，所述获取当前时间之后，还包括：

在所述当前时间符合第三预设时间条件时，关闭所述通信连接。

可选地，所述获取当前时间之后，还包括：

获取上一次数据产生时间；

根据所述当前时间和所述上一次数据产生时间计算间隔时间；

在所述间隔时间超过预设时间时，判定所述当前时间符合第三预设时间条件。

可选地，所述根据所述当前时间和所述上一次数据产生时间计算间隔时间之后，还包括：

在所述间隔时间不超过预设时间时，检测所述当前时间是否为第一预设数值的倍数；

在所述当前时间为所述第一预设数值的倍数时，判定所述当前时间符合第一预设时间条件。

可选地，所述根据所述当前时间和所述上一次数据产生时间计算间隔时间之后，还包括：

在所述间隔时间不超过预设时间时，检测所述当前时间是否为第二预设数值的倍数；

在所述当前时间为所述第二预设数值的倍数时，判定所述当前时间符合第二预设时间条件。

可选地，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备之前，还包括：

进行读协程操作，以检测所述终端设备是否发送了请求信息；

若所述终端设备发送了请求信息，则读取所述终端设备发送的请求信息；

将所述终端设备发送的请求信息存入到第一通道中。

可选地，所述进行读协程操作，以检测所述终端设备是否发送了请求信息之后，还包括：

若所述终端设备没有发送请求信息，则持续等待所述终端设备的请求信息。

可选地，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备之前，还包括：

进行写协程操作，以检测第一通道中是否存在数据，所述第一通道用于存储终端设备发送的请求信息；

在所述第一通道中存在数据时，获取所述第一通道中的第一数据；

检测所述第一数据的数据类型；

在所述数据类型为第一预设类型时，将所述第一数据存入到第二通道中。

可选地，所述检测所述第一数据的数据类型之后，还包括：

在所述数据类型为第二预设类型时，根据所述第一数据进行心跳检测。

可选地，所述检测所述第一数据的数据类型之后，还包括：

在所述数据类型为第三预设类型时，关闭所述通信连接。

此外，为实现上述目的，本发明还提出一种数据传输装置，所述数据传输装置包括：

通信线路模块，用于在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；

通信连接模块，用于在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；

数据发送模块，用于通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

可选地，所述数据发送模块，还用于检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据；在所述目标通道中存在数据时，获取所述目标通道中的目标数据；通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。

可选地，所述数据发送模块，还用于获取目标通道对应的目标通道信息；根据所述目标通道信息确定所述目标通道对应的数据存储状态；根据所述数据存储状态检测所述目标通道中是否存在数据。

可选地，所述数据传输装置，还包括：

定时任务模块，用于进行定时任务协程操作，以检测第二通道中是否存在数据；在所述第二通道中存在数据时，获取当前时间；在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据；将所述第一浏览器数据存入到目标通道中。

此外，为实现上述目的，本发明还提出一种数据传输设备，所述数据传输设备包括：存储器、处理器及存储在所述存储器上并可在所述处理器上运行的数据传输程序，所述数据传输程序被处理器执行时实现如上所述的数据传输方法。

此外，为实现上述目的，本发明还提出一种存储介质，所述存储介质上存储有数据传输程序，所述数据传输程序被处理器执行时实现如上所述的数据传输方法。

本发明提出的数据传输方法中，在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。相较于现有的轮询方式，本方案中的服务器和终端设备只需要完成一次握手，就可以建立持久性的通信连接，之后双方都可以发送数据，体现了数据传输的实时性，从而可以避免浪费服务器连接资源，提高了数据传输效果。

附图说明

图1是本发明实施例方案涉及的硬件运行环境的数据传输设备结构示意图；

图2为本发明数据传输方法第一实施例的流程示意图；

图3为本发明数据传输方法第二实施例的流程示意图；

图4为本发明数据传输方法一实施例的数据传输整体流程示意图；

图5为本发明数据传输方法第三实施例的流程示意图；

图6为本发明数据传输装置第一实施例的功能模块示意图。

本发明目的的实现、功能特点及优点将结合实施例，参照附图做进一步说明。

具体实施方式

应当理解，此处所描述的具体实施例仅仅用以解释本发明，并不用于限定本发明。

参照图1，图1为本发明实施例方案涉及的硬件运行环境的数据传输设备结构示意图。

如图1所示，该数据传输设备可以包括：处理器1001，例如中央处理器(CentralProcessing Unit，CPU)，通信总线1002、用户接口1003，网络接口1004，存储器1005。其中，通信总线1002用于实现这些组件之间的连接通信。用户接口1003可以包括显示屏(Display)、输入单元比如按键，可选用户接口1003还可以包括标准的有线接口、无线接口。网络接口1004可选的可以包括标准的有线接口、无线接口(如Wi-Fi接口)。存储器1005可以是高速随机存取存储器(Random Access Memory，RAM)，也可以是稳定的存储器(non-volatile memory)，例如磁盘存储器。存储器1005可选的还可以是独立于前述处理器1001的存储装置。

本领域技术人员可以理解，图1中示出的设备结构并不构成对数据传输设备的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件布置。

如图1所示，作为一种存储介质的存储器1005中可以包括操作系统、网络通信模块、用户接口模块以及数据传输程序。

在图1所示的数据传输设备中，网络接口1004主要用于连接外网，与其他网络设备进行数据通信；用户接口1003主要用于连接用户设备，与所述用户设备进行数据通信；本发明设备通过处理器1001调用存储器1005中存储的数据传输程序，并执行本发明实施例提供的数据传输方法。

基于上述硬件结构，提出本发明数据传输方法实施例。

参照图2，图2为本发明数据传输方法第一实施例的流程示意图。

在第一实施例中，所述数据传输方法包括：

步骤S10，在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路。

需要说明的是，本实施例的执行主体可为数据传输设备，该数据传输设备可为具有数据处理功能的服务器设备，还可为其他可实现相同或相似功能的设备，本实施例对此不作限制，在本实施例中，以服务器设备为例进行说明。

需要说明的是，本方案可以应用在服务器上，用于服务器与前端浏览器对应的终端设备之间进行数据传输。其中，本方案可适用于多种场景，例如，可将本方案应用在直播数据传输场景、图像数据传输场景以及网页数据传输场景等多种场景，还可将本方案应用在其他类型的场景，本实施例对此不作限制，在本实施例中，以直播数据传输场景为例进行说明。

应当理解的是，在直播数据传输场景下，用户可使用前端浏览器来进行直播观看，因此，前端浏览器需要根据用户选择的直播信息实时从服务器获取直播数据，然后对直播数据进行解析，以向用户展示直播视频。

可以理解的是，针对上述场景下的数据传输，现技术大部分采用的是轮询方式，浏览器每隔一段时间向服务器发送http请求，然后服务器返回最新的数据给客户端。而不管是长轮询还是短轮询，每次都需要浏览器发起请求，才能获取到结果，它们具有一定的被动性，服务器无法主动向浏览器发送数据。因此，通过轮询的方式进行数据传输会浪费服务器连接资源，可能会对服务器性能以及直播效果造成影响，即现有的数据传输方式无法在该场景下达到较好的数据传输效果。

需要说明的是，基于上述问题，本方案不采用轮询的方式进行数据传输，而是采用一种新的方式来进行数据传输，基于该方式，浏览器和服务器只需要完成一次握手，就可以建立持久性的连接，之后双方都可以发送数据，它充分的解决了服务器不能主动向浏览器推送数据的问题，体现了数据传输的实时性。并且，通过该方式还可以控制连接关闭的时间，只要服务器或者客户端的某一方主动关闭连接，就可以自动关闭连接。而且，该方式还有重连机制，当连接不通且还不是关闭状态的时候，会自动进行重连，尽可能的保证双方能够成功发送数据。

应当理解的是，基于上述构思，为了采用该方式来建立服务器与前端浏览器所在的终端设备之间的连接，服务器可持续监听通信请求，在接收到终端设备发送的通信请求时，根据通信请求建立与终端设备之间的通信线路。

可以理解的是，可以将通信线路理解为服务器与终端设备之间的临时通信连接。由于为了保证信息安全，以及达到更好的数据传输效果，本方案中的服务器并非在接收到通信请求之后，就直接建立与终端设备之间用于数据传输的通信连接，而是先只根据通信请求建立与终端设备之间的通信线路，然后再通过该通信线路进行一次握手，在握手成功后，再建立服务器与终端设备之间的通信连接，通过该通信连接可实现服务器与终端设备之间的双向通信。

步骤S20，在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接。

应当理解的是，终端设备和服务器建立通信线路之后，终端设备可发送握手请求，服务器在接收到终端设备通过该通信线路发送的握手请求之后，可根据握手请求反馈握手响应，从而完成终端设备与服务器之间的握手操作，以建立服务器与终端设备之间的通信连接。

可以理解的是，通过上述方式建立了服务器与终端设备之间的通信连接之后，后续的数据交换都可以直接基于该通信连接来实现，不用再重新发送通信请求，节约了带宽资源。并且，该通信连接是双向通信的连接，服务器和/或终端设备均既可以通过该通信连接发送数据，也可以通过该通信连接接收数据，本实施例对此不作限制。

步骤S30，通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

应当理解的是，在服务器与终端设备之间存在上述通信连接的情况下，如果服务器内产生了与前端浏览器相关的数据，那么服务器便可直接将这些与前端浏览器相关的数据通过通信连接发送至终端设备，以使终端设备将这些数据在前端浏览器上进行展示。相较于现有的轮询方式，本方案中的通信连接具有双向通信功能，不需要必须在接收到终端设备的请求的情况下才向其发送数据，可以根据实际情况灵活的通过通信连接向终端设备发送与前端浏览器相关的数据，从而避免了服务器连接资源的浪费，并且可以达到更好的数据传输效果。

在具体实现中，例如，在直播数据传输场景下，用户通过前端浏览器来观看直播，在检测到用户访问直播间时，可以通过上述方式来建立服务器与终端设备之间的通信连接，然后服务器后续便可根据实际情况，将与直播相关的直播数据直接通过该通信连接传输给终端设备，终端设备便可根据接收到的直播数据向用户展示直播内容，从而使后端数据产生之后前端会实时的展现数据，并且服务器资源耗费情况很小。

应当理解的是，除了能够达到上述效果外，本方案中的通信连接还能够灵活关闭连接，即该通信连接既可以由服务器来发起关闭，也可以由终端设备来发起关闭，可以控制连接关闭的时间，只要服务器或者终端设备的某一方主动关闭连接，就可以自动关闭连接。而且，该方式还有重连机制，当连接不通且服务器或者终端设备均未主动关闭通信连接的时候，会自动进行重连，尽可能的保证双方发送数据，避免了数据传输故障的情况。

在本实施例中，在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。相较于现有的轮询方式，本方案中的服务器和终端设备只需要完成一次握手，就可以建立持久性的通信连接，之后双方都可以发送数据，体现了数据传输的实时性，从而可以避免浪费服务器连接资源，提高了数据传输效果。

在一实施例中，如图3所示，基于第一实施例提出本发明数据传输方法第二实施例，所述步骤S30，包括：

步骤S301，检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据。

需要说明的是，本方案可以使用GO语言的协程机制来实现数据传输，可参照图4，图4为数据传输整体流程示意图。在建立服务器与终端设备之间的通信连接之后，本方案的数据传输流程可以分为四大部分，分别为：读协程、写协程、定时任务协程以及输出协程。

需要说明的是，协程是一种比线程更加轻量级的存在，正如一个进程可以拥有多个线程一样，一个线程可以拥有多个协程。因此，一个进程可以由多个线程组成，而一个线程可以由多个协程组成，本实施例对此不作限制。

应当理解的是，本方案中的读协程负责读取终端设备的请求，输出协程负责往终端设备推送数据。写协程以及定时任务协程都是具体负责处理数据逻辑的协程，写协程负责处理终端设备请求的场景，定时任务协程负责处理服务器主动推送的场景，本实施例对此不作限制。

需要说明的是，本方案中包括三个通道(channel)，分别为第一通道(channel-1)、第二通道(channel-2)以及目标通道(channel-3)，其中，目标通道可为用于存储待发送的与前端浏览器相关的数据的通道，第一通道可为用于存储终端设备发送的请求信息的通道，第二通道可以用于存储请求数据的通道，本实施例对此不作限制。

应当理解的是，服务器可进行输出协程操作，以检测目标通道中是否存在数据，在目标通道中存在数据时，将这些数据发送至终端设备，在目标通道中不存在数据时，则继续等待获取数据。

进一步地，为了更加准确地检测目标通道中是否存在数据，提高传输效率，可获取目标通道对应的目标通道信息，根据目标通道信息确定目标通道对应的数据存储状态，进而根据目标通道对应的数据存储状态检测目标通道中是否存在数据。

步骤S302，在所述目标通道中存在数据时，获取所述目标通道中的目标数据。

可以理解的是，在目标通道中存在数据的情况下，说明需要将这些数据发送给终端设备，因此，可在这种情况下，获取目标通道中的数据，并将这些目标通道中的数据称为目标数据。

步骤S303，通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。

应当理解的是，在目标通道中存在数据，且从目标通道中获取目标数据之后，服务器可通过通信连接将目标数据发送至终端设备。终端设备在接收到这些目标数据之后，可将目标数据在前端浏览器上进行展示。

在具体实现中，在目标通道中存在直播数据时，服务器可从目标通道中获取这些目标直播数据，并通过通信连接将目标直播数据发送至终端设备。终端设备在接收到这些目标直播数据之后，可根据目标直播数据在前端浏览器中播放直播。

在本实施例中，检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据；在所述目标通道中存在数据时，获取所述目标通道中的目标数据；通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。从而可及时、主动地通过通信连接将目标通道中的数据发送给终端设备，使终端设备能够及时地进行前端展示，提高了数据传输的及时性。

进一步地，本方案还包括读协程操作，通过读协程来读取终端设备的请求，所述步骤S30之前，还包括：

进行读协程操作，以检测所述终端设备是否发送了请求信息；若所述终端设备发送了请求信息，则读取所述终端设备发送的请求信息；将所述终端设备发送的请求信息存入到第一通道中。

应当理解的是，服务器可进行读协程操作，以检测终端设备是否发送了请求信息，在终端设备发送了请求信息时，读取请求信息，在终端设备没有发送请求信息时，持续等待终端设备的请求信息。

可以理解的是，在终端设备发送了请求信息的情况下，可读取终端设备发送的请求信息，并将终端设备发送的请求信息存入到第一通道中。

进一步地，本方案还包括写协程操作，通过写协程来处理终端设备请求的场景，所述步骤S30之前，还包括：

进行写协程操作，以检测第一通道中是否存在数据，所述第一通道用于存储终端设备发送的请求信息；在所述第一通道中存在数据时，获取所述第一通道中的第一数据；检测所述第一数据的数据类型；在所述数据类型为第一预设类型时，将所述第一数据存入到第二通道中。在所述数据类型为第二预设类型时，根据所述第一数据进行心跳检测。在所述数据类型为第三预设类型时，关闭所述通信连接。

需要说明的是，可参照图4，本实施例中的第一预设类型可为msg类型，第二预设类型可为ping类型，第三预设类型可为close类型。

应当理解的是，服务器可进行写协程操作，以检测第一通道中是否存在数据，在第一通道中存在数据时，可将第一通道中的数据称为第一数据。可获取第一通道中的第一数据，并检测第一数据的数据类型。

在该数据类型为第一数据类型，即第一数据的数据类型为msg类型时，可将第一数据存入到第二通道中，并调用方法返回msg数据，将msg数据存入到目标通道中。

在该数据类型为第二数据类型，即第一数据的数据类型为ping类型时，返回pong，以进行心跳检测。

在该数据类型为第三数据类型，即第一数据的数据类型为close类型时，可关闭所有通道(channel)，并且关闭通信连接(本实施例中将通信连接成为ws)。

在本实施例中，通过上述读写协程以及写协程操作，可以使服务器能够及时读取终端设备的请求信息，并作出相应的反馈，进一步地提高了数据传输的实时性，能够达到更好的数据传输效果。

在一实施例中，如图5所示，基于第一实施例或第二实施例提出本发明数据传输方法第三实施例，在本实施例中，基于第一实施例进行说明，所述步骤S30之前，还包括：

步骤S01，进行定时任务协程操作，以检测第二通道中是否存在数据。

需要说明的是，本方案还包括定时任务协程操作，通过定时任务协程处理服务器主动推送的场景。

应当理解的是，服务器可进行定时任务协程操作，以检测第二通道中是否存在数据，在第二通道中不存在数据的情况下，等待第二通道获取到数据，给定时任务的参数赋值。

步骤S02，在所述第二通道中存在数据时，获取当前时间。

应当理解的是，在第二通道中存在数据的情况下，可获取当前时间，并且获取第二通道对应的上一次数据产生时间，根据当前时间和上一次数据产生时间计算间隔时间。

可以理解的是，可将间隔时间与预设时间进行比较，在间隔时间超过预设时间时，判定当前时间符合第三预设时间条件。其中，预设时间可根据实际情况进行设置，例如，可将预设时间设置为30S，本实施例对此不作限制。在具体实现中，当前时间和上一次数据产生时间的差值超过30S时，判定达到超时时间，即当前时间符合第三预设时间条件。

可以理解的是，在间隔时间不超过预设时间时，可进一步检测当前时间是否为第一预设数值的倍数，在当前时间为第一预设数值的倍数时，判定当前时间符合第一预设时间条件。其中，第一预设数值可根据实际情况进行设置，例如，可将预设时间设置为5S，本实施例对此不作限制。在具体实现中，在当前时间为5S的倍数时，判定当前时间符合第一预设时间条件。

可以理解的是，在间隔时间不超过预设时间时，还可进一步检测当前时间是否为第二预设数值的倍数，在当前时间为第二预设数值的倍数时，判定当前时间符合第二预设时间条件。其中，第二预设数值可根据实际情况进行设置，例如，可将预设时间设置为30S，本实施例对此不作限制。在具体实现中，在当前时间为30S的倍数时，判定当前时间符合第二预设时间条件。

应当理解的是，由于5S的倍数与30S的倍数之间存在重叠部分，因此，为了达到更好的检测效果，本实施例中优选为：先检测当前时间是否为第二预设数值的倍数，然后再检测当前时间是否为第一预设数值的倍数。除此之外，也可为其他检测顺序，本实施例对此不作限制。

步骤S03，在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据。

需要说明的是，本实施例中的第一预设数据库可为redis数据库，还可为其他可实现相同或相似功能的设备，本实施例对此不作限制。在当前时间符合第一预设时间条件的情况下，可从redis数据库获取前端浏览器所需的基本数据，本实施例将其称为第一浏览器数据。

步骤S04，将所述第一浏览器数据存入到目标通道中。

应当理解的是，在得到第一浏览器数据之后，可将第一浏览器数据存入到目标通道中，等待输出协程将目标通道中的数据发送至终端设备。

需要说明的是，本实施例中的第二数据库可为es数据库，还可为其他可实现相同或相似功能的设备，本实施例对此不作限制。在当前时间符合第二预设时间条件的情况下，可从es数据库获取前端浏览器所需的普通数据，本实施例将其称为第二浏览器数据。

应当理解的是，在得到第二浏览器数据之后，可将第二浏览器数据存入到目标通道中，等待输出协程将目标通道中的数据发送至终端设备。

需要说明的是，在当前时间符合第三预设时间条件时，可关闭所有通道，并且关闭通信连接。

在本实施例中，进行定时任务协程操作，以检测第二通道中是否存在数据；在所述第二通道中存在数据时，获取当前时间；在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据；将所述第一浏览器数据存入到目标通道中。从而可通过定时任务协程处理服务器主动推送的场景，获取与前端浏览器相关的数据存入到目标通道中，等待输出协程通过服务器与终端设备之间的通信连接将目标通道中的数据发送至终端设备。

此外，本发明实施例还提出一种存储介质，所述存储介质上存储有数据传输程序，所述数据传输程序被处理器执行时实现如上文所述的数据传输方法的步骤。

由于本存储介质采用了上述所有实施例的全部技术方案，因此至少具有上述实施例的技术方案所带来的所有有益效果，在此不再一一赘述。

此外，参照图6，本发明实施例还提出一种数据传输装置，所述数据传输装置包括：

通信线路模块10，用于在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路。

需要说明的是，本方案可以应用在服务器上，用于服务器与前端浏览器对应的终端设备之间进行数据传输。其中，本方案可适用于多种场景，例如，可将本方案应用在直播数据传输场景、图像数据传输场景以及网页数据传输场景等多种场景，还可将本方案应用在其他类型的场景，本实施例对此不作限制，在本实施例中，以直播数据传输场景为例进行说明。

应当理解的是，在直播数据传输场景下，用户可使用前端浏览器来进行直播观看，因此，前端浏览器需要根据用户选择的直播信息实时从服务器获取直播数据，然后对直播数据进行解析，以向用户展示直播视频。

可以理解的是，针对上述场景下的数据传输，现技术大部分采用的是轮询方式，浏览器每隔一段时间向服务器发送http请求，然后服务器返回最新的数据给客户端。而不管是长轮询还是短轮询，每次都需要浏览器发起请求，才能获取到结果，它们具有一定的被动性，服务器无法主动向浏览器发送数据。因此，通过轮询的方式进行数据传输会浪费服务器连接资源，可能会对服务器性能以及直播效果造成影响，即现有的数据传输方式无法在该场景下达到较好的数据传输效果。

需要说明的是，基于上述问题，本方案不采用轮询的方式进行数据传输，而是采用一种新的方式来进行数据传输，基于该方式，浏览器和服务器只需要完成一次握手，就可以建立持久性的连接，之后双方都可以发送数据，它充分的解决了服务器不能主动向浏览器推送数据的问题，体现了数据传输的实时性。并且，通过该方式还可以控制连接关闭的时间，只要服务器或者客户端的某一方主动关闭连接，就可以自动关闭连接。而且，该方式还有重连机制，当连接不通且还不是关闭状态的时候，会自动进行重连，尽可能的保证双方能够成功发送数据。

应当理解的是，基于上述构思，为了采用该方式来建立服务器与前端浏览器所在的终端设备之间的连接，服务器可持续监听通信请求，在接收到终端设备发送的通信请求时，根据通信请求建立与终端设备之间的通信线路。

可以理解的是，可以将通信线路理解为服务器与终端设备之间的临时通信连接。由于为了保证信息安全，以及达到更好的数据传输效果，本方案中的服务器并非在接收到通信请求之后，就直接建立与终端设备之间用于数据传输的通信连接，而是先只根据通信请求建立与终端设备之间的通信线路，然后再通过该通信线路进行一次握手，在握手成功后，再建立服务器与终端设备之间的通信连接，通过该通信连接可实现服务器与终端设备之间的双向通信。

通信连接模块20，用于在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接。

应当理解的是，终端设备和服务器建立通信线路之后，终端设备可发送握手请求，服务器在接收到终端设备通过该通信线路发送的握手请求之后，可根据握手请求反馈握手响应，从而完成终端设备与服务器之间的握手操作，以建立服务器与终端设备之间的通信连接。

可以理解的是，通过上述方式建立了服务器与终端设备之间的通信连接之后，后续的数据交换都可以直接基于该通信连接来实现，不用再重新发送通信请求，节约了带宽资源。并且，该通信连接是双向通信的连接，服务器和/或终端设备均既可以通过该通信连接发送数据，也可以通过该通信连接接收数据，本实施例对此不作限制。

数据发送模块30，用于通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

应当理解的是，在服务器与终端设备之间存在上述通信连接的情况下，如果服务器内产生了与前端浏览器相关的数据，那么服务器便可直接将这些与前端浏览器相关的数据通过通信连接发送至终端设备，以使终端设备将这些数据在前端浏览器上进行展示。相较于现有的轮询方式，本方案中的通信连接具有双向通信功能，不需要必须在接收到终端设备的请求的情况下才向其发送数据，可以根据实际情况灵活的通过通信连接向终端设备发送与前端浏览器相关的数据，从而避免了服务器连接资源的浪费，并且可以达到更好的数据传输效果。

在具体实现中，例如，在直播数据传输场景下，用户通过前端浏览器来观看直播，在检测到用户访问直播间时，可以通过上述方式来建立服务器与终端设备之间的通信连接，然后服务器后续便可根据实际情况，将与直播相关的直播数据直接通过该通信连接传输给终端设备，终端设备便可根据接收到的直播数据向用户展示直播内容，从而使后端数据产生之后前端会实时的展现数据，并且服务器资源耗费情况很小。

应当理解的是，除了能够达到上述效果外，本方案中的通信连接还能够灵活关闭连接，即该通信连接既可以由服务器来发起关闭，也可以由终端设备来发起关闭，可以控制连接关闭的时间，只要服务器或者终端设备的某一方主动关闭连接，就可以自动关闭连接。而且，该方式还有重连机制，当连接不通且服务器或者终端设备均未主动关闭通信连接的时候，会自动进行重连，尽可能的保证双方发送数据，避免了数据传输故障的情况。

在本实施例中，在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。相较于现有的轮询方式，本方案中的服务器和终端设备只需要完成一次握手，就可以建立持久性的通信连接，之后双方都可以发送数据，体现了数据传输的实时性，从而可以避免浪费服务器连接资源，提高了数据传输效果。

在一实施例中，所述数据发送模块30，还用于检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据；在所述目标通道中存在数据时，获取所述目标通道中的目标数据；通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。

在一实施例中，所述数据发送模块30，还用于获取目标通道对应的目标通道信息；根据所述目标通道信息确定所述目标通道对应的数据存储状态；根据所述数据存储状态检测所述目标通道中是否存在数据。

在一实施例中，所述数据传输装置还包括定时任务模块，用于进行定时任务协程操作，以检测第二通道中是否存在数据；在所述第二通道中存在数据时，获取当前时间；在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据；将所述第一浏览器数据存入到目标通道中。

在一实施例中，所述定时任务模块，还用于在所述当前时间符合第二预设时间条件时，从第二预设数据库获取与前端浏览器相关的第二浏览器数据；将所述第二浏览器数据存入到目标通道中。

在一实施例中，所述定时任务模块，还用于在所述当前时间符合第三预设时间条件时，关闭所述通信连接。

在一实施例中，所述定时任务模块，还用于获取上一次数据产生时间；根据所述当前时间和所述上一次数据产生时间计算间隔时间；在所述间隔时间超过预设时间时，判定所述当前时间符合第三预设时间条件。

在一实施例中，所述定时任务模块，还用于在所述间隔时间不超过预设时间时，检测所述当前时间是否为第一预设数值的倍数；在所述当前时间为所述第一预设数值的倍数时，判定所述当前时间符合第一预设时间条件。

在一实施例中，所述定时任务模块，还用于在所述间隔时间不超过预设时间时，检测所述当前时间是否为第二预设数值的倍数；在所述当前时间为所述第二预设数值的倍数时，判定所述当前时间符合第二预设时间条件。

在一实施例中，所述数据传输装置还包括读协程模块，用于进行读协程操作，以检测所述终端设备是否发送了请求信息；所述终端设备发送了请求信息，则读取所述终端设备发送的请求信息；将所述终端设备发送的请求信息存入到第一通道中。

在一实施例中，所述读协程模块，还用于若所述终端设备没有发送请求信息，则持续等待所述终端设备的请求信息。

在一实施例中，所述数据传输装置还包括写协程模块，用于进行写协程操作，以检测第一通道中是否存在数据，所述第一通道用于存储终端设备发送的请求信息；在所述第一通道中存在数据时，获取所述第一通道中的第一数据；检测所述第一数据的数据类型；在所述数据类型为第一预设类型时，将所述第一数据存入到第二通道中。

在一实施例中，所述写协程模块，还用于在所述数据类型为第二预设类型时，根据所述第一数据进行心跳检测。

在一实施例中，所述写协程模块，还用于在所述数据类型为第三预设类型时，关闭所述通信连接。

在本发明所述数据传输装置的其他实施例或具体实现方法可参照上述各方法实施例，此处不再赘述。

需要说明的是，在本文中，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、物品或者装置不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、物品或者装置所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括该要素的过程、方法、物品或者装置中还存在另外的相同要素。

上述本发明实施例序号仅仅为了描述，不代表实施例的优劣。

通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该估算机软件产品存储在如上所述的一个估算机可读存储介质(如ROM/RAM、磁碟、光盘)中，包括若干指令用以使得一台智能设备(可以是手机，估算机，数据传输设备，或者网络数据传输设备等)执行本发明各个实施例所述的方法。

以上仅为本发明的优选实施例，并非因此限制本发明的专利范围，凡是利用本发明说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本发明的专利保护范围内。

本发明公开了A1、一种数据传输方法，所述数据传输方法包括：

在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；

在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；

通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

A2、如A1所述的数据传输方法，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备，包括：

检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据；

在所述目标通道中存在数据时，获取所述目标通道中的目标数据；

通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。

A3、如A2所述的数据传输方法，所述检测目标通道中是否存在数据，包括：

获取目标通道对应的目标通道信息；

根据所述目标通道信息确定所述目标通道对应的数据存储状态；

根据所述数据存储状态检测所述目标通道中是否存在数据。

A4、如A1所述的数据传输方法，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备之前，还包括：

进行定时任务协程操作，以检测第二通道中是否存在数据；

在所述第二通道中存在数据时，获取当前时间；

在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据；

将所述第一浏览器数据存入到目标通道中。

A5、如A4所述的数据传输方法，所述获取当前时间之后，还包括：

在所述当前时间符合第二预设时间条件时，从第二预设数据库获取与前端浏览器相关的第二浏览器数据；

将所述第二浏览器数据存入到目标通道中。

A6、如A4所述的数据传输方法，所述获取当前时间之后，还包括：

在所述当前时间符合第三预设时间条件时，关闭所述通信连接。

A7、如A4所述的数据传输方法，所述获取当前时间之后，还包括：

获取上一次数据产生时间；

根据所述当前时间和所述上一次数据产生时间计算间隔时间；

在所述间隔时间超过预设时间时，判定所述当前时间符合第三预设时间条件。

A8、如A7所述的数据传输方法，所述根据所述当前时间和所述上一次数据产生时间计算间隔时间之后，还包括：

在所述间隔时间不超过预设时间时，检测所述当前时间是否为第一预设数值的倍数；

在所述当前时间为所述第一预设数值的倍数时，判定所述当前时间符合第一预设时间条件。

A9、如A7所述的数据传输方法，所述根据所述当前时间和所述上一次数据产生时间计算间隔时间之后，还包括：

在所述间隔时间不超过预设时间时，检测所述当前时间是否为第二预设数值的倍数；

在所述当前时间为所述第二预设数值的倍数时，判定所述当前时间符合第二预设时间条件。

A10、如A1至A9中任一项所述的数据传输方法，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备之前，还包括：

进行读协程操作，以检测所述终端设备是否发送了请求信息；

若所述终端设备发送了请求信息，则读取所述终端设备发送的请求信息；

将所述终端设备发送的请求信息存入到第一通道中。

A11、如A10所述的数据传输方法，所述进行读协程操作，以检测所述终端设备是否发送了请求信息之后，还包括：

若所述终端设备没有发送请求信息，则持续等待所述终端设备的请求信息。

A12、如A1至A9中任一项所述的数据传输方法，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备之前，还包括：

进行写协程操作，以检测第一通道中是否存在数据，所述第一通道用于存储终端设备发送的请求信息；

在所述第一通道中存在数据时，获取所述第一通道中的第一数据；

检测所述第一数据的数据类型；

在所述数据类型为第一预设类型时，将所述第一数据存入到第二通道中。

A13、如A12所述的数据传输方法，所述检测所述第一数据的数据类型之后，还包括：

在所述数据类型为第二预设类型时，根据所述第一数据进行心跳检测。

A14、如A12所述的数据传输方法，所述检测所述第一数据的数据类型之后，还包括：

在所述数据类型为第三预设类型时，关闭所述通信连接。

本发明还公开了B15、一种数据传输装置，所述数据传输装置包括：

通信线路模块，用于在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；

通信连接模块，用于在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；

数据发送模块，用于通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

B16、如B15所述的数据传输装置，所述数据发送模块，还用于检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据；在所述目标通道中存在数据时，获取所述目标通道中的目标数据；通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。

B17、如B16所述的数据传输装置，所述数据发送模块，还用于获取目标通道对应的目标通道信息；根据所述目标通道信息确定所述目标通道对应的数据存储状态；根据所述数据存储状态检测所述目标通道中是否存在数据。

B18、如B15所述的数据传输装置，所述数据传输装置，还包括：

定时任务模块，用于进行定时任务协程操作，以检测第二通道中是否存在数据；在所述第二通道中存在数据时，获取当前时间；在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据；将所述第一浏览器数据存入到目标通道中。

本发明还公开了C19、一种数据传输设备，所述数据传输设备包括：存储器、处理器及存储在所述存储器上并可在所述处理器上运行的数据传输程序，所述数据传输程序被处理器执行时实现如上所述的数据传输方法。

本发明还公开了D20、一种存储介质，所述存储介质上存储有数据传输程序，所述数据传输程序被处理器执行时实现如上述的数据传输方法。

Claims (10)

1.一种数据传输方法，其特征在于，所述数据传输方法包括：

在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；

在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；

通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

2.如权利要求1所述的数据传输方法，其特征在于，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备，包括：

检测目标通道中是否存在数据，所述目标通道用于存储与前端浏览器相关的数据；

在所述目标通道中存在数据时，获取所述目标通道中的目标数据；

通过所述通信连接将所述目标数据发送至所述终端设备，以使所述终端设备将所述目标数据在前端浏览器上进行展示。

3.如权利要求2所述的数据传输方法，其特征在于，所述检测目标通道中是否存在数据，包括：

获取目标通道对应的目标通道信息；

根据所述目标通道信息确定所述目标通道对应的数据存储状态；

根据所述数据存储状态检测所述目标通道中是否存在数据。

4.如权利要求1所述的数据传输方法，其特征在于，所述通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备之前，还包括：

进行定时任务协程操作，以检测第二通道中是否存在数据；

在所述第二通道中存在数据时，获取当前时间；

在所述当前时间符合第一预设时间条件时，从第一预设数据库获取与前端浏览器相关的第一浏览器数据；

将所述第一浏览器数据存入到目标通道中。

5.如权利要求4所述的数据传输方法，其特征在于，所述获取当前时间之后，还包括：

在所述当前时间符合第二预设时间条件时，从第二预设数据库获取与前端浏览器相关的第二浏览器数据；

将所述第二浏览器数据存入到目标通道中。

6.如权利要求4所述的数据传输方法，其特征在于，所述获取当前时间之后，还包括：

在所述当前时间符合第三预设时间条件时，关闭所述通信连接。

7.如权利要求4所述的数据传输方法，其特征在于，所述获取当前时间之后，还包括：

获取上一次数据产生时间；

根据所述当前时间和所述上一次数据产生时间计算间隔时间；

在所述间隔时间超过预设时间时，判定所述当前时间符合第三预设时间条件。

8.一种数据传输装置，其特征在于，所述数据传输装置包括：

通信线路模块，用于在接收到终端设备发送的通信请求时，根据所述通信请求建立与所述终端设备之间的通信线路；

通信连接模块，用于在接收到所述终端设备通过所述通信线路发送的握手请求时，根据所述握手请求建立与所述终端设备之间的通信连接；

数据发送模块，用于通过所述通信连接将与前端浏览器相关的数据发送至所述终端设备。

9.一种数据传输设备，其特征在于，所述数据传输设备包括：存储器、处理器及存储在所述存储器上并可在所述处理器上运行的数据传输程序，所述数据传输程序被处理器执行时实现如权利要求1至7中任一项所述的数据传输方法。

10.一种存储介质，其特征在于，所述存储介质上存储有数据传输程序，所述数据传输程序被处理器执行时实现如权利要求1至7中任一项所述的数据传输方法。

Images