CN108733698B - 一种日志消息的处理方法及后台服务系统 - Google Patents

Abstract

本发明公开了一种日志消息的处理方法及后台服务系统，能够提高对有问题的服务节点的定位效率。本发明实施例方法包括：后台服务系统接收远程终端发送的第一远程过程调用协议RPC消息；若所述第一RPC消息符合预置条件，则所述后台服务系统根据所述第一RPC消息在所述第一RPC消息中设置目标标识，得到第二RPC消息，所述目标标识用于当所述第二RPC消息被传输至所述后台服务系统的各服务节点时，对各服务节点的时序进行标记；对于各服务节点，当所述第二RPC消息被传输至该服务节点时，所述后台服务系统根据所述第二RPC消息以及获取到的所述第二RPC消息的当前调用信息生成固定格式的日志消息；所述后台服务系统根据所述日志消息创建具有所述时序的有向无环图。

Description

一种日志消息的处理方法及后台服务系统

技术领域

本发明涉及计算机技术领域，尤其涉及一种日志消息的处理方法及后台服务系统。

背景技术

远程过程调用协议(Remote Procedure Call，RPC)，指的是一种通过网络从远程计算器程序上请求服务，而不需要了解底层网络技术的协议。比如，两台服务器A和B，一个应用部署在A服务器上，想要调用B服务器上应用提供的函数或方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。

现有方案根据该RPC协议提供了一种日志消息的处理方法，具体的：远程终端接入的后台服务系统的初始服务节点对符合条件的RPC消息设置染色标记后，将设置有染色标记的RPC消息传递到下游服务节点，进而该RPC消息经过的各服务节点上报无固定格式的日志消息到后台服务系统中的日志服务器中，日志服务器根据日志消息构建有向无环图(directed acycline praph，DAG)，并且将日志消息集中存储到磁盘文件中。

然而，由于各服务节点的时间不是同步的，所以依赖各服务节点的时间来确定RPC消息在各服务节点的时序是不可靠的，导致不能准确展示RPC消息的业务逻辑流程，从而现有方案中所构建的DAG图的时序关系不准确，进而不能通过该DAG图有效定位有问题的服务节点。

发明内容

本发明实施例提供了一种日志消息的处理方法及后台服务系统，能够提高对有问题的服务节点的定位效率。。

有鉴于此，本发明实施例第一方面提供了一种日志消息的处理方法，可包括：

后台服务系统接收远程终端发送的第一远程过程调用协议RPC消息；

若所述第一RPC消息符合预置条件，则所述后台服务系统根据所述第一RPC消息在所述第一RPC消息中设置目标标识，得到第二RPC消息，所述目标标识用于当所述第二RPC消息被传输至所述后台服务系统的各服务节点时，对各服务节点的时序进行标记；

对于各服务节点，当所述第二RPC消息被传输至该服务节点时，所述后台服务系统根据所述第二RPC消息以及获取到的所述第二RPC消息的当前调用信息生成固定格式的日志消息；

所述后台服务系统根据所述日志消息创建具有所述时序的有向无环图。

本发明实施例第二方面提供了一种后台服务系统，可包括：

接收模块，用于接收远程终端发送的第一远程过程调用协议RPC消息；

设置模块，用于若所述第一RPC消息符合预置条件，则根据所述第一RPC消息在所述第一RPC消息中设置目标标识，得到第二RPC消息，所述目标标识用于当所述第二RPC消息被传输至所述后台服务系统的各服务节点时，对各服务节点的时序进行标记；

生成模块，用于对于各服务节点，当所述第二RPC消息被传输至该服务节点时，根据所述第二RPC消息以及获取到的所述第二RPC消息的当前调用信息生成固定格式的日志消息；

创建模块，用于根据所述日志消息创建具有所述时序的有向无环图。

本发明实施例第三方面提供了一种后台服务系统，可包括：接收器、处理器以及存储器；

所述接收器，用于接收远程终端发送的第一远程过程调用协议RPC消息；

所述处理器，用于若所述第一RPC消息符合预置条件，则根据所述第一RPC消息在所述第一RPC消息中设置目标标识，得到第二RPC消息，所述目标标识用于当所述第二RPC消息被传输至所述后台服务系统的各服务节点时，对各服务节点的时序进行标记；对于各服务节点，当所述第二RPC消息被传输至该服务节点时，根据所述第二RPC消息以及获取到的所述第二RPC消息的当前调用信息生成固定格式的日志消息；根据所述日志消息创建具有所述时序的有向无环图。

所述存储器，用于存储所述处理器执行相应的操作所需的代码。

本发明实施例第四方面提供了一种计算机存储介质，其上存储有计算机程序，其特征在于，该程序被处理器执行时实现如本发明实施例第一方面所述方法的步骤。

