CN113377507A - 任务处理方法、装置、设备以及计算机可读存储介质 - Google Patents

Abstract

本申请提供了一种任务处理方法、装置、设备以及计算机可读存储介质，用于提供一种更为简洁的、点对点的任务处理请求的传输方式，使得服务进程的应用更为便捷，可为用户提供更好的用户体验。方法包括：在客户端的运行过程中，UE在用户操作的触发下，发起任务处理请求；UE从服务器集合中确定处理任务处理请求的目标服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；UE在TCP协议下，通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

Description

任务处理方法、装置、设备以及计算机可读存储介质

技术领域

本申请涉及互联网领域，具体涉及一种任务处理方法、装置、设备以及计算机可读存储介质。

背景技术

在客户机-服务器(Client-Server，C/S)架构的分布式服务器系统中，不同服务器上可根据为用户提供的各类功能服务部署不同的服务进程，这些服务进程也可称为功能模块、服务器实例等，客户端发起的任务处理请求，可通过服务器系统部署的服务器网关统一处理，分发至对应的服务进程进行响应。

在传输控制协议(Transmission Control Protocol，TCP)的应用场景下，客户端将处理请求以TCP长连接的二进制数据流的形式，传输到服务器网关，由服务器网关解析后，投递到具体的服务器上的服务进程进行处理。

而在现有的相关技术的研究过程中，发明人发现，传统技术中服务器网关的分发处理，是根据任务处理请求的类型标识(Identification，ID)固定分发到配对的服务进程的，然而在实际应用中，服务器系统中可能存在较为复杂、大量的服务进程，经常根据业务状态更新服务进程，这就导致了类型ID与服务进程之间的配对关系需要频繁地进行更新，且对于用户侧的客户端而言，还具有随时响应的特点，因此，这就导致服务进程的应用存在应用不便的问题。

发明内容

本申请提供了一种任务处理方法、装置、设备以及计算机可读存储介质，用于提供一种更为简洁的、点对点的任务处理请求的传输方式，使得服务进程的应用更为便捷，可为用户提供更好的用户体验。

第一方面，本申请提供了一种任务处理方法，方法包括：

在客户端的运行过程中，用户设备UE在用户操作的触发下，发起任务处理请求，任务处理请求用于请求处理目标任务；

UE从服务器集合中确定处理任务处理请求的目标服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

UE在TCP协议下，通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关为服务器集合中用于运行网关服务的服务器，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

结合本申请第一方面，在本申请第一方面第一种可能的实现方式中，UE在TCP协议下，通过服务器网关向目标服务进程传输任务处理请求，包括：

UE将任务处理请求写进消息包的消息本体数据字段中；

UE将目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，写进消息包的头部中的路由数据字段中；

UE将消息包的包体总大小写进头部中的包体总大小字段中；

UE在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，以使得服务器网关以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从接收到的整体的二进制数据流中解析出消息包，并将任务处理请求以及处理协议标识转发至进程标识所标识的目标服务进程。

结合本申请第一方面，在本申请第一方面第二种可能的实现方式中，UE从服务器集合中确定响应任务处理请求的目标服务进程，包括：

UE从本地预先配置的不同服务进程与不同预设任务之间的对应关系中，查询用于处理目标任务的目标服务进程，对应关系是由人工预先配置的，或者，对应关系是预先从服务器网关查询并存储得到的。

结合本申请第一方面，在本申请第一方面第三种可能的实现方式中，UE从服务器集合中确定响应任务处理请求的目标服务进程，包括：

UE通过与服务器网关之间的交互，从服务器网关查询用于处理目标任务的目标服务进程，服务器网关还配置了不同服务进行与不同预设任务之间的对应关系。

第二方面，本申请提供了另一种任务处理方法，方法包括：

服务器网关在TPC协议下接收UE发送的任务处理请求，服务器网关为服务器集合中用于运行网关服务的服务器，任务处理请求是在客户端的运行过程中由UE在用户操作的触发下发起的，任务处理请求用于请求目标服务进程处理目标任务，目标服务进程是UE从服务器集合中确定响应任务处理请求的服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

结合本申请第二方面，在本申请第二方面第一种可能的实现方式中，任务处理请求由UE写进消息包的消息本体数据字段中，消息包的头部中的路由数据字段中写进有目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，头部中的包体总大小字段中写进有消息包的包体总大小，UE将消息包的包体总大小写进头部中的包体总大小字段中，消息包由UE在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，服务器网关在TPC协议下接收UE发送的任务处理请求，包括：

服务器在TCP协议下，接收整体的二进制数据流；

服务器以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从整体的二进制数据流中解析出消息包；

服务器网关向目标服务进程传输任务处理请求，包括：

服务器网关将消息包提取出的任务处理请求以及处理协议标识，转发至进程标识所标识的目标服务进程。

第三方面，本申请提供了一种任务处理装置，装置包括：

