技术领域technical field
本发明属于计算机应用技术领域，尤其涉及一种多源数据处理方法、终端设备及计算机可读存储介质。The invention belongs to the field of computer application technology, and in particular relates to a multi-source data processing method, terminal equipment and a computer-readable storage medium.
背景技术Background technique
在当前的很多数据应用场景中，数据信息的获取往往有多个数据源共同提供服务，现有技术中通过部署多个应用，每个应用分别连接不同的应用数据数据源，分别提取所需数据之后，进行汇总，最终组合成结果返回调用方。这种做法，首先从资源角度非常耗费资源，需要多个应用共同提供服务。其次，涉及多应用之间的通讯，网络层次的时间消耗也十分影响性能，因此，现有技术中在基于不同数据源的数据进行数据获取与数据处理时存在效率较低的问题。In many current data application scenarios, the acquisition of data information often requires multiple data sources to provide services together. In the existing technology, multiple applications are deployed, and each application is connected to a different application data source to extract the required data. After that, aggregation is performed, and finally the result is combined and returned to the caller. This approach, first of all, is very resource-intensive from the perspective of resources, requiring multiple applications to jointly provide services. Secondly, when communication between multiple applications is involved, time consumption at the network level also greatly affects performance. Therefore, there is a problem of low efficiency in data acquisition and data processing based on data from different data sources in the prior art.
发明内容Contents of the invention
有鉴于此，本发明实施例提供了一种多源数据处理方法、终端设备及计算机可读存储介质，以解决现有技术中在从不同数据源获取与处理数据时存在时间、资源消耗较大的问题。In view of this, an embodiment of the present invention provides a multi-source data processing method, a terminal device, and a computer-readable storage medium to solve the problem of time and resource consumption in obtaining and processing data from different data sources in the prior art. The problem.
本发明实施例的第一方面提供了一种多源数据处理方法，包括：The first aspect of the embodiments of the present invention provides a multi-source data processing method, including:
获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法；Obtaining a call request of a program method sent by the user terminal; the call request includes the function of the program method; the program method is used to indicate a method for processing data;
解析所述调用请求，得到所述程序方法对应的至少一个切面程序，以及执行每个所述切面程序时待调用的目标数据的数据标识；所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；Parsing the call request to obtain at least one aspect program corresponding to the program method, and the data identification of the target data to be called when executing each of the aspect programs; the aspect program is obtained by cutting the program method program; the section program is used to call and process the data associated with the section program in each preset data source; all the section programs are used to fully realize the function of the program method together;
根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。According to the data identifier, call the target data corresponding to the data identifier from each data source, execute all the aspect programs, and realize the function of the program method.
本发明实施例的第二方面提供了一种终端设备，包括存储器、处理器以及存储在所述存储器中并可在所述处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现以下步骤：The second aspect of the embodiments of the present invention provides a terminal device, including a memory, a processor, and a computer program stored in the memory and operable on the processor, when the processor executes the computer program Implement the following steps:
获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法；Obtaining a call request of a program method sent by the user terminal; the call request includes the function of the program method; the program method is used to indicate a method for processing data;
解析所述调用请求，得到所述程序方法对应的至少一个切面程序，以及执行每个所述切面程序时待调用的目标数据的数据标识；所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；Parsing the call request to obtain at least one aspect program corresponding to the program method, and the data identification of the target data to be called when executing each of the aspect programs; the aspect program is obtained by cutting the program method program; the section program is used to call and process the data associated with the section program in each preset data source; all the section programs are used to fully realize the function of the program method together;
根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。According to the data identifier, call the target data corresponding to the data identifier from each data source, execute all the aspect programs, and realize the function of the program method.
本发明实施例的第三方面提供了一种终端设备，包括：A third aspect of the embodiments of the present invention provides a terminal device, including:
获取单元，用于获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法；An acquisition unit, configured to acquire a call request of a program method sent by the user terminal; the call request includes the function of the program method; the program method is used to indicate a method for processing data;
解析单元，用于解析所述调用请求，得到所述程序方法对应的至少一个切面程序，以及执行每个所述切面程序时待调用的目标数据的数据标识；所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；A parsing unit, configured to parse the invocation request, obtain at least one aspect program corresponding to the program method, and a data identification of the target data to be called when executing each of the aspect programs; the aspect program is for the program The program obtained by cutting the method; the cut program is used to call and process the data associated with the cut program in each preset data source; all the cut programs are used to completely realize the function of the program method ;
执行单元，用于根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。The execution unit is configured to call the target data corresponding to the data identifier from each data source according to the data identifier, execute all the aspect programs, and realize the functions of the program method.
本发明实施例的第四方面提供了一种计算机可读存储介质，所述计算机存储介质存储有计算机程序，所述计算机程序包括程序指令，所述程序指令当被处理器执行时使所述处理器执行上述第一方面的方法。A fourth aspect of the embodiments of the present invention provides a computer-readable storage medium, the computer storage medium stores a computer program, the computer program includes program instructions, and when the program instructions are executed by a processor, the processing The device executes the method of the first aspect above.
本发明实施例与现有技术相比存在的有益效果是：The beneficial effect that the embodiment of the present invention exists compared with prior art is:
本发明实施例通过获取用户终端发送的程序方法的调用请求；解析所述调用请求，得到所述程序方法对应的至少一个切面程序，以及执行每个所述切面程序时待调用的目标数据的数据标识；所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。通过确定用户终端发送的调用请求中的程序方法所对应的至少一个切面程序，以及每个切面程序对应的目标数据，并从预设的多个数据源中调取其中存储的目标数据，来直接根据切面程序处理该切面程序对应的目标数据，完整实现程序方法的功能，避免将多种多源数据提取之后再统一执行程序方法的繁琐步骤，减少多源数据获取时的资源消耗和时间消耗，增加数据获取和数据处理的效率。In the embodiment of the present invention, by obtaining the invocation request of the program method sent by the user terminal; parsing the invocation request, obtaining at least one aspect program corresponding to the program method, and the data of the target data to be invoked when executing each of the aspect programs Identification; the cut program is a program obtained by cutting the program method; the cut program is used to call and process the data associated with the cut program in each preset data source; all the cut programs use together to fully realize the functions of the program method; according to the data identifier, call the target data corresponding to the data identifier from each data source, execute all the aspect programs, and realize the function of the program method . By determining at least one aspect program corresponding to the program method in the call request sent by the user terminal, and the target data corresponding to each aspect program, and calling the target data stored therein from multiple preset data sources, to directly Process the target data corresponding to the aspect program according to the aspect program, fully realize the functions of the program method, avoid the cumbersome steps of uniformly executing the program method after extracting various multi-source data, and reduce resource consumption and time consumption when acquiring multi-source data. Increase the efficiency of data acquisition and data processing.
附图说明Description of drawings
为了更清楚地说明本发明实施例中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动性的前提下，还可以根据这些附图获得其他的附图。In order to more clearly illustrate the technical solutions in the embodiments of the present invention, the following will briefly introduce the accompanying drawings that need to be used in the descriptions of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only of the present invention. For some embodiments, those skilled in the art can also obtain other drawings according to these drawings without paying creative efforts.
图1是本发明实施例一提供的多源数据处理方法的流程图；FIG. 1 is a flowchart of a multi-source data processing method provided in Embodiment 1 of the present invention;
图2是本发明实施例二提供的多源数据处理方法的流程图；FIG. 2 is a flow chart of a multi-source data processing method provided in Embodiment 2 of the present invention;
图3是本发明实施例三提供的终端设备的示意图；FIG. 3 is a schematic diagram of a terminal device provided in Embodiment 3 of the present invention;
图4是本发明实施例四提供的终端设备的示意图。FIG. 4 is a schematic diagram of a terminal device provided in Embodiment 4 of the present invention.
具体实施方式Detailed ways
以下描述中，为了说明而不是为了限定，提出了诸如特定系统结构、技术之类的具体细节，以便透彻理解本发明实施例。然而，本领域的技术人员应当清楚，在没有这些具体细节的其它实施例中也可以实现本发明。在其它情况中，省略对众所周知的系统、装置、电路以及方法的详细说明，以免不必要的细节妨碍本发明的描述。In the following description, specific details such as specific system structures and technologies are presented for the purpose of illustration rather than limitation, so as to thoroughly understand the embodiments of the present invention. It will be apparent, however, to one skilled in the art that the invention may be practiced in other embodiments without these specific details. In other instances, detailed descriptions of well-known systems, devices, circuits, and methods are omitted so as not to obscure the description of the present invention with unnecessary detail.
为了说明本发明所述的技术方案，下面通过具体实施例来进行说明。In order to illustrate the technical solutions of the present invention, specific examples are used below to illustrate.
参见图1，图1是本发明实施例一提供的多源数据处理方法的流程图。本实施例中多源数据处理方法的执行主体为终端。终端包括但不限于智能手机、平板电脑、可穿戴设备等移动终端，还可以是台式电脑等。如图所示的多源数据处理方法可以包括以下步骤：Referring to FIG. 1 , FIG. 1 is a flowchart of a multi-source data processing method provided in Embodiment 1 of the present invention. The execution subject of the multi-source data processing method in this embodiment is a terminal. Terminals include, but are not limited to, mobile terminals such as smartphones, tablet computers, and wearable devices, and may also be desktop computers. The multi-source data processing method as shown in the figure may include the following steps:
S101：获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法。S101: Obtain an invocation request of a program method sent by a user terminal; the invocation request includes a function of the program method; the program method is used to indicate a method for processing data.
在实际应用中的很多情况下，服务器用于处理用户终端的各种请求。用户终端通过向服务器发送各种类型的指令或者请求，以使服务器来执行和实现。本实施例中的服务器可以随时获取用户终端发送的程序方法的调用请求，其中，调用请求包括了该程序方法的功能，即，服务器在接收到该调用请求之后，便可以得到用户终端需要什么样的功能，再根据调用请求中的程序方法的功能，确定对应的执行程序。In many cases in practical applications, the server is used to process various requests from user terminals. The user terminal sends various types of instructions or requests to the server, so that the server can execute and implement it. The server in this embodiment can obtain the invocation request of the program method sent by the user terminal at any time, wherein the invocation request includes the function of the program method, that is, after the server receives the invocation request, it can obtain what the user terminal needs. function, and then determine the corresponding execution program according to the function of the program method in the calling request.
在实际应用中，当启动一个程序方法时，然后程序方法又调用了另一个方法，当程序进入被调用方法体时也要穿过一个分界线，当被调方法执行完成之后，程序流就会返回到程序方法，这就是我们平时没怎么意识到的边界。使用了程序切面，我们就可以把代码放到那些边界上，这些边界代表了一个地方或一个条件，对于放置一些可复用的代码很有用。In practical applications, when a program method is started, and then the program method calls another method, when the program enters the body of the called method, a dividing line must also be crossed. After the called method is executed, the program flow will be Returning to the program method, this is the boundary that we usually don't realize. Using program aspects, we can place code on those boundaries, which represent a place or a condition, and are useful for placing some reusable code.
S102：解析所述调用请求，得到所述程序方法对应的至少一个切面程序，以及执行每个所述切面程序时待调用的目标数据的数据标识；所述切面程序为对所述程序方法进行切面得到的程序，所有所述切面程序用于实现所述程序方法的功能。S102: Parse the invocation request to obtain at least one aspect program corresponding to the program method, and the data identification of the target data to be called when each of the aspect programs is executed; the aspect program is an aspect aspect for the program method In the obtained program, all the aspect programs are used to realize the functions of the program method.
在获取到调用请求之后，我们对调用请求进行解析，得到程序方法对应的至少一个切面程序。本实施例中的切面程序为对程序方法进行切面之后得到的一个一个具有小功能的程序，所有的切面程序共同运行便可以实现该程序方法的功能。After obtaining the call request, we parse the call request to obtain at least one aspect program corresponding to the program method. The aspect program in this embodiment is a program with small functions obtained after the program method is aspect-cut, and all the aspect programs can realize the function of the program method by running together.
在开发软件系统中，经常会遇到功能比较单一，在系统中分布广泛但是与具体业务逻辑无关的功能逻辑。例如日志，缓存等功能。这些功能比较独立，和业务逻辑的相关性不高，但系统的各层次都需要对其进行关注。以往系统开发，更注重把系统纵向分层，相邻的层次间存在单向引用关系，不相邻的层次间相互透明。但这种开发方式只是将纵向的功能隔离，无法和各层次通用性的功能消除耦合关系，导致通用性的模块维护比较困难，本实施例中通过预编译方式、代码级扩展或运行期动态代理，实现在不修改源代码的情况下动态执行每个切面程序，以实现用户终端发送的程序方法的功能。因此引入横向切面的概念，将日志，缓存等这些通用性功能各作为一种横向切面，将需要进行这些功能处理的地方叫做切面关注点，将切面和其关注点的耦合关系剥离出来组成新的模块对切面及其关注点进行编织，这样使业务逻辑的开发人员不必关注于具体的切面逻辑，消除了切面功能和业务逻辑的耦合。In the development of software systems, we often encounter functional logic that has a single function and is widely distributed in the system but has nothing to do with specific business logic. Such as logging, caching and other functions. These functions are relatively independent and have little correlation with business logic, but all levels of the system need to pay attention to them. In the past, system development paid more attention to the vertical layering of the system. There was a one-way reference relationship between adjacent layers, and mutual transparency between non-adjacent layers. However, this development method only isolates the vertical functions, and cannot eliminate the coupling relationship with the general functions of each level, making it difficult to maintain general modules. , realizing the dynamic execution of each aspect program without modifying the source code, so as to realize the function of the program method sent by the user terminal. Therefore, the concept of horizontal section is introduced, and the common functions such as log and cache are regarded as a kind of horizontal section. The places that need to be processed with these functions are called section concerns, and the coupling relationship between aspects and their concerns is separated to form a new one. Modules weave aspects and their concerns, so that developers of business logic do not have to focus on specific aspect logic, eliminating the coupling between aspect functions and business logic.
在对调用请求进行解析时，我们可以通过调用请求得到一些信息，这些信息可以用来执行切面程序以实现调用请求的程序功能。这些信息可以包括：切面，用于表示一个应用系统的某一个方面；通知，用于表示切面的行为，具体表现为实现切面逻辑的一个方法。常见通知有：before、after、around、throws等；连接点用于表示应用程序执行过程中插入切面的点；切入点指定了通知应当应用在哪些连接点上。目标对象是指被通知的对象。When parsing the call request, we can get some information through the call request, which can be used to execute the aspect program to realize the program function of the call request. The information may include: aspects, used to represent a certain aspect of an application system; notifications, used to represent the behavior of the aspects, specifically as a method for implementing the logic of the aspects. Common notifications include: before, after, around, throws, etc.; the connection point is used to indicate the point where the aspect is inserted during the execution of the application; the pointcut specifies which connection points the notification should be applied to. The target object is the object to be notified.
本实施例中的程序方法用于表示一个全套的应用程序，用于实现一个完整的功能。但是这个程序方法中可能包含一些小程序，并且每个小程序所对应的处理或者需要获取的数据源不同，因此，我们预先对该程序方法进行切面，得到不同的切面方法。The program method in this embodiment is used to represent a complete application program for realizing a complete function. However, this program method may contain some small programs, and each small program corresponds to different processing or data sources that need to be obtained. Therefore, we cut the program method in advance to obtain different cutting methods.
为了提高应用程序的复用性和程序编写的效率，本实施例中预设有切面方法库，用于将可以实现小功能的切面方法存储至该切面方法库中，在方法程序需要的时候，直接进行调用。我们通过获取到的调用请求，在切面方法库中查找到与该调用请求对应的切面方法程序。每个切面方法程序中预设有数据源标识，用于表示该切面方法程序所需要获取或者调用的数据源中的数据。In order to improve the reusability of the application program and the efficiency of programming, an aspect method library is preset in this embodiment, which is used to store the aspect method that can realize small functions into the aspect method library. When the method program needs it, Make the call directly. Through the obtained invocation request, we find the aspect method program corresponding to the invocation request in the aspect method library. Each aspect method program is preset with a data source identifier, which is used to represent the data in the data source that the aspect method program needs to obtain or call.
S103：根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。S103: According to the data identifier, call target data corresponding to the data identifier from each data source, execute all the aspect programs, and realize the function of the program method.
在调用数据源中的数据时，我们先确定程序方法中所有切面方法对应的数据源，确定每个数据源的配置信息，并根据配置信息对数据源进行配置；配置信息包括数据源标识、数据源地址、数据源密码以及最少及最大连接数信息等等，配置信息用于将切面方法与数据源关联，以分别在spring启动时连接上对应的数据源。When calling the data in the data source, we first determine the data source corresponding to all the aspect methods in the program method, determine the configuration information of each data source, and configure the data source according to the configuration information; the configuration information includes data source identification, data Source address, data source password, minimum and maximum number of connections, etc., the configuration information is used to associate the aspect method with the data source, so as to connect to the corresponding data source when spring starts.
进一步的，步骤S103可以具体包括步骤S1031和步骤S1032：Further, step S103 may specifically include step S1031 and step S1032:
S1031：根据所述数据标识，确定所述数据标识对应的目标数据的配置信息。S1031: Determine configuration information of target data corresponding to the data identifier according to the data identifier.
我们在根据数据标识来确定目标数据时，先根据数据标识确定数据标识对应的目标数据的配置信息。这些配置可以包括但不限于：数据库名，数据库地址，数据库用户名密码，最少及最大连接数信息等等。When we determine the target data according to the data identifier, we first determine the configuration information of the target data corresponding to the data identifier according to the data identifier. These configurations may include but not limited to: database name, database address, database user name and password, minimum and maximum connection information, and so on.
示例性地，在不同业务场景下，方法A和方法B需要分别在运行时连接pg数据库及mysql数据库这两个数据源。在方法A上，需要添加自定义注解，注解上要指定数据源的key为pgdatabase，方法B上同样添加注解，注解上要指定数据源key为mysqldatabase。Exemplarily, in different business scenarios, method A and method B need to connect to two data sources, the pg database and the mysql database, respectively at runtime. On method A, you need to add a custom annotation, specifying that the key of the data source is pgdatabase on the annotation, and adding an annotation on method B, specifying that the key of the data source is mysqldatabase on the annotation.
S1032：根据所述配置信息和所述数据标识，从所述数据源中提取所述目标数据，并执行所述切面程序来处理所述目标数据，实现所述程序方法的功能。S1032: According to the configuration information and the data identifier, extract the target data from the data source, and execute the aspect program to process the target data, so as to realize the function of the program method.
在确定了数据标识对应的目标数据的配置信息之后，我们根据配置信息和数据标识，从对应的数据源中提取出目标数据，并执行每个切面程序来处理目标数据，最后实现用户终端的数据处理功能。After determining the configuration information of the target data corresponding to the data identifier, we extract the target data from the corresponding data source according to the configuration information and data identifier, and execute each aspect program to process the target data, and finally realize the data of the user terminal. Processing function.
具体的，本实施例中的配置信息可以包括但不限于每个数据对应的数据库名、数据库地址、数据库用户名密码以及最少或最大连接数信息等等。通过这些配置信息，我们可以很精确的查找到目标数据，例如，我们可以通过数据库名和数据库地址确定存储目标数据的存储区域，直接读取该存储区域中的数据，再通过数据标识来从该存储区域中提取目标数据。进一步的，由于当前很多数据库中都设有数据读取权限或者验证信息，因此，本实施例中的配置信息还可以包括数据库用户名密码等，以通过数据库用户名密码来验证数据调取终端的身份信息，并在验证通过之后，将目标数据发送至数据调取终端来进行处理。Specifically, the configuration information in this embodiment may include, but is not limited to, the database name, database address, database user name and password, minimum or maximum connection number information, and the like corresponding to each data. Through these configuration information, we can find the target data very accurately. For example, we can determine the storage area where the target data is stored through the database name and database address, directly read the data in the storage area, and then use the data identifier to retrieve the target data from the storage area. Extract the target data in the region. Further, since many databases currently have data reading authority or verification information, the configuration information in this embodiment may also include the database user name and password, etc., so as to verify the identity of the data retrieval terminal through the database user name and password. Identity information, and after the verification is passed, the target data is sent to the data retrieval terminal for processing.
示例性的，若一个服务器要同时连接两个数据源，一个是pg数据库，一个mysql数据库。要分别在应用配置好这两个数据源。这些配置包括数据库名，数据库地址，数据库用户名密码，最少及最大连接数信息等等。分别在spring启动时连接上对应的数据源。这两个数据源分别都为他们命名一个唯一的数据源标识，以此来区分这两个数据源。例如，pg数据库，数据源标识为pgdatabase，mysql数据库的数据源标识为mysqldatabase。每次在获取连接去发起数据库读取的时候，都需要调用方法去确定当前的连接池，在这个时候，通过提前set指定的数据库key，来达到数据源切换的目的。数据处理终端可以根据切面程序的执行方式或者触发条件，来回切换数据源来调用目标数据进行处理，最后实现程序方法对应的数据处理功能。Exemplarily, if a server wants to connect to two data sources at the same time, one is the pg database and the other is the mysql database. These two data sources should be configured in the application respectively. These configurations include database name, database address, database user name and password, minimum and maximum connection information, and so on. Connect to the corresponding data source when spring starts. These two data sources respectively name a unique data source identifier for them, so as to distinguish the two data sources. For example, for the pg database, the data source ID is pgdatabase, and the data source ID for the mysql database is mysqldatabase. Every time a connection is obtained to initiate a database read, a method needs to be called to determine the current connection pool. At this time, the purpose of data source switching is achieved by setting the specified database key in advance. The data processing terminal can switch data sources back and forth to call the target data for processing according to the execution mode or trigger conditions of the aspect program, and finally realize the data processing function corresponding to the program method.
上述方案，通过获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法；解析所述调用请求，得到所述程序方法对应的至少一个切面程序，以及执行每个所述切面程序时待调用的目标数据的数据标识；所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。通过确定用户终端发送的调用请求中的程序方法所对应的至少一个切面程序，以及每个切面程序对应的目标数据，并从预设的多个数据源中调取其中存储的目标数据，来直接根据切面程序处理该切面程序对应的目标数据，完整实现程序方法的功能，避免将多种多源数据提取之后再统一执行程序方法的繁琐步骤，减少多源数据获取时的资源消耗和时间消耗，增加数据获取和数据处理的效率。In the above solution, by obtaining the invocation request of the program method sent by the user terminal; the invocation request includes the function of the program method; the program method is used to represent the method for processing data; and the program method is obtained by parsing the invocation request At least one aspect program corresponding to the method, and the data identification of the target data to be called when each of the aspect programs is executed; the aspect program is a program obtained by performing an aspect aspect on the program method; Process the data associated with the aspect program in each preset data source; all the aspect programs are used to fully realize the function of the program method; according to the data identification, call from each data source The target data corresponding to the data identifier executes all the aspect programs to realize the functions of the program method. By determining at least one aspect program corresponding to the program method in the call request sent by the user terminal, and the target data corresponding to each aspect program, and calling the target data stored therein from multiple preset data sources, to directly Process the target data corresponding to the aspect program according to the aspect program, fully realize the functions of the program method, avoid the cumbersome steps of uniformly executing the program method after extracting various multi-source data, and reduce resource consumption and time consumption when acquiring multi-source data. Increase the efficiency of data acquisition and data processing.
参见图2，图2是本发明实施例二提供的多源数据处理方法的流程图。本实施例中多源数据处理方法的执行主体为终端。终端包括但不限于智能手机、平板电脑、可穿戴设备等移动终端，还可以是台式电脑等。如图所示的多源数据处理方法可以包括以下步骤：Referring to FIG. 2 , FIG. 2 is a flowchart of a multi-source data processing method provided in Embodiment 2 of the present invention. The execution subject of the multi-source data processing method in this embodiment is a terminal. Terminals include, but are not limited to, mobile terminals such as smartphones, tablet computers, and wearable devices, and may also be desktop computers. The multi-source data processing method as shown in the figure may include the following steps:
S201：获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法。S201: Obtain an invocation request of a program method sent by a user terminal; the invocation request includes a function of the program method; the program method is used to indicate a method for processing data.
在本实施例中S201与图1对应的实施例中S101的实现方式完全相同，具体可参考图1对应的实施例中的S101的相关描述，在此不再赘述。The implementation of S201 in this embodiment is completely the same as that of S101 in the embodiment corresponding to FIG. 1 . For details, reference may be made to the relevant description of S101 in the embodiment corresponding to FIG. 1 , and details are not repeated here.
S202：对所述调用请求中所述程序方法的功能进行划分，得到至少两个子功能；根据所述子功能对所述程序方法进行切面划分，得到至少两个子程序；并根据所述子程序从预设的切面程序库中选取与各个所述子程序对应的切面程序。S202: Divide the function of the program method in the call request to obtain at least two sub-functions; divide the program method according to the sub-functions to obtain at least two sub-programs; and obtain at least two sub-programs according to the sub-programs A section program corresponding to each of the subprograms is selected from a preset section program library.
在获取到调用请求之后，我们对调用请求中的程序方法的功能进行解析，得到该程序方法对应的至少两个子功能，其中所有子功能组合在一起可以实现程序方法的完整功能。根据各个子功能对程序方法进行切面划分，得到至少两个子程序，本实施例中的切面程序为对程序方法进行切面之后得到的一个一个具有小功能的程序，所有的切面程序共同运行便可以实现该程序方法的功能。After obtaining the invocation request, we analyze the function of the program method in the invocation request, and obtain at least two sub-functions corresponding to the program method, wherein all sub-functions can be combined to realize the complete function of the program method. Divide the program method according to each sub-function to obtain at least two sub-programs. The aspect program in this embodiment is a program with small functions obtained after cutting the program method. All the program methods can be realized by running together. The function of the program method.
进一步的，步骤S202之前，还可以包括步骤S2021～S2022：Further, before step S202, steps S2021-S2022 may also be included:
S2021：在预设切面程序中设定与所述预设切面程序对应的数据标识，并在所述数据标识与所述数据源中的数据之间建立关联关系；所述关联关系用于通过所述数据标识从所述数据源中提取数据。S2021: Set a data identifier corresponding to the preset aspect program in the preset aspect program, and establish an association relationship between the data identifier and the data in the data source; the association relationship is used to pass the The data identifier extracts data from the data source.
在确定调用请求对应的数据源标识之前，我们需要先设定每个切面程序对应的数据源标识。具体的，我们在每个切面程序的代码中，通过自定义注释的方式，在切面方法程序中设定切面方法对应的数据源标识，同时建立数据标识和数据源中的数据之间的关联关系，并将设定之后的切面方法存储至切面方法库中。本实施例中数据标识与数据源中的数据之间的关联关系，用于将数据标识和数据源关联起来，以在切面程序运行时，可以通过数据标识和关联关系直接调用该切面程序对应的目标数据。Before determining the data source ID corresponding to the call request, we need to set the data source ID corresponding to each aspect program. Specifically, in the code of each aspect program, we set the data source identifier corresponding to the aspect method in the aspect method program by customizing annotations, and at the same time establish the association between the data identifier and the data in the data source , and store the set facet method in the facet method library. The association relationship between the data identifier and the data in the data source in this embodiment is used to associate the data identifier with the data source, so that when the aspect program is running, the corresponding aspect program can be directly called through the data identifier and the association relationship target data.
具体的，我们可以通过自定义注解的方式在预设切面程序中设定与预设切面程序对应的数据标识。自定义注解要求必输字段数据库标识，定义该自定义注解为方法级别，即只能在方法级别使用该注解。同时定义面向该自定义注解的切面方法，切点为所有被该自定义注解修饰的方法。切面定义为，在被切方法调用之前，指定本次方法调用所用数据源，具体数据源由用户在使用自定义注解时必输的字段数据库标识指定。以此达到在方法级别切换数据源的目的。Specifically, we can set the data identifier corresponding to the preset aspect program in the preset aspect program by customizing annotations. The custom annotation requires a mandatory field database identifier, and the custom annotation is defined as a method level, that is, the annotation can only be used at the method level. At the same time, define the aspect method for the custom annotation, and the cut point is all the methods modified by the custom annotation. The aspect definition is to specify the data source used for this method call before the cut method is called. The specific data source is specified by the field database identifier that the user must enter when using the custom annotation. In this way, the purpose of switching data sources at the method level is achieved.
S2022：将设定之后的所述预设切面程序存储至所述切面程序库中。S2022: Store the preset slice program after setting in the slice program library.
在切面程序中设定切面程序对应的数据标识，并在数据标识与数据源中的数据之间建立关联关系之后，我们便可以将设定之后的预设切面程序存储至切面程序库中。本实施例中的切面程序库用于存储各种类型的切面程序，这些切面程序可以随时被调用，以实现不同的小功能，当很多切面程序被按照一定的时序或者触发条件被调用，便可以执行完成一个完整的数据处理功能。After setting the data identifier corresponding to the aspect program in the aspect program, and establishing an association between the data identifier and the data in the data source, we can store the preset aspect program after setting in the aspect program library. The aspect program library in this embodiment is used to store various types of aspect programs. These aspect programs can be called at any time to achieve different small functions. When many aspect programs are called according to a certain timing or trigger conditions, they can be Execute and complete a complete data processing function.
S203：识别每个所述切面程序中待调用的目标数据的数据标识；所述数据标识用于从所述数据源中调用与所述数据标识对应的目标数据。S203: Identify the data identifier of the target data to be called in each aspect program; the data identifier is used to call the target data corresponding to the data identifier from the data source.
在确定了程序方法对应的至少一个切面程序之后，我们可以根据切面程序的程序代码来识别每个切面程序中待调用的目标数据的数据标识，以通过这些数据标识来获取切面程序对应的目标数据。After determining at least one aspect program corresponding to the program method, we can identify the data identifier of the target data to be called in each aspect program according to the program code of the aspect program, so as to obtain the target data corresponding to the aspect program through these data identifiers .
每次在获取连接去发起数据库读取的时候，都需要调用方法去确定当前的连接池，在这个时候，通过提前set指定的数据库key，来达到数据源切换的目的。Every time a connection is obtained to initiate a database read, a method needs to be called to determine the current connection pool. At this time, the purpose of data source switching is achieved by setting the specified database key in advance.
示例性地，通过在方法A上，需要添加注解指定数据源的key为pgdatabase，方法B上同样添加注解，注解上要指定数据源key为mysqldatabase。在方法A被调用时，因为添加了注解，会触发切面方法调用，即在方法A执行之前首先会调用切面方法。在切面方法中，会去读取用户在注解上指定的数据源key,对方法A来说，即为pgdatabase。之后在切面方法中，会去设置当前的数据源为pgdatabase，因为用threadlocal修饰，这个设置将只在当前线程的当前方法有效。对方法B来说，会去读取用户在注解上指定的数据源key为mysqldatabase。当真正去请求数据库连接时，会首先判断当前的数据源是哪个，然后去对应的数据源中获取连接。这样就做到了在方法级别动态切换数据源的目的。For example, on method A, it is necessary to add annotations to specify the key of the data source as pgdatabase, and to add annotations on method B, and to specify the key of the data source as mysqldatabase. When method A is called, because the annotation is added, the aspect method call will be triggered, that is, the aspect method will be called first before method A is executed. In the aspect method, the data source key specified by the user in the annotation will be read. For method A, it is pgdatabase. After that, in the aspect method, the current data source will be set to pgdatabase, because it is modified with threadlocal, this setting will only be valid in the current method of the current thread. For method B, it will read the data source key specified by the user in the annotation as mysqldatabase. When actually requesting a database connection, it will first determine which is the current data source, and then go to the corresponding data source to obtain the connection. This achieves the purpose of dynamically switching data sources at the method level.
进一步的，在不同的切面方法执行过程中，其处理的数据可能不止与其对应的数据源数据，还可能是其他的切面方法执行之后得到的数据，这种情况下，我们可以直接将与该切面方法相关的切面方法关联，直接拦截对应的切面方法执行结束之后的数据。Furthermore, during the execution of different aspect methods, the data processed may not only be the corresponding data source data, but also the data obtained after the execution of other aspect methods. In this case, we can directly use the aspect The method-related aspect method association directly intercepts the data after the execution of the corresponding aspect method.
S204：根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。S204: According to the data identifier, call the target data corresponding to the data identifier from each data source, execute all the aspect programs, and realize the function of the program method.
在确定了实现程序功能的至少一个切面程序及其对应的目标数据的数据标识之后，我们根据数据标识，从预设的数据源中调用与数据标识对应的目标数据，执行所有切面程序，实现程序方法的功能。After determining at least one aspect program that realizes the program function and the data identifier of the corresponding target data, we call the target data corresponding to the data identifier from the preset data source according to the data identifier, execute all the aspect programs, and realize the program The function of the method.
进一步的，步骤S204可以具体包括步骤S2041～S2043：Further, step S204 may specifically include steps S2041-S2043:
S2041：确定每个所述切面程序的执行时序。S2041: Determine the execution time sequence of each aspect program.
我们通过把项目中需要在多处用到的功能，比如日志、安全和事物等集中到一个类中处理，而不用在每个需要用到该功能的地方显式调用。在执行切面程序时，我们需要确定所有切面程序的执行时序，在确定了执行时序之后，便可以确定每个切面程序的执行时间。We concentrate the functions that need to be used in multiple places in the project, such as logging, security, and things, into one class for processing, without having to explicitly call each function that needs to be used. When executing an aspect program, we need to determine the execution timing of all aspect programs. After determining the execution timing, we can determine the execution time of each aspect program.
进一步的，本实施例中的执行时序还可以包括各个切面程序执行时的触发条件的时序，示例性地，切面程序A执行的同时可以执行切面程序B，这两个切面程序是可以同时执行的执行时序，但是切面程序A执行完毕之后才能执行切面程序C，此时，切面程序A执行完毕便是切面程序C执行的触发条件，因此，本实施例中还可以通过各个切面程序之间的执行进展来作为彼此的触发条件。除此之外，还可以是切面程序D运行的同时，生成了数据E，而切面程序F是用于处理数据E的切面程序，此时，便可以运行切面程序F，这种情况下，生成某种数据也可以作为运行相应切面程序的触发条件。Further, the execution timing in this embodiment may also include the timing of the trigger conditions when the various aspect programs are executed. For example, the aspect program B can be executed while the aspect program A is executing, and the two aspect programs can be executed at the same time. Execution timing, but the execution of the aspect program C can only be executed after the execution of the aspect program A. At this time, the execution of the aspect program A is the trigger condition for the execution of the aspect program C. Therefore, in this embodiment, the execution of each aspect program can also be performed progress to serve as triggers for each other. In addition, it is also possible that the data E is generated while the aspect program D is running, and the aspect program F is an aspect program used to process the data E. At this time, the aspect program F can be run. In this case, the generated Certain data can also be used as a trigger to run the corresponding aspect program.
除此之外，还可以确定各个切面程序的连接点和切点，其中，连接点用于表示在何种操作发生时应用切面。比如方法调用时、修改字段时和抛出异常时等等；切点一般用某个包中的类的明确的方法来指定在何处应用切面，应用切面的这个点便称为切点，一般用切点来指定连接点。In addition, the connection point and cut point of each aspect program can also be determined, wherein the connection point is used to indicate when the operation occurs to apply the aspect. For example, when a method is called, when a field is modified, when an exception is thrown, etc.; the pointcut generally uses a clear method of a class in a certain package to specify where to apply the aspect. The point where the aspect is applied is called a pointcut. Use pointcuts to specify join points.
S2042：根据每个切面程序的所述数据标识，从所述数据源中提取与所述数据标识对应的目标数据。S2042: According to the data identifier of each aspect program, extract target data corresponding to the data identifier from the data source.
我们在根据数据标识来确定目标数据时，先根据数据标识确定数据标识对应的目标数据的配置信息。这些配置可以包括但不限于：数据库名，数据库地址，数据库用户名密码，最少及最大连接数信息等等。示例性地，在不同业务场景下，方法A和方法B需要分别在运行时连接pg数据库及mysql数据库这两个数据源。在方法A上，需要添加注解，注解上要指定数据源的key为pgdatabase，方法B上同样添加注解，注解上要指定数据源key为mysqldatabase。When we determine the target data according to the data identifier, we first determine the configuration information of the target data corresponding to the data identifier according to the data identifier. These configurations may include but not limited to: database name, database address, database user name and password, minimum and maximum connection information, and so on. Exemplarily, in different business scenarios, method A and method B need to connect to two data sources, the pg database and the mysql database, respectively at runtime. On method A, you need to add a note, specifying that the key of the data source is pgdatabase on the note, and adding a note on method B, specifying that the key of the data source is mysqldatabase.
S2043：根据每个所述切面程序的执行时序，执行所述切面程序来处理所述切面程序对应的目标数据，实现所述程序方法的功能。S2043: According to the execution time sequence of each of the aspect programs, execute the aspect programs to process the target data corresponding to the aspect programs, so as to realize the functions of the program methods.
在确定了数据标识对应的目标数据的配置信息之后，我们根据配置信息和数据标识，从对应的数据源中提取出目标数据，并执行每个切面程序来处理目标数据，最后实现用户终端的数据处理功能。After determining the configuration information of the target data corresponding to the data identifier, we extract the target data from the corresponding data source according to the configuration information and data identifier, and execute each aspect program to process the target data, and finally realize the data of the user terminal. Processing function.
上述方案，通过获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法；对所述调用请求中所述程序方法的功能进行划分，得到至少两个子功能；根据所述子功能对所述程序方法进行切面划分，得到至少两个子程序；并根据所述子程序从预设的切面程序库中选取与各个所述子程序对应的切面程序；识别每个所述切面程序中待调用的目标数据的数据标识；所述数据标识用于从所述数据源中调用与所述数据标识对应的目标数据。所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。通过确定用户终端发送的调用请求中的程序方法所对应的至少一个切面程序，以及每个切面程序对应的目标数据，并从预设的多个数据源中调取其中存储的目标数据，来直接根据切面程序处理该切面程序对应的目标数据，完整实现程序方法的功能，避免将多种多源数据提取之后再统一执行程序方法的繁琐步骤，减少多源数据获取时的资源消耗和时间消耗，增加数据获取和数据处理的效率。In the above solution, by obtaining the invocation request of the program method sent by the user terminal; the invocation request includes the function of the program method; the program method is used to represent the method for processing data; the program method in the invocation request Divide the functions of the program to obtain at least two sub-functions; divide the program method into aspects according to the sub-functions to obtain at least two sub-programs; The aspect program corresponding to the subroutine; the data identifier identifying the target data to be called in each of the aspect programs; the data identifier is used to call the target data corresponding to the data identifier from the data source. The cut program is a program obtained by cutting the program method; the cut program is used to call and process the data associated with the cut program in each preset data source; all the cut programs are used together Completely realize the functions of the program method; according to the data identifier, call the target data corresponding to the data identifier from each data source, execute all the aspect programs, and realize the function of the program method. By determining at least one aspect program corresponding to the program method in the call request sent by the user terminal, and the target data corresponding to each aspect program, and calling the target data stored therein from multiple preset data sources, to directly Process the target data corresponding to the aspect program according to the aspect program, fully realize the functions of the program method, avoid the cumbersome steps of uniformly executing the program method after extracting various multi-source data, and reduce resource consumption and time consumption when acquiring multi-source data. Increase the efficiency of data acquisition and data processing.
参见图3，图3是本发明实施例三提供的一种终端设备的示意图。终端设备包括的各单元用于执行图1～图2对应的实施例中的各步骤。具体请参阅图1～图2各自对应的实施例中的相关描述。为了便于说明，仅示出了与本实施例相关的部分。本实施例的终端设备300包括：Referring to FIG. 3 , FIG. 3 is a schematic diagram of a terminal device provided by Embodiment 3 of the present invention. Each unit included in the terminal device is configured to execute each step in the embodiments corresponding to FIG. 1 to FIG. 2 . For details, please refer to the relevant descriptions in the embodiments corresponding to FIG. 1 to FIG. 2 . For ease of description, only the parts related to this embodiment are shown. The terminal device 300 in this embodiment includes:
获取单元301，用于获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法；The acquiring unit 301 is configured to acquire a call request of a program method sent by the user terminal; the call request includes the function of the program method; the program method is used to indicate a method for processing data;
解析单元302，用于解析所述调用请求，得到所述程序方法对应的至少一个切面程序，以及执行每个所述切面程序时待调用的目标数据的数据标识；所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；The parsing unit 302 is configured to parse the call request, obtain at least one aspect program corresponding to the program method, and a data identifier of the target data to be invoked when each of the aspect programs is executed; the aspect program is for the The program obtained by cutting the program method; the cut program is used to call and process the data associated with the cut program in each preset data source; all the cut programs are used to completely realize the program method together Function;
执行单元303，用于根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。The execution unit 303 is configured to call the target data corresponding to the data identifier from each data source according to the data identifier, execute all the aspect programs, and realize the functions of the program method.
进一步的，所述解析单元302可以包括：Further, the parsing unit 302 may include:
切面单元，用于对所述调用请求中所述程序方法的功能进行划分，得到至少两个子功能；根据所述子功能对所述程序方法进行切面划分，得到至少两个子程序；并根据所述子程序从预设的切面程序库中选取与各个所述子程序对应的切面程序；An aspect unit, configured to divide the function of the program method in the call request to obtain at least two sub-functions; divide the program method according to the sub-function to obtain at least two sub-programs; and according to the The subroutine selects an aspect program corresponding to each subroutine from a preset aspect program library;
识别单元，用于识别每个所述切面程序中待调用的目标数据的数据标识；所述数据标识用于从所述数据源中调用与所述数据标识对应的目标数据。The identification unit is configured to identify the data identification of the target data to be called in each of the aspect programs; the data identification is used to call the target data corresponding to the data identification from the data source.
进一步的，所述终端设备还可以包括：Further, the terminal device may also include:
关联单元，用于在预设切面程序中设定与所述预设切面程序对应的数据标识，并在所述数据标识与所述数据源中的数据之间建立关联关系；所述关联关系用于通过所述数据标识从所述数据源中提取数据；An associating unit, configured to set a data identifier corresponding to the preset aspect program in the preset aspect program, and establish an association relationship between the data identifier and the data in the data source; the association relationship uses for extracting data from the data source through the data identifier;
存储单元，用于将设定之后的所述预设切面程序存储至所述切面程序库中。The storage unit is used for storing the preset slice program after setting in the slice program library.
进一步的，所述执行单元303可以包括：Further, the execution unit 303 may include:
信息确定单元，用于根据所述数据标识，确定所述数据标识对应的目标数据的配置信息；An information determining unit, configured to determine configuration information of target data corresponding to the data identifier according to the data identifier;
数据提取单元，用于根据所述配置信息和所述数据标识，从所述数据源中提取所述目标数据，并执行所述切面程序来处理所述目标数据，实现所述程序方法的功能。A data extraction unit, configured to extract the target data from the data source according to the configuration information and the data identifier, and execute the aspect program to process the target data, so as to realize the functions of the program method.
进一步的，所述执行单元303可以包括：Further, the execution unit 303 may include:
时序确定单元，用于确定每个所述切面程序的执行时序；a timing determination unit, configured to determine the execution timing of each of the aspect programs;
目标提取单元，用于根据每个切面程序的所述数据标识，从所述数据源中提取与所述数据标识对应的目标数据；a target extraction unit, configured to extract target data corresponding to the data identifier from the data source according to the data identifier of each aspect program;
程序执行单元，用于根据每个所述切面程序的执行时序，执行所述切面程序来处理所述切面程序对应的目标数据，实现所述程序方法的功能。The program execution unit is configured to execute the aspect program according to the execution time sequence of each aspect program to process the target data corresponding to the aspect program, so as to realize the function of the program method.
上述方案，通过获取用户终端发送的程序方法的调用请求；所述调用请求中包括所述程序方法的功能；所述程序方法用于表示处理数据的方法；对所述调用请求中所述程序方法的功能进行划分，得到至少两个子功能；根据所述子功能对所述程序方法进行切面划分，得到至少两个子程序；并根据所述子程序从预设的切面程序库中选取与各个所述子程序对应的切面程序；识别每个所述切面程序中待调用的目标数据的数据标识；所述数据标识用于从所述数据源中调用与所述数据标识对应的目标数据。所述切面程序为对所述程序方法进行切面得到的程序；所述切面程序用于调用并处理预设的各个数据源中与所述切面程序相关联的数据；所有所述切面程序用于一起完整地实现所述程序方法的功能；根据所述数据标识，从所述各个数据源中调用与所述数据标识对应的目标数据，执行所有所述切面程序，实现所述程序方法的功能。通过确定用户终端发送的调用请求中的程序方法所对应的至少一个切面程序，以及每个切面程序对应的目标数据，并从预设的多个数据源中调取其中存储的目标数据，来直接根据切面程序处理该切面程序对应的目标数据，完整实现程序方法的功能，避免将多种多源数据提取之后再统一执行程序方法的繁琐步骤，减少多源数据获取时的资源消耗和时间消耗，增加数据获取和数据处理的效率。In the above solution, by obtaining the invocation request of the program method sent by the user terminal; the invocation request includes the function of the program method; the program method is used to represent the method for processing data; the program method in the invocation request Divide the functions of the program to obtain at least two sub-functions; divide the program method into aspects according to the sub-functions to obtain at least two sub-programs; The aspect program corresponding to the subroutine; the data identifier identifying the target data to be called in each of the aspect programs; the data identifier is used to call the target data corresponding to the data identifier from the data source. The cut program is a program obtained by cutting the program method; the cut program is used to call and process the data associated with the cut program in each preset data source; all the cut programs are used together Completely realize the functions of the program method; according to the data identifier, call the target data corresponding to the data identifier from each data source, execute all the aspect programs, and realize the function of the program method. By determining at least one aspect program corresponding to the program method in the call request sent by the user terminal, and the target data corresponding to each aspect program, and calling the target data stored therein from multiple preset data sources, to directly Process the target data corresponding to the aspect program according to the aspect program, fully realize the functions of the program method, avoid the cumbersome steps of uniformly executing the program method after extracting various multi-source data, and reduce resource consumption and time consumption when acquiring multi-source data. Increase the efficiency of data acquisition and data processing.
图4是本发明实施例四提供的终端设备的示意图。如图4所示，该实施例的终端设备4包括：处理器40、存储器41以及存储在所述存储器41中并可在所述处理器40上运行的计算机程序42。所述处理器40执行所述计算机程序42时实现上述各个多源数据处理方法实施例中的步骤，例如图1所示的步骤101至103。或者，所述处理器40执行所述计算机程序42时实现上述各装置实施例中各模块/单元的功能，例如图3所示单元301至303的功能。FIG. 4 is a schematic diagram of a terminal device provided in Embodiment 4 of the present invention. As shown in FIG. 4 , the terminal device 4 of this embodiment includes: a processor 40 , a memory 41 and a computer program 42 stored in the memory 41 and operable on the processor 40 . When the processor 40 executes the computer program 42, it implements the steps in the above embodiments of the multi-source data processing method, for example, steps 101 to 103 shown in FIG. 1 . Alternatively, when the processor 40 executes the computer program 42, functions of the modules/units in the above-mentioned device embodiments, such as the functions of the units 301 to 303 shown in FIG. 3 , are realized.
示例性的，所述计算机程序42可以被分割成一个或多个模块/单元，所述一个或者多个模块/单元被存储在所述存储器41中，并由所述处理器40执行，以完成本发明。所述一个或多个模块/单元可以是能够完成特定功能的一系列计算机程序指令段，该指令段用于描述所述计算机程序42在所述终端设备4中的执行过程。Exemplarily, the computer program 42 can be divided into one or more modules/units, and the one or more modules/units are stored in the memory 41 and executed by the processor 40 to complete this invention. The one or more modules/units may be a series of computer program instruction segments capable of accomplishing specific functions, and the instruction segments are used to describe the execution process of the computer program 42 in the terminal device 4 .
所述终端设备4可以是桌上型计算机、笔记本、掌上电脑及云端服务器等计算设备。所述终端设备可包括，但不仅限于，处理器40、存储器41。本领域技术人员可以理解，图4仅仅是终端设备4的示例，并不构成对终端设备4的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件，例如所述终端设备还可以包括输入输出设备、网络接入设备、总线等。The terminal device 4 may be computing devices such as desktop computers, notebooks, palmtop computers, and cloud servers. The terminal device may include, but not limited to, a processor 40 and a memory 41 . Those skilled in the art can understand that FIG. 4 is only an example of the terminal device 4, and does not constitute a limitation on the terminal device 4. It may include more or less components than those shown in the figure, or combine certain components, or different components. , for example, the terminal device may also include an input and output device, a network access device, a bus, and the like.
所称处理器40可以是中央处理单元(Central Processing Unit，CPU)，还可以是其他通用处理器、数字信号处理器(Digital Signal Processor，DSP)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现成可编程门阵列(Field-Programmable Gate Array，FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等。通用处理器可以是微处理器或者该处理器也可以是任何常规的处理器等。The so-called processor 40 may be a central processing unit (Central Processing Unit, CPU), and may also be other general-purpose processors, a digital signal processor (Digital Signal Processor, DSP), an application specific integrated circuit (Application Specific Integrated Circuit, ASIC), Off-the-shelf programmable gate array (Field-Programmable Gate Array, FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, etc. A general-purpose processor may be a microprocessor, or the processor may be any conventional processor, and the like.
所述存储器41可以是所述终端设备4的内部存储单元，例如终端设备4的硬盘或内存。所述存储器41也可以是所述终端设备4的外部存储设备，例如所述终端设备4上配备的插接式硬盘，智能存储卡(Smart Media Card，SMC)，安全数字(Secure Digital，SD)卡，闪存卡(Flash Card，FC)等。进一步地，所述存储器41还可以既包括所述终端设备4的内部存储单元也包括外部存储设备。所述存储器41用于存储所述计算机程序以及所述终端设备所需的其他程序和数据。所述存储器41还可以用于暂时地存储已经输出或者将要输出的数据。The storage 41 may be an internal storage unit of the terminal device 4 , such as a hard disk or memory of the terminal device 4 . The memory 41 can also be an external storage device of the terminal device 4, such as a plug-in hard disk equipped on the terminal device 4, a smart memory card (Smart Media Card, SMC), a secure digital (Secure Digital, SD) card, flash card (Flash Card, FC), etc. Further, the memory 41 may also include both an internal storage unit of the terminal device 4 and an external storage device. The memory 41 is used to store the computer program and other programs and data required by the terminal device. The memory 41 can also be used to temporarily store data that has been output or will be output.
所属领域的技术人员可以清楚地了解到，为了描述的方便和简洁，仅以上述各功能单元、模块的划分进行举例说明，实际应用中，可以根据需要而将上述功能分配由不同的功能单元、模块完成，即将所述装置的内部结构划分成不同的功能单元或模块，以完成以上描述的全部或者部分功能。实施例中的各功能单元、模块可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中，上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。另外，各功能单元、模块的具体名称也只是为了便于相互区分，并不用于限制本申请的保护范围。上述系统中单元、模块的具体工作过程，可以参考前述方法实施例中的对应过程，在此不再赘述。Those skilled in the art can clearly understand that for the convenience and brevity of description, only the division of the above-mentioned functional units and modules is used for illustration. In practical applications, the above-mentioned functions can be assigned to different functional units, Completion of modules means that the internal structure of the device is divided into different functional units or modules to complete all or part of the functions described above. Each functional unit and module in the embodiment may be integrated into one processing unit, or each unit may exist separately physically, or two or more units may be integrated into one unit, and the above-mentioned integrated units may adopt hardware It can also be implemented in the form of software functional units. In addition, the specific names of the functional units and modules are only for the convenience of distinguishing each other, and are not used to limit the protection scope of the present application. For the specific working process of the units and modules in the above system, reference may be made to the corresponding process in the foregoing method embodiments, and details will not be repeated here.
在上述实施例中，对各个实施例的描述都各有侧重，某个实施例中没有详述或记载的部分，可以参见其它实施例的相关描述。In the above-mentioned embodiments, the descriptions of each embodiment have their own emphases, and for parts that are not detailed or recorded in a certain embodiment, refer to the relevant descriptions of other embodiments.
所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。The units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in one place, or may be distributed to multiple network units. Part or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.
所述集成的模块/单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明实现上述实施例方法中的全部或部分流程，也可以通过计算机程序来指令相关的硬件来完成，所述的计算机程序可存储于一计算机可读存储介质中。If the integrated module/unit is realized in the form of a software function unit and sold or used as an independent product, it can be stored in a computer-readable storage medium. Based on this understanding, the present invention realizes all or part of the processes in the methods of the above embodiments, and can also be completed by instructing related hardware through a computer program, and the computer program can be stored in a computer-readable storage medium.
以上所述实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围，均应包含在本发明的保护范围之内。The above-described embodiments are only used to illustrate the technical solutions of the present invention, rather than to limit them; although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: it can still carry out the foregoing embodiments Modifications to the technical solutions recorded in the examples, or equivalent replacement of some of the technical features; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the spirit and scope of the technical solutions of the various embodiments of the present invention, and should be included in within the protection scope of the present invention.
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910426004.9ACN110262854A (en) | 2019-05-21 | 2019-05-21 | Multi-source data processing method and terminal device |
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910426004.9ACN110262854A (en) | 2019-05-21 | 2019-05-21 | Multi-source data processing method and terminal device |
| Publication Number | Publication Date |
|---|---|
| CN110262854Atrue CN110262854A (en) | 2019-09-20 |
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201910426004.9APendingCN110262854A (en) | 2019-05-21 | 2019-05-21 | Multi-source data processing method and terminal device |
| Country | Link |
|---|---|
| CN (1) | CN110262854A (en) |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112000738A (en)* | 2020-08-18 | 2020-11-27 | 中国建设银行股份有限公司 | Database connection switching method, device, equipment and medium |
| CN113377629A (en)* | 2020-03-09 | 2021-09-10 | 北京沃东天骏信息技术有限公司 | Method and device for monitoring user abnormal codes |
| CN113961544A (en)* | 2021-10-26 | 2022-01-21 | 中国银行股份有限公司 | Database sorting method and device |
| CN114139509A (en)* | 2021-12-01 | 2022-03-04 | 招商局金融科技有限公司 | Report processing method, device, equipment and medium |
| CN113961544B (en)* | 2021-10-26 | 2025-10-17 | 中国银行股份有限公司 | Database splitting method and device |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20090300138A1 (en)* | 2008-05-29 | 2009-12-03 | Red Hat, Inc. | Using Distributed Aspects to Reorder Online Application Workflows |
| CN103870455A (en)* | 2012-12-07 | 2014-06-18 | 阿里巴巴集团控股有限公司 | Multi-data-source data integrated processing method and device |
| CN104991824A (en)* | 2015-08-03 | 2015-10-21 | 上海斐讯数据通信技术有限公司 | Method and system for dynamically switching application program data sources |
| CN107301179A (en)* | 2016-04-14 | 2017-10-27 | 北京京东尚科信息技术有限公司 | The method and apparatus of data base read-write separation |
| CN108520004A (en)* | 2018-03-12 | 2018-09-11 | 舟谱数据技术南京有限公司 | Based on method parameter section multi-tenant data source switching system |
| CN109491830A (en)* | 2017-09-12 | 2019-03-19 | 北京京东尚科信息技术有限公司 | The method and system in switch data source |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20090300138A1 (en)* | 2008-05-29 | 2009-12-03 | Red Hat, Inc. | Using Distributed Aspects to Reorder Online Application Workflows |
| CN103870455A (en)* | 2012-12-07 | 2014-06-18 | 阿里巴巴集团控股有限公司 | Multi-data-source data integrated processing method and device |
| CN104991824A (en)* | 2015-08-03 | 2015-10-21 | 上海斐讯数据通信技术有限公司 | Method and system for dynamically switching application program data sources |
| CN107301179A (en)* | 2016-04-14 | 2017-10-27 | 北京京东尚科信息技术有限公司 | The method and apparatus of data base read-write separation |
| CN109491830A (en)* | 2017-09-12 | 2019-03-19 | 北京京东尚科信息技术有限公司 | The method and system in switch data source |
| CN108520004A (en)* | 2018-03-12 | 2018-09-11 | 舟谱数据技术南京有限公司 | Based on method parameter section multi-tenant data source switching system |
| Title |
|---|
| 匿名: "Spring(4)——面向切面编程（AOP模块）", 《HTTPS://WWW.JIANSHU.COM/P/994027425B44》, 12 February 2019 (2019-02-12), pages 1 - 7* |
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113377629A (en)* | 2020-03-09 | 2021-09-10 | 北京沃东天骏信息技术有限公司 | Method and device for monitoring user abnormal codes |
| CN112000738A (en)* | 2020-08-18 | 2020-11-27 | 中国建设银行股份有限公司 | Database connection switching method, device, equipment and medium |
| CN112000738B (en)* | 2020-08-18 | 2023-06-02 | 建信金融科技有限责任公司 | Database connection switching method, device, equipment and medium |
| CN113961544A (en)* | 2021-10-26 | 2022-01-21 | 中国银行股份有限公司 | Database sorting method and device |
| CN113961544B (en)* | 2021-10-26 | 2025-10-17 | 中国银行股份有限公司 | Database splitting method and device |
| CN114139509A (en)* | 2021-12-01 | 2022-03-04 | 招商局金融科技有限公司 | Report processing method, device, equipment and medium |
| CN114139509B (en)* | 2021-12-01 | 2024-11-01 | 招商局金融科技有限公司 | Report processing method, device, equipment and medium |
| Publication | Publication Date | Title |
|---|---|---|
| CN111124906A (en) | Tracking method, compilation method, device and electronic device based on dynamic buried point | |
| CN111767143A (en) | Transaction data processing method, device, equipment and system | |
| KR20170059451A (en) | System and method for determination of partition identifiers in a multitenant application server environment | |
| WO2022027867A1 (en) | Mdc-based multithreaded link tracking method and apparatus, and computer-readable storage medium | |
| CN114531477B (en) | Method and device for configuring functional components, computer equipment and storage medium | |
| CN110825499B (en) | Method and device for realizing security isolation based on unified container cloud platform | |
| CN110262854A (en) | Multi-source data processing method and terminal device | |
| CN113448985A (en) | API (application program interface) interface generation method, calling method and device and electronic equipment | |
| US10776180B1 (en) | Expression-based feature toggle in an application programming interface (API) | |
| CN114064712A (en) | Data access method and device, electronic equipment and computer readable storage medium | |
| CN115408193A (en) | Method and device for processing error codes among multiple modules | |
| CN113111378B (en) | Terminal, storage medium, annotation method and system, and pre-verification method and system | |
| CN110162344B (en) | Isolation current limiting method and device, computer equipment and readable storage medium | |
| CN111338716A (en) | Data processing method, device and terminal device based on rule engine | |
| CN110244945A (en) | Interface document generation method and terminal equipment | |
| CN113722114A (en) | Data service processing method and device, computing equipment and storage medium | |
| CN110865848B (en) | Component interception method and terminal equipment | |
| CN114637969A (en) | Authentication method and device for target object | |
| CN112130900B (en) | A BMC user information management method, system, device and medium | |
| CN110535724B (en) | Application network read and write restriction method, device, electronic device and storage medium | |
| CN118301208A (en) | Data source configuration method, device and readable storage medium | |
| CN111651248A (en) | Scheduled task execution method, device, electronic device and storage medium | |
| CN111399999A (en) | Computer resource processing method and device, readable storage medium and computer equipment | |
| CN117610073A (en) | A data desensitization method, device, electronic equipment and storage medium | |
| CN117251139A (en) | Business process configuration management methods, devices, equipment and storage media |
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| WD01 | Invention patent application deemed withdrawn after publication | ||
| WD01 | Invention patent application deemed withdrawn after publication | Application publication date:20190920 |