从以上技术方案可以看出，本发明实施例具有以下优点：由于第二RPC消息中的目标标识可以用于当第二RPC消息被传输至后台服务系统的各服务节点时，对各服务节点的时序进行标记，所以在对第二RPC消息以及相应的调用信息生成日志消息后，通过日志消息能够构建出带有时序的有向无环图，从而在有向无环图的时序关系准确的情况下，能够提高对有问题的服务节点的定位效率。

附图说明

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

图1为本发明实施例提供的一种RPC调用的工作原理示意图；

图2为本发明实施例提供的一种后台服务系统结构图；

图3为本发明实施例提供的一种日志消息的处理方法流程示意图；

图4为本发明实施例中日志消息的处理方法一个实施例示意图；

图5-a为本发明实施例提供的一种服务节点正常调用的有向无环图；

图5-b为本发明实施例提供的一种服务节点非正常调用的有向无环图；

图6为本发明实施例中日志消息的处理方法另一个实施例示意图；

图7为本发明实施例中后台服务系统一个实施例示意图；

图8为本发明实施例中后台服务系统另一个实施例示意图；

图9为本发明实施例中后台服务系统另一个实施例示意图。

具体实施方式

本发明实施例提供了一种日志消息的处理方法及后台服务系统，能够提高对有问题的服务节点的定位效率。。

本发明的说明书和权利要求书及上述附图中的术语“第一”、“第二”、“第三”、“第四”等(如果存在)是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便这里描述的本发明的实施例例如能够以除了在这里图示或描述的那些以外的顺序实施。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元，而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。

为便于理解，首先对本发明实施例中可能涉及到的名词进行解释说明：

染色：对符合条件的RPC消息赋予特殊标记，该标记会在RPC消息经过的服务节点之间传递，由此与其他普通消息区分开来。

调用链：服务节点之间的逐层调用关系，每一层仅有一个节点。

DAG：有向无环图，服务节点之间的多级调用关系，每一层有1到多个节点，形成树形调用关系。

全局唯一标识(global unique identifier，GUID)：全局唯一的用户标识(Identifier，ID)。

进一步的，下面对本发明实施例中的RPC调用的工作原理进行说明，请参阅图1，图1为本发明实施例提供的一种RPC调用的工作原理示意图，如图1所示，包括如下步骤：

步骤(1)：调用客户端句柄；执行传送参数；

步骤(2)：调用本地内核以发送消息；

步骤(3)：消息传送到远程内核；

步骤(4)：服务器句柄得到消息并取得参数；

步骤(5)：向服务器中的函数请求执行远程过程；

步骤(6)：执行之后，将结果返回服务器句柄；

步骤(7)：服务器句柄返回结果，调用远程内核；

步骤(8)：将结果传回本地内核；

步骤(9)：客户端句柄接收本地内核发送的结果；

步骤(10)：客户端中的函数接收客户端句柄返回的结果。

上面介绍了本发明实施例中的RPC调用的工作原理，下面介绍下本发明实施例中的后台服务系统，如图2所示，图2为本发明实施例提供的一种后台服务系统结构图，该后台服务系统可以包括接入服务节点、该接入服务节点的下游服务节点以及日志服务节点，需要说明的是，下游服务节点的个数可以为一个，也可以为至少两个，此处不作限定。此外，该后台服务系统还可以包括一个数据库，该数据库用于存储日志数据。

下面以图2所示的后台服务系统为例，对本发明实施例中的日志消息的处理方法的流程进行说明，具体的，请参阅图3，图3为本发明实施例提供的一种日志消息的处理方法流程示意图。

在图3中，日志消息覆盖的是整个后台服务系统的处理流程，从远程终端发起请求开始，染色RPC消息在各服务节点之间传递，直到本次RPC消息请求处理终止，步骤如下：

步骤1：接入服务节点对RPC消息进行染色，得到染色RPC消息，并通过调用接口来发起请求到服务A，接入服务节点根据染色RPC消息以及调用接口的信息生成固定格式的日志消息，将日志消息上报给日志服务节点。

步骤2：服务节点A发起请求到服务节点B，记录日志消息并上报给日志服务节点。

步骤3：服务节点B接收服务节点A的请求，记录日志消息并上报给日志服务节点，返回请求结果给服务节点A。

步骤4：服务节点A记录服务节点B返回的请求结果，再向服务节点C发起请求，记录日志消息并上报给日志服务节点。

步骤5：服务节点C接收服务节点A的请求，记录日志消息并上报给日志服务节点，返回请求结果给服务节点A。

步骤6：服务节点A记录服务节点C返回的请求结果，记录日志消息并上报给日志服务节点，数据库存储该日志消息。

当本次RPC消息请求处理终止后，日志服务节点收集到完整的调用信息，此时日志服务节点对格式化的日志消息进行DAG分析以构建出可视化的树形调用关系图，在可视化的树形调用关系图中，可以很快定位有问题的服务节点。