发起单元，用于在客户端的运行过程中，UE在用户操作的触发下，发起任务处理请求，任务处理请求用于请求处理目标任务；

确定单元，用于从服务器集合中确定处理任务处理请求的目标服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

传输单元，用于在TCP协议下，通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关为服务器集合中用于运行网关服务的服务器，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

结合本申请第三方面，在本申请第三方面第一种可能的实现方式中，传输单元，具体用于：

将任务处理请求写进消息包的消息本体数据字段中；

将目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，写进消息包的头部中的路由数据字段中；

将消息包的包体总大小写进头部中的包体总大小字段中；

在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，以使得服务器网关以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从接收到的整体的二进制数据流中解析出消息包，并将任务处理请求以及处理协议标识转发至进程标识所标识的目标服务进程。

结合本申请第三方面，在本申请第三方面第二种可能的实现方式中，确定单元，具体用于：

从本地预先配置的不同服务进程与不同预设任务之间的对应关系中，查询用于处理目标任务的目标服务进程，对应关系是由人工预先配置的，或者，对应关系是预先从服务器网关查询并存储得到的。

结合本申请第三方面，在本申请第三方面第三种可能的实现方式中，确定单元，具体用于：

通过与服务器网关之间的交互，从服务器网关查询用于处理目标任务的目标服务进程，服务器网关还配置了不同服务进行与不同预设任务之间的对应关系。

第四方面，本申请提供了一种任务处理装置，装置包括：

接收单元，用于在TPC协议下接收UE发送的任务处理请求，服务器网关为服务器集合中用于运行网关服务的服务器，任务处理请求是在客户端的运行过程中由UE在用户操作的触发下发起的，任务处理请求用于请求目标服务进程处理目标任务，目标服务进程是UE从服务器集合中确定响应任务处理请求的服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

传输单元，用于向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

结合本申请第四方面，在本申请第四方面第一种可能的实现方式中，任务处理请求由UE写进消息包的消息本体数据字段中，消息包的头部中的路由数据字段中写进有目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，头部中的包体总大小字段中写进有消息包的包体总大小，UE将消息包的包体总大小写进头部中的包体总大小字段中，消息包由UE在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，接收单元，具体用于：

在TCP协议下，接收整体的二进制数据流；

以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从整体的二进制数据流中解析出消息包；

传输单元，具体用于：

将消息包提取出的任务处理请求以及处理协议标识，转发至进程标识所标识的目标服务进程。

第五方面，本申请提供了一种任务处理设备，包括处理器和存储器，存储器中存储有计算机程序，处理器调用存储器中的计算机程序时执行本申请第一方面、本申请第一方面任一种可能的实现方式、本申请第二方面或者本申请第二方面任一种可能的实现方式提供的方法。

第六方面，本申请提供了一种计算机可读存储介质，计算机可读存储介质存储有多条指令，指令适于处理器进行加载，以执行本申请第一方面、本申请第一方面任一种可能的实现方式、本申请第二方面或者本申请第二方面任一种可能的实现方式提供的方法。

从以上内容可得出，本申请具有以下的有益效果：

在C/S架构的分布式服务器系统的基础上，若UE与服务器之间采用的TCP协议进行通信，在客户端的运行过程中，UE在用户操作的触发下，发起任务处理请求后，UE从服务器集合中直接确定处理任务处理请求的目标服务进程，再通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，在这任务传输过程中可以发现，由于UE在上报任务处理请求时已经指定了目标服务进程，因此服务器网关可第一时间内交由该目标服务进程进行处理，这提供一种更为简洁的、点对点的任务处理请求的传输方式，使得服务进程的应用更为便捷，客户端可更为自由地、精确地访问服务进程，摆脱传统根据类型ID分配服务进程伴随的僵硬、效率低下且维护不便的问题，可为用户提供更好的用户体验。

附图说明

为了更清楚地说明本申请实施例中的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本申请的一些实施例，对于本领域技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

图1为本申请任务处理方法的一种流程示意图；

图2为本申请消息包的一种结构示意图；

图3为本申请路由数据字段的一种结构示意图；

图4为本申请服务器网关的一种场景示意图；

图5为本申请任务处理方法的另一种流程示意图；

图6为本申请任务处理装置的一种结构示意图；

图7为本申请任务处理装置的另一种结构示意图；

图8为本申请任务处理设备的一种结构示意图。

具体实施方式

下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本申请一部分实施例，而不是全部的实施例。基于本申请中的实施例，本领域技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本申请保护的范围。

本申请的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便这里描述的实施例能够以除了在这里图示或描述的内容以外的顺序实施。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或模块的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或模块，而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或模块。在本申请中出现的对步骤进行的命名或者编号，并不意味着必须按照命名或者编号所指示的时间/逻辑先后顺序执行方法流程中的步骤，已经命名或者编号的流程步骤可以根据要实现的技术目的变更执行次序，只要能达到相同或者相类似的技术效果即可。