请参阅图4，本发明实施例中日志消息的处理方法一个实施例包括：

101、后台服务系统接收远程终端发送的第一远程过程调用协议RPC消息；

本实施例中，当用户需要通过远程终端调用远端的后台服务系统中的服务节点上的应用时，用户可以通过远程终端向后台服务系统发送第一RPC消息。

需要说明的是，在实际应用中，后台服务系统可以同时接收至少两个远程终端发送的RPC消息，此处不作限定。

在一些可能的实施例中，后台服务系统中可以包括接入服务节点，接入服务节点用于接收第一RPC消息。由此，上述后台服务系统接收远程终端发送的第一远程过程调用协议RPC消息可以为：后台服务系统通过接入服务节点接收远程终端发送的第一远程过程调用协议RPC消息。

需要说明的是，接入服务节点是服务节点的树形架构的根节点，远程终端所有的请求发往的第一个服务节点就是接入服务节点。

102、若第一RPC消息符合预置条件，则后台服务系统根据第一RPC消息在第一RPC消息中设置目标标识，得到第二RPC消息，目标标识用于当第二RPC消息被传输至后台服务系统中的各服务节点时，对各服务节点的时序进行标记；

本实施例中，后台服务系统在接收到第一RPC消息后，后台服务系统需要判断第一RPC消息是否符合预置条件，如果第一RPC消息符合预置条件，则后台服务系统会根据第一RPC消息在第一RPC消息中设置目标标识，得到第二RPC消息，其中，目标标识用于当第二RPC消息被传输至后台服务系统的各服务节点时，对各服务节点的时序进行标记。

在一些可能的实施例中，针对第一RPC消息是否符合预置条件给出了如下判定方法，具体的：后台服务器判断第一RPC消息中的全局唯一标识符是否与预设白名单匹配；若匹配，则后台服务系统确定第一RPC消息符合预置条件；或，后台服务器判断第一RPC消息中的国际移动设备标识是否与预设白名单匹配；若匹配，则后台服务系统确定第一RPC消息符合预置条件。

可以理解，后台服务器可以通过第一RPC消息中的全局唯一标识符或国际移动设备标识来进行判定，如果全局唯一标识符或国际移动设备标识命中了白名单，则判断符合预置条件。

需要说明的是，后台服务器还可以采用其他方式判定第一RPC消息是否符合预置条件，此处不作限定。

并且，在一些可能的实施例中，上述后台服务系统根据第一RPC消息在第一RPC消息中设置目标标识可以为：后台服务系统中的接入服务节点根据第一RPC消息在第一RPC消息中设置目标标识，目标标识包括如下至少一种字段：远程终端的请求序列号、第一RPC消息名称、目标标识的调用链层次、各服务节点名称以及日志消息的打印时间。

可见，目标标识可以由多种字段组成，在实际应用中，目标标识的组成字段可以参见表1，如下表1所示，该组成字段可以包括requestId、method、seq、serverName、serverSeq。

103、对于各服务节点，当第二RPC消息被传输至该服务节点时，后台服务系统根据第二RPC消息以及获取到的第二RPC消息的当前调用信息生成固定格式的日志消息；

本实施例中，当第二RPC消息传输到某一个服务节点时，后台服务系统会确定第二RPC消息下一个将要传输到的服务节点，然后生成第二RPC消息的调用信息，最后后台服务系统可以根据第二RPC消息以及该第二RPC消息的调用信息生成固定格式的日志消息。

需要说明的是，日志消息中可以携带有该目标标识。

此外，后台服务系统在生成固定格式的日志消息后，后台服务系统可以通过数据库存储该日志消息，由此，在一些可能的实施例中，还可以包括：后台服务系统按照日志消息的格式存储日志消息，日志消息包括固定字段和可变参数字段。

可见，按照日志消息的格式来存储日志消息，从而不需要再对存储的日志消息进行人工二次筛选，从而提供了一种有效的自动过滤分析方法，完善了本申请技术方案。

可选的，在一些可能的实施例中，上述后台服务系统根据第二RPC消息以及获取到的第二RPC消息的当前调用信息生成固定格式的日志消息可以为：后台服务系统根据第二RPC消息、获取到的第二RPC消息的当前调用信息以及获取到的当前时刻生成固定格式的日志消息。

需要说明的是，后台服务系统还可以采用其他方式生成日志消息，此处不作限定。

另外，日志消息可以由固定字段和可变参数字段组成，在实际应用中，日志消息的组成字段可以参见表2，如下表2所示，该组成字段可以包括：logname、guid、ime、log_type、cost_time、desc、ret_code、k1，v1∣k2，v2∣…∣kn，vn。

字段名称	字段含义
		logname	流程名称
guid	远程终端的guid
		imei	远程终端的imei