本申请中所出现的模块的划分，是一种逻辑上的划分，实际应用中实现时可以有另外的划分方式，例如多个模块可以结合成或集成在另一个系统中，或一些特征可以忽略，或不执行，另外，所显示的或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，模块之间的间接耦合或通信连接可以是电性或其他类似的形式，本申请中均不作限定。并且，作为分离部件说明的模块或子模块可以是也可以不是物理上的分离，可以是也可以不是物理模块，或者可以分布到多个电路模块中，可以根据实际的需要选择其中的部分或全部模块来实现本申请方案的目的。

在介绍本申请提供的方法之前，首先介绍本申请所涉及的背景内容。

本申请提供的任务处理方法、装置以及计算机可读存储介质，可应用于任务处理设备，用于提供一种更为简洁的、点对点的任务处理请求的传输方式，使得服务进程的应用更为便捷，可为用户提供更好的用户体验。

本申请提及的任务处理方法，其执行主体可以为任务处理装置，或者集成了该任务处理装置的服务器、物理主机或者用户设备(User Equipment，UE)等设备，在C/S架构下的功能分类，具体可分为客户机以及服务器。其中，任务处理装置可以采用硬件或者软件的方式实现，UE具体可以为智能手机、平板电脑、笔记本电脑、台式电脑或者个人数字助理(Personal Digital Assistant，PDA)等终端设备，任务处理设备还可以通过设备集群的方式设置。

下面，开始介绍本申请提供的任务处理方法。

首先，参阅图1，图1示出了本申请任务处理方法的一种流程示意图，本申请提供的任务处理方法，具体可包括如下步骤：

步骤S101，在客户端的运行过程中，UE在用户操作的触发下，发起任务处理请求，任务处理请求用于请求处理目标任务；

步骤S102，UE从服务器集合中确定处理任务处理请求的目标服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

步骤S103，UE在TCP协议下，通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关为服务器集合中用于运行网关服务的服务器，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

从图1所示实施例可看出，在C/S架构的分布式服务器系统的基础上，若UE与服务器之间采用的TCP协议进行通信，在客户端的运行过程中，UE在用户操作的触发下，发起任务处理请求后，UE从服务器集合中直接确定处理任务处理请求的目标服务进程，再通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，在这任务传输过程中可以发现，由于UE在上报任务处理请求时已经指定了目标服务进程，因此服务器网关可第一时间内交由该目标服务进程进行处理，这提供一种更为简洁的、点对点的任务处理请求的传输方式，使得服务进程的应用更为便捷，客户端可更为自由地、精确地访问服务进程，摆脱传统根据类型ID分配服务进程伴随的僵硬、效率低下且维护不便的问题，可为用户提供更好的用户体验。

下面则对上述图1所示实施例的各个步骤及其在实际应用中可能的实现方式进行详细阐述。

在本申请中，任务处理请求的处理是在C/S架构下进行的，该任务处理请求所请求处理的目标任务，为客户端在运行过程中需要结合云端的服务器进行处理的任务，其任务类型具体可随客户端或者说应用程序(Application，APP)的功能而定。

例如典型地需要实时进行较大量级的数字计算的网络游戏，在游戏运行过程中，需要计算实时的角色能力数值、伤害输出数值等，在这过程中，对于处理效率具有较高的要求，以满足广大玩家的正常游戏体验。

而在传统的任务处理方式下，若服务器侧采用任务处理请求的类型ID来分配对应的服务进程、功能模块或者说服务器实例，则由于网络游戏这类经常根据业务状态更新服务进程的应用频繁更新的特性，存在了类型ID与服务进程之间的配对关系频繁更新的情况，这就有很有可能时不时出现更新异常或者未及时更新导致任务分配异常的事件，尤其对于要求随时响应的应用来说，会直接影响到用户体验。

而本申请针对该问题，则提出了一种更为简洁的、点对点的任务处理请求的传输方式，使得客户端发起的任务处理请求，可自由且精确地指定负责处理的目标服务进程，如此对于服务器网关而言，在身份验证通过后，则可转发至具体服务器上的目标服务进程进行响应，使得服务进程的应用更为便捷。

具体的，当UE运行客户端时，在客户端的运行过程中，在用户操作的触发下，可根据当前的应用运行需求发起对应的任务处理请求。

触发发起任务处理请求的用户操作与任务处理请求之间，可以理解，在实际应用中，可以为一对一的对应关系，以网络游戏为例，若用户点击更换游戏角色的虚拟装备物品，则需要更新角色的当前能力值，此时，显然针对该跟换的虚拟装备物品，可发起一能力值更新请求进行能力值的更新。

另一方面，还存在着触发发起任务处理请求的用户操作与任务处理请求之间，还可能是更为复杂的对应关系，例如，仍以网络游戏为例，用户可通过点击触发游戏执行一系列自动发起的事件，此时，则会发起不同的任务处理请求，以响应这些事件。

在获取到所需处理的任务处理请求时，本申请则由UE主动确定处理当前任务处理请求的目标服务进程。