log_type	日志消息类型
		cost_time	耗时
Desc	流程的描述
		ret_code	返回码
k1，v1∣k2，v2∣…∣kn，vn	用于携带关键结果信息，自解析的kv列表

104、后台服务系统根据日志消息创建具有时序的有向无环图。

本实施例中，在后台服务系统生成日志消息后，后台服务系统也就收集到完整的调用信息，此时通过算法对固定格式的日志消息进行DAG分析，可以构建出具有时序的有向无环图，也即是可视化的树形调用关系图。

由于算法输入的是上报的日志消息，通过日志消息的打印时间、服务节点名称过滤后会有多个协议处理过程，可以根据<requested,method>筛选出属于同个协议处理流程的所有记录集合，然后对集合中的元素运用算法来得到一个可视化的树形调用关系图，该可视化的树形调用关系图用于快速诊断问题，同时也可以用于监测分析。一种可选算法如下：

第一步：取出集合中seq最小的元素作为首节点；

第二步：以某节点为根节点的树形图构建过程，输入为server_name，包括如下步骤；

1)、从集合中取出serverName＝server_name的所有日志记录，每条日志记录根据serverSeq升序排列，构建可视化节点；

2)、从集合中取出caller＝server_name的所有去重serverName，如果结果为空，返回；否则对每个serverName递归执行步骤1)，并将节点连接到caller节点。

通过以上算法生成的有向无环图可以参见图5-a和图5-b，其中图5-a为本发明实施例提供的一种服务节点正常调用的有向无环图，所有的服务节点为正常调用状态，点击服务节点可以查看具体的日志信息。图5-b为本发明实施例提供的一种服务节点非正常调用的有向无环图，存在中间两个服务节点为非正常调用状态，点击非正常的服务节点可以快速定位。

可选的，在一些可能的实施例中，上述后台服务系统根据日志消息创建具有时序的有向无环图可以为：

后台服务系统根据日志消息确定各服务节点的有序调用关系；

后台服务系统根据有序调用关系创建具有时序的有向无环图。

本实施例中，由于第二RPC消息中的目标标识可以用于当第二RPC消息被传输至后台服务系统的各服务节点时，对各服务节点的时序进行标记，所以在对第二RPC消息以及相应的调用信息生成日志消息后，通过日志消息能够构建出带有时序的有向无环图，从而在有向无环图的时序关系准确的情况下，能够提高对有问题的服务节点的定位效率。

请参阅图6，本发明实施例中日志消息的处理方法另一个实施例包括：

201、服务节点接收第一RPC消息；

本实施例中，服务节点为后台服务系统中的任意一个服务节点，服务节点所接收到的第一RPC消息可能为远程终端向该服务节点发送的，也可能为该服务节点的上游服务节点向该服务节点发送的。

可以理解，如果该第一RPC消息为终端设备向该服务节点发送的，那么该服务节点为接入服务节点，如果该第一RPC消息为该服务节点的上游服务节点向该服务节点发送的，那么该服务节点不为接入服务节点。所以后台服务系统需要判断该服务节点是否为接入服务节点。

202、后台服务系统判断该服务节点是否为接入服务节点，若是，则执行步骤203，若否，则执行步骤204；

本实施例中，由于该服务节点可能为接入服务节点，也可能不为接入服务节点，所以后台服务系统需要判断该服务节点是否为接入服务节点，若是，则执行步骤203，若否，则执行步骤204。

203、服务节点判断第一RPC消息是否符合预置条件，若符合，则执行步骤205，若不符合，则返回执行步骤201；

本实施例中，在后台服务系统确定该服务节点为接入服务节点后，该服务节点判断该第一RPC消息是否符合预置条件，即该服务节点判断该第一RPC消息是否符合染色条件，若符合，则执行步骤205，若不符合，则返回执行步骤201。

204、服务节点判断第一RPC消息是否已染色，若是，则执行步骤206，若否，则返回执行步骤201。

本实施例中，由于服务节点不为接入服务节点，所以服务节点需要判断第一RPC消息是否已染色，若是，则染色后的第一RPC消息为第二RPC消息，执行步骤206，若否，则返回执行步骤201.

205、服务节点对第一RPC消息进行染色，得到第二RPC消息，再执行步骤206；

本实施例中，服务节点可以在第一RPC消息中设置染色标记，从而得到第二RPC消息。

206、服务节点根据第二RPC消息以及获取到的第二RPC消息的当前调用信息生成固定格式的日志消息；

本实施例中，在服务节点对第一RPC消息染色，得到第二RPC消息后，服务节点可以根据第二RPC消息以及获取到的第二RPC消息的当前调用信息生成固定格式的日志消息。

207、服务节点将第二RPC消息发送给下游服务节点。

本实施例中，服务节点将第二RPC消息发送给下游服务节点后，服务节点会向日志服务节点上报日志消息。