具体的，可根据任务处理需求、业务需求等条件，进行目标服务进程的确定。

在这过程中，具体可通过查询的方式进行目标服务进程的确定。

第一种，从服务器网关处查询

即，UE通过与所述服务器网关之间的交互，从服务器网关查询用于处理目标任务的目标服务进程，服务器网关配置了不同服务进行与不同预设任务之间的对应关系。

可以理解，可预先服务器网关配置不同服务进行与不同预设任务之间的对应关系，如此，可在线进行目标服务进程的确定。

该对应关系，可以通过表的形式配置，方便读写。

该对应关系，可以根据历史任务处理请求的分配记录统计得到，也可以由工作人员直接写入，甚至在极端情况下还可以为实时从不同的服务进程中按照适配原则挑选出来的。

第二种，本地查询

即，UE从本地预先配置的不同服务进程与不同预设任务之间的对应关系中，查询用于处理目标任务的所述目标服务进程，对应关系是由人工预先配置的，或者，对应关系是预先从所述服务器网关查询并存储得到的。

UE本地或者说客户端本地预先配置的不同服务进程与不同预设任务之间的对应关系，可以是在人工方式先预先配置的，例如用户可手动从官网下载并配置，或者用户也可以触发客户端更新的同时进行该对应关系的下载、更新，或者用户还可以触发客户端下载、更新该对应关系。

或者，该对应关系还可以是从服务器网关处查询得到的，服务器网关可采用上述第一种查询方式中提及的获取方式获取得到该对应关系。

可以理解的是，本申请所提及的不同服务进程与不同预设任务之间的对应关系，不仅可以是服务进程与预设任务之间点对点的配对关系，还可以存在服务进程与预设任务之间点对面的配对关系，或者服务进程与预设任务之间面对点的配对关系，如此，允许一定的调节范围，可采用顺序、随机等方式挑选出适配的目标服务进程。

可以理解，上述提及的第一种查询方式，对于客户端的服务提供方，例如网络游戏的运营商，具有维护方便的特点，而对于上述提及的第二种查询方式，则在实际应用中容易取得更快的处理速度，这对于响应要求高的客户端服务，显然具有更好的应用价值以及用户体验。

与此同时应当注意到的是，本申请除了是在C/S架构的分布式服务器系统的基础上提出的，还是在TCP协议的基础上提出的，在客户端与服务器之间的通信传输过程中，所传输的数据是以TCP长连接二进制数据流的形式存在的。

而针对该通信传输方式，本申请还考虑了可能出现的粘包问题，进行了进一步的优化设计。

该粘包问题，可以理解为：客户端发送的若干包数据到服务器接收时粘成一包，在服务器的接收缓冲区中，后一包数据的头紧接着前一包数据的尾，不同数据包难以从整体的数据流中准确解析出的情况。

本申请则考虑从任务处理请求转化得到的消息包的头部入手，在数据包的头部配置了路由数据字段以及包体总大小字段，而消息包的消息本体数据字段则可写入实质上想传输的数据。

对应的，针对于任务处理请求的传输，其过程可包括：

UE将任务处理请求写进消息包的消息本体数据字段中；

UE将目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，写进消息包的头部中的路由数据字段中；

UE将消息包的包体总大小写进头部中的包体总大小字段中；

UE在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，以使得服务器网关以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从接收到的整体的二进制数据流中解析出消息包，并将任务处理请求以及处理协议标识转发至进程标识所标识的目标服务进程。

可以理解，对于包括了多个不同的消息包的整体的二进制数据流，服务器网关在接收到该数据流时，由于本申请在消息包的头部的包体总大小字段描述了所属消息包的包体总大小了(可以理解为整个数据包的长度)，因此可以从整体的二进制数据流中，从数据流的起始位置开始，根据每个识别出的包体总大小(上述提及的定位标准)，进行数据流的拆分并解析，即可精确地得到原始的不同消息包。

而在解析出的消息包中，则可从其头部的路由数据字段所描述的目标服务进程的进程标识，确定该消息包携带的任务处理请求所分配的、用于执行的目标服务进程，即可进行任务处理请求的转发。

其中，本申请在路由数据字段中还配置了通过目标服务进程处理任务处理请求的处理协议的协议标识，该处理协议确定了目标服务进程在处理任务处理请求时具体可采用的处理方法。

可以理解，根据该协议标识的设置，对于同一服务进程，还可实现在不同处理协议下的任务处理方式，尤其为客户端提供的更为自由的、精确的选择权，因此，客户端对于服务器侧任务处理请求的处理，还具有更高的管控效果。

从上述内容来看，本申请对于消息包的优化配置，可有效解决网络传输中二进制流的连续数据(即包括了多个的消息包)解析为单个的消息包的粘包问题，实现业务逻辑的消息包完整性验证。

其次，本申请还采用简洁的消息包头，可保证负载业务逻辑的前提下，尽量精简协议数据内容，以保证数据传输的灵活性和网络流量的精简度。

为便于理解，下面则示出一组实例进行举例说明。

参阅图2，图2示出了本申请消息包的一种结构示意图，本申请中的消息包，其头部具体可包括包类型字段、包体总大小字段、路由大小字段、路由数据字段以及消息体数据字段。

此时，包体总大小字段描述的包体总大小，具体则为包含从包头的包类型到包尾序列化的消息内容大小。

具体的，包类型字段所描述的包类型用于描述所属消息包的具体类型，可以为1byte，例如：

0x01表示握手消息，

0x02表示心跳信息，

0x03普通的功能协议，

0x04断开连接的告知。

可根据不同类型确定所属消息包的具体结构，比如0x02类型的心跳包，0x04断开连接，无其他消息路由和消息体，由服务器网关本身维护，无需其他元素，单条消息的大小为1byte，最大化精简数据包内容。

路由大小字段所描述的路由大小用于描述后面的路由数据字段的大小，如单个消息包中的路由大小字段采用1btye的大小描述，故路由数据字段的路由字符串的总大小应控制在0～255个字符之间。

继续参阅图3，图3示出了本申请路由数据字段的一种结构示意图，在图3中，路由数据字段所描述的路由数据称为路由信息字符串，也就是说，路由数据可以采用字符串的形式配置。

该字符串，具体是采用拼接的方式体现的，其中的服务模块(即本申请提及的服务进程、服务器实例)，其名称由服务器定义，分布式服务器系统中的多服务器实例可存在模块名称动态变更的情况，服务器可告知客户端服务于它的对应模块名称。

而实际处理方法，又可称为处理协议方法，可由客户端和服务器协商制定，用于表示此消息具体行为。

服务模块名称与实际处理方法之间，可采用点号进行分割，当然，路由信息字符串为业务内容动态变更，具体大小根据不同业务动态伸缩，由路由大小字段来描述，其涉及内容的组合自由，可兼容各种命名方式。

示例性的，路由信息字符串可以为room1.enterroom，其中room1表示服务器实例名称room1，后面的enterroom协议内容为游戏的进入房间，中间采用点号分割，最终组成标准的路由信息字符串，单个消息的具体传输内容，可以采用流行的json或者ProtocolBuffer等序列化方式。

可以看出，本申请采用了间接的消息包头，动态描述消息包体类型，不同的业务逻辑还可定义不同类型的消息头，动态定义内部数据结构，组合出最精简的消息包数据，灵活、简洁、减少规则维护，同时也节省了网络流量。

继续以消息类型为0x03的业务功能协议为例，服务器网关从网络传输的二进制数据流中，先读取1byte的消息包类型，如果为普通业务协议包，再读取3个字节的消息整体大小，最后通过包体总大小从二进制流中读出单个消息包的数据，此为需要处理的单个请求消息包，解决了网络传输二进制流中常见的粘包问题。

在消息包的解析过程中，结合图4示出的本申请服务器网关的一种场景示意图，服务器网关的处理，可包括：

1.服务器网关从网络传输的二进制流中获得了单个业务消息包的二进制数据，读取消息包中第一个的1byte数据，解析出消息包类型，握手消息、心跳信息、网络断开信息等数据；

2.根据包类型判断是否由网关直接处理，用于维护网络连接、认证和断开等数据，不需要路由到其他服务器实例；

3.如果消息类型是普通的业务信息，则再读出3bytes，解析出整体消息包的大小；

4.读出1byte的路由信息大小；

5.根据4中的大小读出指定大小的路由信息数据；

6.获得路由信息结构，转换成string类型的字符串，通过点号分割算法，获得服务器模块名称和方法名称两个字符串；

7.判断服务器模块名称是否跟本模块名称一致，如果一致在本网关处理；

8.路由模块名称跟网关名称不一致，表明是其他模块，通过服务器拓扑结构找到对应的模块名称，并转发消息到指定模块，找不到指定模块记录日志，并抛弃当前消息，继续读取下一条；

9.通过消息总大小，读出消息体数据，将处理协议的名称和消息体(任务处理请求)发送到指定模块处理。

从上述内容可看出，其主要是以客户端侧的UE，所执行的任务传输方法进行描述的，本申请还提供了以服务器侧的服务器网关所执行的任务传输方法。

参阅图5，图5示出了本申请任务处理方法的另一种流程示意图，在本申请中，任务处理方法还可包括如下步骤：

步骤S501，服务器网关在TPC协议下接收UE发送的任务处理请求，服务器网关为服务器集合中用于运行网关服务的服务器，任务处理请求是在客户端的运行过程中由UE在用户操作的触发下发起的，任务处理请求用于请求目标服务进程处理目标任务，目标服务进程是UE从服务器集合中确定响应任务处理请求的服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

步骤S502，服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