本实施例中，通过在第二RPC消息中携带染色信息，使得各服务节点之间的染色信息建立了有序的关联，从而在对第二RPC消息以及相应的调用信息生成日志消息后，通过日志消息能够构建出带有时序的有向无环图，从而在有向无环图的时序关系准确的情况下，能够提高对有问题的服务节点的定位效率。

下面介绍本发明实施例中的后台服务系统，请参阅图7，本发明实施例中后台服务系统一个实施例包括：

接收模块301，用于接收远程终端发送的第一远程过程调用协议RPC消息；

设置模块302，用于若第一RPC消息符合预置条件，则根据第一RPC消息在第一RPC消息中设置目标标识，得到第二RPC消息，目标标识用于当第二RPC消息被传输至后台服务系统的各服务节点时，对各服务节点的时序进行标记；

生成模块303，用于对于各服务节点，当第二RPC消息被传输至该服务节点时，根据第二RPC消息以及获取到的第二RPC消息的当前调用信息生成固定格式的日志消息；

创建模块304，用于根据日志消息创建具有时序的有向无环图。

本实施例中，由于第二RPC消息中的目标标识可以用于当第二RPC消息被传输至后台服务系统的各服务节点时，对各服务节点的时序进行标记，所以在对第二RPC消息以及相应的调用信息生成日志消息后，通过日志消息能够构建出带有时序的有向无环图，从而在有向无环图的时序关系准确的情况下，能够提高对有问题的服务节点的定位效率。

可选的，在一些可能的实施例中，设置模块302，具体用于通过后台服务系统中的接入服务节点在第一RPC消息中设置目标标识，目标标识包括如下至少一种字段：远程终端的请求序列号、第一RPC消息名称、目标标识的调用链层次、各服务节点名称以及日志消息的打印时间。

可选的，请参阅图8，在一些可能的实施例中，系统还包括：

判断模块401，用于判断第一RPC消息中的全局唯一标识符是否与预设白名单匹配；

确定模块402，用于若匹配，则确定第一RPC消息符合预置条件；或，

判断模块401，还用于判断第一RPC消息中的国际移动设备标识是否与预设白名单匹配；

确定模块402，还用于若匹配，则确定第一RPC消息符合预置条件。

进一步的，系统还包括：

存储模块403，用于按照日志消息的格式存储日志消息，日志消息包括固定字段和可变参数字段。

可见，按照日志消息的格式来存储日志消息，从而不需要再对存储的日志消息进行人工二次筛选，从而提供了一种有效的自动过滤分析方法，完善了本申请技术方案。

可选的，在一些可能的实施例中，创建模块304，具体用于根据日志消息确定各服务节点的有序调用关系；根据有序调用关系创建具有时序的有向无环图。

上面从模块化功能实体的角度对本发明实施例中的后台服务系统进行了描述，下面从硬件处理的角度对本发明实施例中的后台服务系统进行描述，请参阅图9，本发明实施例中的后台服务系统包括：接收器501、处理器502以及存储器503。

本发明实施例涉及的后台服务系统可以具有比图9所示出的更多或更少的部件，可以组合两个或更多个部件，或者可以具有不同的部件配置或设备，各个部件可以在包括一个或多个信号处理和/或专用集成电路在内的硬件、软件或硬件和软件的组合实现。

接收器501用于执行如下操作：

接收远程终端发送的第一远程过程调用协议RPC消息；

处理器502用于执行如下操作：

若第一RPC消息符合预置条件，则根据第一RPC消息在第一RPC消息中设置目标标识，得到第二RPC消息，目标标识用于当第二RPC消息被传输至后台服务系统的各服务节点时，对各服务节点的时序进行标记；对于各服务节点，当第二RPC消息被传输至该服务节点时，根据第二RPC消息以及获取到的第二RPC消息的当前调用信息生成固定格式的日志消息；根据日志消息创建具有时序的有向无环图。

存储器503用于存储处理器502执行相应的操作所需要的代码。

本实施例中，由于第二RPC消息中的目标标识可以用于当第二RPC消息被传输至后台服务系统的各服务节点时，对各服务节点的时序进行标记，所以在对第二RPC消息以及相应的调用信息生成日志消息后，通过日志消息能够构建出带有时序的有向无环图，从而在有向无环图的时序关系准确的情况下，能够提高对有问题的服务节点的定位效率。

可选的，处理器502还用于执行如下操作：

通过后台服务系统中的接入服务节点在第一RPC消息中设置目标标识，目标标识包括如下至少一种字段：远程终端的请求序列号、第一RPC消息名称、目标标识的调用链层次、各服务节点名称以及日志消息的打印时间。

可选的，处理器502还用于执行如下操作：

判断第一RPC消息中的全局唯一标识符是否与预设白名单匹配；若匹配，则确定第一RPC消息符合预置条件；或，