在一种示例性的实现方式中，任务处理请求由UE写进消息包的消息本体数据字段中，消息包的头部中的路由数据字段中写进有目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，头部中的包体总大小字段中写进有消息包的包体总大小，UE将消息包的包体总大小写进头部中的包体总大小字段中，消息包由UE在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，对应的，步骤S501，具体可包括：

服务器在TCP协议下，接收整体的二进制数据流；

服务器以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从整体的二进制数据流中解析出消息包；

步骤S502，具体可包括：

服务器网关将消息包提取出的任务处理请求以及处理协议标识，转发至进程标识所标识的目标服务进程。

可以理解，此处以服务器网关出发提出的任务处理方法，其方案所能达到的效果以及具体内容都已体现在了前面以UE提出的任务处理方法的说明中，具体在此不再赘述。

以上是本申请提供任务处理方法的介绍，为便于更好的实施本申请提供的任务处理方法，本申请还提供了任务处理装置。

参阅图6，图6为本申请任务处理装置的另一种结构示意图，在本申请中，装置600具体可包括如下结构：

发起单元601，用于在客户端的运行过程中，UE在用户操作的触发下，发起任务处理请求，任务处理请求用于请求处理目标任务；

确定单元602，用于从服务器集合中确定处理任务处理请求的目标服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

传输单元603，用于在TCP协议下，通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关为服务器集合中用于运行网关服务的服务器，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

在一种示例性的实现方式中，传输单元603，具体用于：

将任务处理请求写进消息包的消息本体数据字段中；

将目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，写进消息包的头部中的路由数据字段中；

将消息包的包体总大小写进头部中的包体总大小字段中；

在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，以使得服务器网关以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从接收到的整体的二进制数据流中解析出消息包，并将任务处理请求以及处理协议标识转发至进程标识所标识的目标服务进程。

在又一种示例性的实现方式中，确定单元602，具体用于：

从本地预先配置的不同服务进程与不同预设任务之间的对应关系中，查询用于处理目标任务的目标服务进程，对应关系是由人工预先配置的，或者，对应关系是预先从服务器网关查询并存储得到的。

在又一种示例性的实现方式中，确定单元602，具体用于：

通过与服务器网关之间的交互，从服务器网关查询用于处理目标任务的目标服务进程，服务器网关还配置了不同服务进行与不同预设任务之间的对应关系。

参阅图7，图7为本申请任务处理装置的另一种结构示意图，在本申请中，装置700具体可包括如下结构：

接收单元701，用于在TPC协议下接收UE发送的任务处理请求，服务器网关为服务器集合中用于运行网关服务的服务器，任务处理请求是在客户端的运行过程中由UE在用户操作的触发下发起的，任务处理请求用于请求目标服务进程处理目标任务，目标服务进程是UE从服务器集合中确定响应任务处理请求的服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

传输单元702，用于向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

在一种示例性的实现方式中，任务处理请求由UE写进消息包的消息本体数据字段中，消息包的头部中的路由数据字段中写进有目标服务进程的进程标识以及通过目标服务进程处理任务处理请求的处理协议的协议标识，头部中的包体总大小字段中写进有消息包的包体总大小，UE将消息包的包体总大小写进头部中的包体总大小字段中，消息包由UE在TCP协议下，将消息包转化为二进制数据流，并传输至服务器网关，接收单元701，具体用于：

在TCP协议下，接收整体的二进制数据流；

以包体总大小字段携带的包体总大小为定位标准，将二进制数据流从整体的二进制数据流中解析出消息包；

传输单元702，具体用于：

将消息包提取出的任务处理请求以及处理协议标识，转发至进程标识所标识的目标服务进程。

本申请还提供了任务处理设备，参阅图8，图8示出了本申请任务处理设备的一种结构示意图，具体的，本申请任务处理设备可包括处理器801、存储器802以及输入输出设备803，处理器801用于执行存储器802中存储的计算机程序时实现如图1或5对应实施例中任务处理方法的各步骤；或者，处理器801用于执行存储器802中存储的计算机程序时实现如图6或图7对应实施例中各单元的功能，存储器802用于存储处理器801执行上述图1或5对应实施例中任务处理方法所需的计算机程序。

示例性的，计算机程序可以被分割成一个或多个模块/单元，一个或者多个模块/单元被存储在存储器802中，并由处理器801执行，以完成本申请。一个或多个模块/单元可以是能够完成特定功能的一系列计算机程序指令段，该指令段用于描述计算机程序在计算机装置中的执行过程。

任务处理设备可包括，但不仅限于处理器801、存储器802、输入输出设备803。本领域技术人员可以理解，示意仅仅是任务处理设备的示例，并不构成对任务处理设备的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件，例如任务处理设备还可以包括网络接入设备、总线等，处理器801、存储器802、输入输出设备803等通过总线相连。

处理器801可以是中央处理单元(Central Processing Unit，CPU)，还可以是其他通用处理器、数字信号处理器(Digital Signal Processor，DSP)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现成可编程门阵列(Field-Programmable Gate Array，FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等，处理器是任务处理设备的控制中心，利用各种接口和线路连接整个设备的各个部分。

存储器802可用于存储计算机程序和/或模块，处理器801通过运行或执行存储在存储器802内的计算机程序和/或模块，以及调用存储在存储器802内的数据，实现计算机装置的各种功能。存储器802可主要包括存储程序区和存储数据区，其中，存储程序区可存储操作系统、至少一个功能所需的应用程序等；存储数据区可存储根据任务处理设备的使用所创建的数据等。此外，存储器可以包括高速随机存取存储器，还可以包括非易失性存储器，例如硬盘、内存、插接式硬盘，智能存储卡(Smart Media Card，SMC)，安全数字(SecureDigital，SD)卡，闪存卡(Flash Card)、至少一个磁盘存储器件、闪存器件、或其他易失性固态存储器件。

处理器801用于执行存储器802中存储的计算机程序时，具体可实现以下功能：

在客户端的运行过程中，UE在用户操作的触发下，发起任务处理请求，任务处理请求用于请求处理目标任务；

从服务器集合中确定处理任务处理请求的目标服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

在TCP协议下，通过服务器网关向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关为服务器集合中用于运行网关服务的服务器，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

或者，处理器801用于执行存储器802中存储的计算机程序时，具体可实现以下功能：

在TPC协议下接收UE发送的任务处理请求，服务器网关为服务器集合中用于运行网关服务的服务器，任务处理请求是在客户端的运行过程中由UE在用户操作的触发下发起的，任务处理请求用于请求目标服务进程处理目标任务，目标服务进程是UE从服务器集合中确定响应任务处理请求的服务进程，服务器集合包括不同服务器，服务器集合为采用C/S架构部署的分布式服务器系统，不同服务器通过各自部署的服务进程处理不同任务；

向目标服务进程传输任务处理请求，以使得目标服务进程处理目标任务，服务器网关配置了不同服务进程与不同服务器之间的对应关系。

所属领域的技术人员可以清楚地了解到，为描述的方便和简洁，上述描述的任务处理装置、设备及其相应单元的具体工作过程，可以参考如图1或5对应实施例中任务处理方法的说明，具体在此不再赘述。

本领域普通技术人员可以理解，上述实施例的各种方法中的全部或部分步骤可以通过指令来完成，或通过指令控制相关的硬件来完成，该指令可以存储于一计算机可读存储介质中，并由处理器进行加载和执行。

为此，本申请提供一种计算机可读存储介质，其中存储有多条指令，该指令能够被处理器进行加载，以执行本申请如图1或5对应实施例中任务处理方法中的步骤，具体操作可参考如图1或5对应实施例中任务处理方法的说明，在此不再赘述。

其中，该计算机可读存储介质可以包括：只读存储器(Read Only Memory，ROM)、随机存取记忆体(Random Access Memory，RAM)、磁盘或光盘等。

由于该计算机可读存储介质中所存储的指令，可以执行本申请如图1或5对应实施例任务处理方法中的步骤，因此，可以实现本申请如图1或5对应实施例中任务处理方法所能实现的有益效果，详见前面的说明，在此不再赘述。

以上对本申请提供的任务处理方法、装置、设备以及计算机可读存储介质进行了详细介绍，本文中应用了具体个例对本申请的原理及实施方式进行了阐述，以上实施例的说明只是用于帮助理解本申请的方法及其核心思想；同时，对于本领域的技术人员，依据本申请的思想，在具体实施方式及应用范围上均会有改变之处，综上所述，本说明书内容不应理解为对本申请的限制。

Claims (10)

1.一种任务处理方法，其特征在于，所述方法包括：

在客户端的运行过程中，用户设备UE在用户操作的触发下，发起任务处理请求，所述任务处理请求用于请求处理目标任务；

所述UE从服务器集合中确定处理所述任务处理请求的目标服务进程，所述服务器集合包括不同服务器，所述服务器集合为采用C/S架构部署的分布式服务器系统，所述不同服务器通过各自部署的服务进程处理不同任务；

所述UE在TCP协议下，通过服务器网关向所述目标服务进程传输所述任务处理请求，以使得所述目标服务进程处理所述目标任务，所述服务器网关为所述服务器集合中用于运行网关服务的服务器，所述服务器网关配置了不同服务进程与所述不同服务器之间的对应关系。

2.根据权利要求1所述的方法，其特征在于，所述UE在TCP协议下，通过服务器网关向所述目标服务进程传输所述任务处理请求，包括：

所述UE将所述任务处理请求写进消息包的消息本体数据字段中；

所述UE将所述目标服务进程的进程标识以及通过所述目标服务进程处理所述任务处理请求的处理协议的协议标识，写进消息包的头部中的路由数据字段中；

所述UE将所述消息包的包体总大小写进所述头部中的包体总大小字段中；

所述UE在TCP协议下，将所述消息包转化为二进制数据流，并传输至所述服务器网关，以使得所述服务器网关以所述包体总大小字段携带的所述包体总大小为定位标准，将所述二进制数据流从接收到的整体的二进制数据流中解析出所述消息包，并将所述任务处理请求以及所述处理协议标识转发至所述进程标识所标识的所述目标服务进程。

3.根据权利要求1所述的方法，其特征在于，所述UE从服务器集合中确定响应所述任务处理请求的目标服务进程，包括：

所述UE从本地预先配置的不同服务进程与不同预设任务之间的对应关系中，查询用于处理所述目标任务的所述目标服务进程，所述对应关系是由人工预先配置的，或者，所述对应关系是预先从所述服务器网关查询并存储得到的。

4.根据权利要求1所述的方法，其特征在于，所述UE从服务器集合中确定响应所述任务处理请求的目标服务进程，包括：

所述UE通过与所述服务器网关之间的交互，从所述服务器网关查询用于处理所述目标任务的所述目标服务进程，所述服务器网关还配置了不同服务进行与不同预设任务之间的对应关系。

5.一种任务处理方法，其特征在于，所述方法包括：

服务器网关在TPC协议下接收用户设备UE发送的任务处理请求，所述服务器网关为所述服务器集合中用于运行网关服务的服务器，所述任务处理请求是在客户端的运行过程中由UE在用户操作的触发下发起的，所述任务处理请求用于请求目标服务进程处理目标任务，所述目标服务进程是所述UE从服务器集合中确定响应所述任务处理请求的服务进程，所述服务器集合包括不同服务器，所述服务器集合为采用C/S架构部署的分布式服务器系统，所述不同服务器通过各自部署的服务进程处理不同任务；

所述服务器网关向所述目标服务进程传输所述任务处理请求，以使得所述目标服务进程处理所述目标任务，所述服务器网关配置了不同服务进程与所述不同服务器之间的对应关系。

6.根据权利要求5所述的方法，其特征在于，所述任务处理请求由所述UE写进消息包的消息本体数据字段中，所述消息包的头部中的路由数据字段中写进有所述目标服务进程的进程标识以及通过所述目标服务进程处理所述任务处理请求的处理协议的协议标识，所述头部中的包体总大小字段中写进有所述消息包的包体总大小，所述UE将所述消息包的包体总大小写进所述头部中的包体总大小字段中，所述消息包由所述UE在TCP协议下，将所述消息包转化为二进制数据流，并传输至所述服务器网关，所述服务器网关在TPC协议下接收UE发送的任务处理请求，包括：

所述服务器在TCP协议下，接收整体的二进制数据流；

所述服务器以所述包体总大小字段携带的所述包体总大小为定位标准，将所述二进制数据流从所述整体的二进制数据流中解析出所述消息包；

所述服务器网关向所述目标服务进程传输所述任务处理请求，包括：

所述服务器网关将所述消息包提取出的所述任务处理请求以及所述处理协议标识，转发至所述进程标识所标识的所述目标服务进程。

7.一种任务处理装置，其特征在于，所述装置包括：

发起单元，用于在客户端的运行过程中，用户设备UE在用户操作的触发下，发起任务处理请求，所述任务处理请求用于请求处理目标任务；

确定单元，用于从服务器集合中确定处理所述任务处理请求的目标服务进程，所述服务器集合包括不同服务器，所述服务器集合为采用C/S架构部署的分布式服务器系统，所述不同服务器通过各自部署的服务进程处理不同任务；

传输单元，用于在TCP协议下，通过服务器网关向所述目标服务进程传输所述任务处理请求，以使得所述目标服务进程处理所述目标任务，所述服务器网关为所述服务器集合中用于运行网关服务的服务器，所述服务器网关配置了不同服务进程与所述不同服务器之间的对应关系。

8.一种任务处理装置，其特征在于，所述装置包括：

接收单元，用于在TPC协议下接收用户设备UE发送的任务处理请求，所述服务器网关为所述服务器集合中用于运行网关服务的服务器，所述任务处理请求是在客户端的运行过程中由UE在用户操作的触发下发起的，所述任务处理请求用于请求目标服务进程处理目标任务，所述目标服务进程是所述UE从服务器集合中确定响应所述任务处理请求的服务进程，所述服务器集合包括不同服务器，所述服务器集合为采用C/S架构部署的分布式服务器系统，所述不同服务器通过各自部署的服务进程处理不同任务；

传输单元，用于向所述目标服务进程传输所述任务处理请求，以使得所述目标服务进程处理所述目标任务，所述服务器网关配置了不同服务进程与所述不同服务器之间的对应关系。

9.一种任务处理设备，其特征在于，包括处理器和存储器，所述存储器中存储有计算机程序，所述处理器调用所述存储器中的计算机程序时执行如权利要求1至6任一项所述的方法。

10.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质存储有多条指令，所述指令适于处理器进行加载，以执行权利要求1至7任一项所述的方法。

Images