判断第一RPC消息中的国际移动设备标识是否与预设白名单匹配；若匹配，则确定第一RPC消息符合预置条件。

可选的，存储器503还用于按照日志消息的格式存储日志消息，日志消息包括固定字段和可变参数字段。

可见，按照日志消息的格式来存储日志消息，从而不需要再对存储的日志消息进行人工二次筛选，从而提供了一种有效的自动过滤分析方法，完善了本申请技术方案。

可选的，处理器502还用于执行如下操作：

根据日志消息确定各服务节点的有序调用关系；根据有序调用关系创建具有时序的有向无环图。

在上述实施例中，可以全部或部分地通过软件、硬件、固件或者其任意组合来实现。当使用软件实现时，可以全部或部分地以计算机程序产品的形式实现。

所述计算机程序产品包括一个或多个计算机指令。在计算机上加载和执行所述计算机程序指令时，全部或部分地产生按照本发明实施例所述的流程或功能。所述计算机可以是通用计算机、专用计算机、计算机网络、或者其他可编程装置。所述计算机指令可以存储在计算机可读存储介质中，或者从一个计算机可读存储介质向另一计算机可读存储介质传输，例如，所述计算机指令可以从一个网站站点、计算机、服务器或数据中心通过有线(例如同轴电缆、光纤、数字用户线(DSL))或无线(例如红外、无线、微波等)方式向另一个网站站点、计算机、服务器或数据中心进行传输。所述计算机可读存储介质可以是计算机能够存储的任何可用介质或者是包含一个或多个可用介质集成的服务器、数据中心等数据存储设备。所述可用介质可以是磁性介质，(例如，软盘、硬盘、磁带)、光介质(例如，DVD)、或者半导体介质(例如固态硬盘Solid State Disk(SSD))等。

所属领域的技术人员可以清楚地了解到，为描述的方便和简洁，上述描述的系统，装置和单元的具体工作过程，可以参考前述方法实施例中的对应过程，在此不再赘述。

在本申请所提供的几个实施例中，应该理解到，所揭露的系统，装置和方法，可以通过其它的方式实现。例如，以上所描述的装置实施例仅仅是示意性的，例如，所述单元的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式，例如多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，装置或单元的间接耦合或通信连接，可以是电性，机械或其它的形式。

所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。

另外，在本发明各个实施例中的各功能单元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。

所述集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：U盘、移动硬盘、只读存储器(ROM，Read-OnlyMemory)、随机存取存储器(RAM，Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。

以上所述，以上实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。

Claims (4)

1.一种日志消息的处理方法，其特征在于，包括：

对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息；所述后台服务系统能够同时接收至少两个远程终端发送的RPC消息；所述后台服务系统中包括接入服务节点，所述接入服务节点是服务节点的树形架构的根节点，远程终端的所有请求均首先发送至所述接入服务节点；

若该服务节点接收到的第一RPC消息是由远程终端向该服务节点发送的，则确定该服务节点为接入服务节点；

若该服务节点为接入服务节点，则所述后台服务系统判断所述第一RPC消息是否符合预置条件，具体包括：后台服务器判断所述第一RPC消息中的全局唯一标识符是否与预设白名单匹配，若匹配，则所述后台服务系统确定所述第一RPC消息符合预置条件；或，所述后台服务器判断所述第一RPC消息中的国际移动设备标识是否与所述预设白名单匹配，若匹配，则所述后台服务系统确定所述第一RPC消息符合预置条件；

若所述第一RPC消息符合预置条件，则所述后台服务系统中的接入服务节点根据所述第一RPC消息在所述第一RPC消息中设置目标标识，得到第二RPC消息，所述目标标识用于当所述第二RPC消息被传输至所述后台服务系统的各服务节点时，对各服务节点的时序进行标记；

若所述第一RPC消息不符合预置条件，则返回执行所述对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息的步骤；

若该服务节点接收到的第一RPC消息是由该服务节点的上游服务节点向该服务节点发送的，而不是由所述远程终端向该服务节点发送的，则确定该服务节点不是接入服务节点；

若该服务节点不是接入服务节点，则通过该服务节点判断所述第一RPC消息是否已设置目标标识；

若所述第一RPC消息已设置目标标识，则将所述第一RPC消息确定为所述第二RPC消息，并根据所述第二RPC消息、获取到的所述第二RPC消息的当前调用信息以及获取到的当前时刻生成固定格式的日志消息，再将所述第二RPC消息发送给下游服务节点；

若所述第一RPC消息未设置目标标识，则返回执行所述对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息的步骤；

对于各服务节点，当所述第二RPC消息被传输至该服务节点时，所述后台服务系统根据所述第二RPC消息、获取到的所述第二RPC消息的当前调用信息以及获取到的当前时刻生成固定格式的日志消息，并按照所述固定格式存储所述日志消息，以无需再对存储的日志消息进行人工二次筛选；所述目标标识包括：所述远程终端的请求序列号、所述第一RPC消息名称、所述目标标识的调用链层次、所述各服务节点名称以及所述日志消息的打印时间；所述日志消息的组成字段包括固定字段和可变参数字段，具体包括：流程名称、远程终端的guid、远程终端的IMEI、日志消息类型、耗时、流程描述、返回码与自解析的kv列表；所述自解析的kv列表用于携带关键结果信息；

所述后台服务系统根据所述日志消息，通过所述日志消息的打印时间和所述各服务节点名称进行过滤后有多个协议处理流程，根据所述远程终端的请求序列号和所述第一RPC消息名称筛选出属于同一协议处理流程的所有记录集合；

取出所述记录集合中所述目标标识的调用链层次最小的元素作为首节点；

以输入的目标服务节点名称作为根节点，从所述记录集合中取出所述目标服务节点名称的所有日志记录，并根据每条日志记录中所述日志消息的打印时间进行升序排列，构建可视化节点；

从所述记录集合中取出被所述目标服务节点名称调用的服务节点名称，将每个被所述目标服务节点名称调用的服务节点名称作为目标服务节点名称，递归执行所述从所述记录集合中取出所述目标服务节点名称的所有日志记录，并根据每条日志记录中所述日志消息的打印时间进行升序排列，构建可视化节点的步骤，直至被所述目标服务节点名称调用的服务节点名称不存在，得到具有所述时序的有向无环图。

2.一种后台服务系统，其特征在于，包括：

接收模块，用于对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息；所述后台服务系统能够同时接收至少两个远程终端发送的RPC消息；所述后台服务系统中包括接入服务节点，所述接入服务节点是服务节点的树形架构的根节点，远程终端的所有请求均首先发送至所述接入服务节点；若该服务节点接收到的第一RPC消息是由远程终端向该服务节点发送的，则确定该服务节点为接入服务节点；

判断模块，用于若该服务节点为接入服务节点，则判断所述第一RPC消息是否符合预置条件；

设置模块，用于若所述第一RPC消息符合预置条件，则所述后台服务系统中的接入服务节点根据所述第一RPC消息在所述第一RPC消息中设置目标标识，得到第二RPC消息，所述目标标识用于当所述第二RPC消息被传输至所述后台服务系统的各服务节点时，对各服务节点的时序进行标记；若所述第一RPC消息不符合预置条件，则返回执行所述对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息的步骤；

所述后台服务系统还用于，若该服务节点接收到的第一RPC消息是由该服务节点的上游服务节点向该服务节点发送的，而不是由所述远程终端向该服务节点发送的，则确定该服务节点不是接入服务节点；若该服务节点不是接入服务节点，则通过该服务节点判断所述第一RPC消息是否已设置目标标识；若所述第一RPC消息已设置目标标识，则将所述第一RPC消息确定为所述第二RPC消息，并根据所述第二RPC消息、获取到的所述第二RPC消息的当前调用信息以及获取到的当前时刻生成固定格式的日志消息，再将所述第二RPC消息发送给下游服务节点；若所述第一RPC消息未设置目标标识，则返回执行所述对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息的步骤；

生成模块，用于对于各服务节点，当所述第二RPC消息被传输至该服务节点时，根据所述第二RPC消息、获取到的所述第二RPC消息的当前调用信息以及获取到的当前时刻生成固定格式的日志消息，并按照所述固定格式存储所述日志消息，以无需再对存储的日志消息进行人工二次筛选；所述目标标识包括：所述远程终端的请求序列号、所述第一RPC消息名称、所述目标标识的调用链层次、所述各服务节点名称以及所述日志消息的打印时间；

创建模块，用于根据所述日志消息，通过所述日志消息的打印时间和所述各服务节点名称进行过滤后有多个协议处理流程，根据所述远程终端的请求序列号和所述第一RPC消息名称筛选出属于同一协议处理流程的所有记录集合；取出所述记录集合中所述目标标识的调用链层次最小的元素作为首节点；以输入的目标服务节点名称作为根节点，从所述记录集合中取出所述目标服务节点名称的所有日志记录，并根据每条日志记录中所述日志消息的打印时间进行升序排列，构建可视化节点；从所述记录集合中取出被所述目标服务节点名称调用的服务节点名称，将每个被所述目标服务节点名称调用的服务节点名称作为目标服务节点名称，递归执行所述从所述记录集合中取出所述目标服务节点名称的所有日志记录，并根据每条日志记录中所述日志消息的打印时间进行升序排列，构建可视化节点的步骤，直至被所述目标服务节点名称调用的服务节点名称不存在，得到具有所述时序的有向无环图；

所述系统还包括：确定模块；

所述判断模块，用于判断所述第一RPC消息中的全局唯一标识符是否与预设白名单匹配；

所述确定模块，用于若匹配，则确定所述第一RPC消息符合预置条件；或，

所述判断模块，还用于判断所述第一RPC消息中的国际移动设备标识是否与所述预设白名单匹配；

所述确定模块，还用于若匹配，则确定所述第一RPC消息符合预置条件；

所述生成模块，具体用于按照所述日志消息的格式存储所述日志消息，所述日志消息包括固定字段和可变参数字段，具体包括：流程名称、远程终端的guid、远程终端的IMEI、日志消息类型、耗时、流程描述、返回码与自解析的kv列表；所述自解析的kv列表用于携带关键结果信息。

3.一种后台服务系统，其特征在于，包括：接收器、处理器以及存储器；

所述接收器，用于对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息；所述后台服务系统能够同时接收至少两个远程终端发送的RPC消息；所述后台服务系统中包括接入服务节点，所述接入服务节点是服务节点的树形架构的根节点，远程终端的所有请求均首先发送至所述接入服务节点；若该服务节点接收到的第一RPC消息是由远程终端向该服务节点发送的，则确定该服务节点为接入服务节点；

所述处理器，用于若该服务节点为接入服务节点，则判断所述第一RPC消息是否符合预置条件，具体包括：后台服务器判断所述第一RPC消息中的全局唯一标识符是否与预设白名单匹配，若匹配，则所述后台服务系统确定所述第一RPC消息符合预置条件；或，所述后台服务器判断所述第一RPC消息中的国际移动设备标识是否与所述预设白名单匹配，若匹配，则所述后台服务系统确定所述第一RPC消息符合预置条件；若所述第一RPC消息符合预置条件，则所述后台服务系统中的接入服务节点根据所述第一RPC消息在所述第一RPC消息中设置目标标识，得到第二RPC消息，所述目标标识用于当所述第二RPC消息被传输至所述后台服务系统的各服务节点时，对各服务节点的时序进行标记；若所述第一RPC消息不符合预置条件，则返回执行所述对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息的步骤；若该服务节点接收到的第一RPC消息是由该服务节点的上游服务节点向该服务节点发送的，而不是由所述远程终端向该服务节点发送的，则确定该服务节点不是接入服务节点；若该服务节点不是接入服务节点，则通过该服务节点判断所述第一RPC消息是否已设置目标标识；若所述第一RPC消息已设置目标标识，则将所述第一RPC消息确定为所述第二RPC消息，并根据所述第二RPC消息、获取到的所述第二RPC消息的当前调用信息以及获取到的当前时刻生成固定格式的日志消息，再将所述第二RPC消息发送给下游服务节点；若所述第一RPC消息未设置目标标识，则返回执行所述对于后台服务系统中的任一服务节点，该服务节点接收第一远程过程调用协议RPC消息的步骤；对于各服务节点，当所述第二RPC消息被传输至该服务节点时，根据所述第二RPC消息、获取到的所述第二RPC消息的当前调用信息以及获取到的当前时刻生成固定格式的日志消息，并按照所述固定格式存储所述日志消息，以无需再对存储的日志消息进行人工二次筛选；所述目标标识包括：所述远程终端的请求序列号、所述第一RPC消息名称、所述目标标识的调用链层次、所述各服务节点名称以及所述日志消息的打印时间；根据所述日志消息，通过所述日志消息的打印时间和所述各服务节点名称进行过滤后有多个协议处理流程，根据所述远程终端的请求序列号和所述第一RPC消息名称筛选出属于同一协议处理流程的所有记录集合；取出所述记录集合中所述目标标识的调用链层次最小的元素作为首节点；以输入的目标服务节点名称作为根节点，从所述记录集合中取出所述目标服务节点名称的所有日志记录，并根据每条日志记录中所述日志消息的打印时间进行升序排列，构建可视化节点；从所述记录集合中取出被所述目标服务节点名称调用的服务节点名称，将每个被所述目标服务节点名称调用的服务节点名称作为目标服务节点名称，递归执行所述从所述记录集合中取出所述目标服务节点名称的所有日志记录，并根据每条日志记录中所述日志消息的打印时间进行升序排列，构建可视化节点的步骤，直至被所述目标服务节点名称调用的服务节点名称不存在，得到具有所述时序的有向无环图；所述日志消息的组成字段包括固定字段和可变参数字段，具体包括：流程名称、远程终端的guid、远程终端的IMEI、日志消息类型、耗时、流程描述、返回码与自解析的kv列表；所述自解析的kv列表用于携带关键结果信息；

所述存储器，用于存储所述处理器执行相应的操作所需的代码。

4.一种计算机存储介质，其上存储有计算机程序，其特征在于，该程序被处理器执行时实现如权利要求1所述方法的步骤。