CN107479992A - A kind of method for processing business and device - Google Patents

Abstract

The invention discloses a service processing method, which is applied to a first process. The method comprises the following steps: receiving a service request message sent by a second process, determining a service set to be processed according to the service request message, and determining a service set to be processed in the service set The first service subset that responds sends a response message to the second process after processing all services in the first service subset. Applying the technical solution provided by the embodiment of the present invention, in the process of processing the service request message sent by the second process, if there is a service to be answered, the first process will preferentially process the first service subset composed of the services to be answered in the service set The business to be answered, and after processing the business in the first business subset, send a response message to the second process, so as to shorten the time for the second process to wait for the response message, speed up the processing speed of the second process, and improve user experience. The invention also discloses a business processing device, which has corresponding technical effects.

Description

A business processing method and device

technical field

The invention relates to the field of computer application technology, in particular to a business processing method and device.

Background technique

In computer applications, business interaction and communication among various processes are becoming more and more frequent.

In recent years, when processes are interacting and communicating with each other in many application scenarios, the receiving process may be required to respond after processing the corresponding business, and the sending process may perform subsequent operations only after receiving the response message. In a typical application scenario, such as in a distributed metadata cluster, when a metadata service fails, the backup metadata service that replaces the failed metadata service needs to receive the message sent by other active metadata services after processing the business request message ACK to perform subsequent operations.

In the application scenario that requires the receiving process to respond, if the receiving process is busy or the receiving process is slow to process the business, the response message is sent slowly, which may cause the business of the sending process to be unable to process or the processing speed is very slow, affecting user experience.

To sum up, how to effectively speed up the speed of process processing and improve user experience is a technical problem urgently needed to be solved by those skilled in the art.

Contents of the invention

The purpose of the present invention is to provide a business processing method and device, so as to speed up the process of processing business and improve user experience.

In order to solve the above technical problems, the present invention provides the following technical solutions:

A business processing method, applied to a first process, comprising:

receiving the service request message sent by the second process;

Determine the set of services to be processed according to the service request message;

determining a first subset of services to be answered in the service set;

After all the services in the first service subset are processed, a response message is sent to the second process.

Preferably, the determining the first subset of services to be answered in the service set includes:

For each service in the service set, if the service is a service to be answered, the service is added to the first service subset.

Preferably, after sending the response message to the second process, or while sending the response message to the second process, the method further includes:

Processing services in the service set that are not the first service subset.

Preferably, after determining the service set to be processed according to the service request message and before determining the first service subset to be answered in the service set, the method further includes:

judging whether the target performance parameter value is less than a preset first threshold;

If yes, perform the operation of determining the first service subset to be answered in the service set.

Preferably, when judging that the target performance parameter value is greater than or equal to the first threshold, it also includes:

After processing all the services in the service set, send a response message to the second process.

A service processing device, applied to a first process, comprising:

A service request message receiving module, configured to receive a service request message sent by the second process;

A service set determination module, configured to determine a service set to be processed according to the service request message;

A first service subset determination module, configured to determine a first service subset to be answered in the service set;

A response message sending module, configured to send a response message to the second process after processing all services in the first service subset is completed.

Preferably, the first business subset determination module is specifically used for:

For each service in the service set, if the service is a service to be answered, the service is added to the first service subset.

Preferably, a business processing module is also included for:

After the sending of the response message to the second process, or at the same time as the sending of the response message to the second process, the services in the service set that are not the first service subset are processed.

Preferably, a judging module is also included for:

After determining the service set to be processed according to the service request message and before determining the first service subset to be answered in the service set, judging whether the target performance parameter value is less than a preset first threshold;

If yes, trigger the first service subset determining module.

Preferably, the response message sending module is also used for:

When it is judged that the target performance parameter value is greater than or equal to the first threshold, after all services in the service set are processed, a response message is sent to the second process.

Applying the technical solution provided by the embodiment of the present invention, the first process receives the service request message sent by the second process, determines the service set to be processed according to the service request message, and determines the first service subset to be answered in the service set, After processing all the services in the first service subset, a response message is sent to the second process. In the process of processing the service request message sent by the second process, if there is a business to be answered, the first process will give priority to the business to be answered in the first business subset composed of the business to be answered in the business set, and after processing the first After completing the business in the business subset, send a response message to the second process, so as to shorten the waiting time of the second process for the response message, speed up the processing speed of the second process, and improve user experience.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present invention or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only These are some embodiments of the present invention. Those skilled in the art can also obtain other drawings based on these drawings without creative work.

Fig. 1 is the implementation flowchart of a business processing method in the embodiment of the present invention;

Fig. 2 is a partial flow chart of the metadata service in the prior art;

Fig. 3 is a partial flow chart of the metadata service after applying the technical solution provided by the embodiment of the present invention;

Fig. 4 is a schematic structural diagram of a service processing device in an embodiment of the present invention.

detailed description

The core of the present invention is to provide a business processing method, which is applied to the first process. The first process receives the service request message sent by the second process, determines the service set to be processed according to the service request message, determines the first service subset to be answered in the service set, and processes all the services in the first service subset After completion, send a reply message to the second process. The time for the second process to wait for a response message can be shortened, the speed of processing services by the second process can be accelerated, and user experience can be improved.

In order to enable those skilled in the art to better understand the solution of the present invention, the present invention will be further described in detail below in conjunction with the accompanying drawings and specific embodiments. Apparently, the described embodiments are only some of the embodiments of the present invention, but not all of them. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.

Please refer to FIG. 1. FIG. 1 is an implementation flowchart of a business processing method in an embodiment of the present invention. The method includes the following steps:

S101. Receive a service request message sent by a second process.

During business processing, the second process may need to communicate or interact with the first process. Specifically, the second process is busy with business during the current period, and the first process needs to process part of the business to share the business pressure, or, the current business processed by the second process needs the support of the first process, or, the second process needs to know the first process It may be necessary to communicate or interact with the first process in any situation. In these cases, the second process may send a service request message to the first process. Wherein, the service request message may include: request type, service to be processed, response requirements for each service, and the like.

After the first process receives the service request message sent by the second process, it may perform the operation of step S102.

S102. Determine a set of services to be processed according to the service request message.

According to the service request message, the first process can determine the services requested by the second process to be processed by the first process. For the first process, these services are services to be processed. The first process may determine the set of services to be processed as the service set to be processed, that is, the service set includes all services requested by the second process to be processed by the first process.

S103. Determine a first subset of services to be answered in the service set.

The first process splits the services in the service set, and determines the services to be answered as services in the first service subset.

In one embodiment of the present invention, step S103 may include the following steps:

For each service in the service set, if the service is a service to be answered, the service is added to the first service subset.

In this embodiment, a rule for judging whether a business is a business to be answered can be set in advance, for example, judging whether there is a return value in the processing logic of the business, or according to the response requirements for each business carried in the business request message To judge whether it is a service to be answered, the management personnel can also judge and classify each business in advance to form a judgment standard.

The first process judges each business in the business set according to the preset rules for judging whether the business is a business to be answered. If the business is a business to be answered, it means that the business is the first process answering the second If the business must be completed before the process, it is determined that the business is a business in the first business subset.

S104. After processing all the services in the first service subset, send a response message to the second process.

After processing all the services in the first service subset, the first process may send a response message carrying the processing results of the services to be responded to to the second process. After receiving the response message from the first process, the second process can perform subsequent operations.

In one embodiment of the present invention, after the first process sends the response message to the second process, or while sending the response message to the second process, the following steps may also be performed:

Processing services other than the first service subset in the service set.

After the first process finishes processing the content in the first service subset, or while sending a response message to the second process, it can process services in the service set that are not in the first service subset.

Specifically, the first process may determine services in the service set that are not in the first service subset as services in the second service subset, that is, the second service subset is the complement of the first service subset in the service set. set. After determining the second service subset, the first process processes services in the second service subset, that is, processes unprocessed services in the service set.

Applying the method provided by the embodiment of the present invention, the first process receives the service request message sent by the second process, determines the service set to be processed according to the service request message, and determines the first service subset to be answered in the service set, and then After all the services in the first service subset are processed, a response message is sent to the second process. In the process of processing the service request message sent by the second process, if there is a business to be answered, the first process will give priority to the business to be answered in the first business subset composed of the business to be answered in the business set, and after processing the first After completing the business in the business subset, send a response message to the second process, so as to shorten the waiting time of the second process for the response message, speed up the processing speed of the second process, and improve user experience.

In an embodiment of the present invention, a function switch for replying to the response message may be preset. The open or closed state of the functional switch may be predetermined, or may be determined and adjusted according to actual conditions, which is not limited in this embodiment of the present invention.

In this embodiment, before step S101 is executed, the first process first judges whether the function switch for the response message is turned on; if yes, the operations from step S101 to step S104 can be executed sequentially; After receiving the operation of the service request message sent by the second process, determine the service to be processed according to the service request message, and then send a response message to the second process after processing all the services to be processed.

According to the function switch, it can be determined whether to give priority to the services in the first service subset corresponding to the response message, and service processing can be performed according to the actual situation to meet user needs and improve user experience.

In an embodiment of the present invention, after determining the service set to be processed according to the service request message and before determining the first service subset to be answered in the service set, the following steps may also be performed:

Judging whether the target performance parameter value is smaller than the preset first threshold; if yes, performing step S103 to determine the first service subset to be answered in the service set.

It should be noted that the target performance parameter of the first process may represent the current business processing status of the first process, for example, it may represent the business processing speed of the first process, the amount of business to be processed, and the current resource usage. The time when the first process finishes processing the services in the service set corresponding to the service request message sent by the second process and sends a response message to the second process can be judged according to the target performance parameter.

Specifically, the target performance parameter may be represented by certain parameters of a single first process, or may be obtained after weighted calculation based on multiple performance parameters of the first process. For example, the target performance parameter may be the business The processing speed may be the business volume of the first process, or may be the weighted sum of the business processing speed and the business volume. It should be noted that the larger the value of the target performance parameter, the smaller the business volume of the first process, or the faster the business processing speed, or the smaller business volume and the faster processing speed. Therefore, the target performance parameter value can represent to a certain extent the time for the first process to process the service corresponding to the service request message, that is to say, the time for the first process to send a response message to the second process can be estimated according to the target performance parameter value.

In this embodiment, a first threshold may be preset according to a specific target performance parameter, and the specific size of the first threshold may be preset or determined and adjusted according to actual conditions, which is not limited in this embodiment of the present invention.

After determining the service set to be processed according to the service request message and before determining the first service subset to be answered according to the service set, it may be determined whether the current target performance parameter value of itself is less than the preset first threshold, and if so, It shows that if the first process has processed all the services in the service request message, it will be relatively late to send a response message to the second process, which may cause the second process to wait for a longer time for the response message. In this case, the first process The operation of step S103 can be performed, that is, after the first process can process all services belonging to the first service set in the service set, it can immediately send a response message to the second process, which can shorten the waiting time of the second process.

In another embodiment of the present invention, when it is judged that the target performance parameter is greater than or equal to the first threshold, after all services in the service set are processed, a response message is sent to the second process.

In the embodiment of the present invention, if the target performance parameter value of the first process is greater than or equal to the preset first threshold, it indicates that the first process can quickly process all the services in the service set and send a response to the second process message, the second process may not have to wait for a long time. In this case, the first process may send a response message to the second process after processing all services in the service set.

Performing the above operations can shorten the waiting time for the second process to receive the response message, and avoid processing only part of the services in the service set when there is a relationship between the various services in the service set, which may cause the second process to receive Occurs that the reply message is incorrect.

In order to facilitate the understanding of the technical solution of the present invention, the following takes the metadata service as an example to describe the embodiment of the present invention in detail.

It should be noted that the metadata service described below may be a metadata process.

Metadata clusters are usually constructed in active-standby mode (activation-backup). When an activated metadata service fails, a backup metadata service in the metadata cluster will start the takeover process. The succession process of the backup metadata service will go through a series of stages, in which it mainly communicates with other active metadata services to obtain the cached content of the failed metadata service. After the replacement is completely successful, the original backup metadata service replaces the original failed metadata service, becomes active, and continues to provide external services.

It should be noted that during the succession process, that is, the backup metadata service cannot provide external services before it is officially activated. That is, it cannot respond to the latest read and write requests entered by the client at this time. Therefore, the speed of the succession process directly affects the system availability. The faster the takeover time, the better the user experience.

As shown in Figure 2, the existing replacement process: when the original No. 1 metadata service fails, the backup metadata service starts to take over the original No. No. 2 metadata service and No. 2 metadata service send service request messages. At the same time, metadata service No. 0 and metadata service No. 2 send service request messages to metadata service No. 1 after sensing the failure of the original metadata service No. 1. Metadata service No. 0, Metadata service No. 1, and Metadata service No. 2 reply ACK respectively after processing the service corresponding to the service request message. After metadata service No. 1 processes the business corresponding to the business request message sent by metadata service No. 0 and metadata service No. 2, it needs to receive the ACK replies from metadata service No. 0 and metadata service No. 2 respectively before executing Follow up.

In this case, if metadata service No. 0 and/or metadata service No. 2 are processing business request messages, due to their busy work and slow business processing speed, they may reply ACK to metadata service No. 1 If it is slow, it may further cause slow or stagnant succession of No. 1 metadata service, affecting user experience.

Among them, the content to be brought back by the ACK replies from metadata service No. 0 and metadata service No. 2 is only part of the business processing results corresponding to the business request message, not all the business processing results. Based on the specific situation of the metadata service, after consideration, in practical applications, the technical solution provided by the embodiment of the present invention can be used to deal with the alternation of faults among the metadata service No. 0, metadata service No. 1, and metadata service No. business.

During the alternation of metadata failures, metadata service No. 0, metadata service No. 1, and metadata service No. 2 may send service request messages, and may also process received service request messages and reply response messages, so Metadata service No. 0, metadata service No. 1, and metadata service No. 2 can be used as the first process or as the second process. Specifically, when they receive and process service request messages, they can be regarded as the first process; when they send service request messages and receive response messages, they can be regarded as the second process.

As shown in Figure 3, applying the technical solution provided by the present invention, the metadata service replacement process can be as follows: when the original No. 1 metadata service fails, the backup metadata service starts to take over the original No. 1 metadata service and becomes No. 1 metadata service For services, metadata service No. 1 sends service request messages to metadata service No. 0 and metadata service No. 2 in the activated state respectively. At the same time, metadata service No. 0 and metadata service No. 2 also send service request messages to metadata service No. 1 after sensing the failure of the original metadata service No. 1.

After the No. 1 metadata service finishes processing all the services in the service set corresponding to the received service request, it returns ACK respectively. After the metadata service No. 0 and the metadata service No. 2 have processed the services in the first service subset corresponding to the ACK, they reply ACK respectively. At this time, after metadata service No. 1 receives the ACK replies from metadata service No. 0 and metadata service No. 2, subsequent operations can be performed. While metadata service No. 1 is performing subsequent operations, metadata service No. 0 and metadata service No. 2 can respectively process services in the service set that are not in the first service subset.

Without affecting the logic and function, the technical solution provided by the embodiment of the present invention can be used. Metadata service No. 0 and metadata service No. 2 have processed the first service sub-item corresponding to the service request message sent by metadata service No. 1. After collection, send ACK to No. 1 metadata service, which can shorten the time for No. 1 metadata service to wait for ACK, speed up the business processing speed of No. 1 metadata service, and complete the succession process faster, becoming an activated metadata service , began to provide external services, improve the availability of external services provided by the metadata service system, and improve user experience.

Corresponding to the above method embodiment, the embodiment of the present invention also provides a service processing device, which is applied to the first process. The service processing device described below and the service processing method described above can be referred to in correspondence.

Referring to shown in Figure 4, the device includes:

A service request message receiving module 201, configured to receive a service request message sent by the second process;

A service set determining module 202, configured to determine a service set to be processed according to the service request message;

The first service subset determination module 203 is configured to determine the first service subset to be answered in the service set;

The response message sending module 204 is configured to send a response message to the second process after processing all services in the first service subset.

Applying the device provided by the embodiment of the present invention, the first process receives the service request message sent by the second process, determines the service set to be processed according to the service request message, and determines the first service subset to be answered in the service set. After all the services in the first service subset are processed, a response message is sent to the second process. In the process of processing the service request message sent by the second process, if there is a business to be answered, the first process will give priority to the business to be answered in the first business subset composed of the business to be answered in the business set, and after processing the first After completing the business in the business subset, send a response message to the second process, so as to shorten the waiting time of the second process for the response message, speed up the processing speed of the second process, and improve user experience.

In a specific implementation manner of the present invention, the first service subset determination module 203 is specifically used for:

For each service in the service set, if the service is a service to be answered, the service is added to the first service subset.

In a specific embodiment of the present invention, it also includes a business processing module for:

After sending the response message to the second process, or while sending the response message to the second process, the services of the service set other than the first service subset are processed.

In a specific embodiment of the present invention, it also includes a judging module for:

After determining the service set to be processed according to the service request message and before determining the first service subset to be answered in the service set, judging whether the target performance parameter value is less than a preset first threshold;

If yes, trigger the first service subset determining module 203 .

In a specific implementation manner of the present invention, the response message sending module 204 is also used for:

When it is judged that the target performance parameter value is greater than or equal to the first threshold, after all services in the service set are processed, a response message is sent to the second process.

Each embodiment in this specification is described in a progressive manner, each embodiment focuses on the difference from other embodiments, and the same or similar parts of each embodiment can be referred to each other. As for the device disclosed in the embodiment, since it corresponds to the method disclosed in the embodiment, the description is relatively simple, and for the related part, please refer to the description of the method part.

Professionals can further realize that the units and algorithm steps of the examples described in conjunction with the embodiments disclosed herein can be implemented by electronic hardware, computer software or a combination of the two. In order to clearly illustrate the possible For interchangeability, in the above description, the composition and steps of each example have been generally described according to their functions. Whether these functions are executed by hardware or software depends on the specific application and design constraints of the technical solution. Those skilled in the art may use different methods to implement the described functions for each specific application, but such implementation should not be regarded as exceeding the scope of the present invention.

The steps of the methods or algorithms described in connection with the embodiments disclosed herein may be directly implemented by hardware, software modules executed by a processor, or a combination of both. Software modules can be placed in random access memory (RAM), internal memory, read-only memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, removable disk, CD-ROM, or any other Any other known storage medium.

In this paper, specific examples are used to illustrate the principles and implementation methods of the present invention, and the descriptions of the above embodiments are only used to help understand the technical solutions and core ideas of the present invention. It should be pointed out that for those skilled in the art, without departing from the principle of the present invention, some improvements and modifications can be made to the present invention, and these improvements and modifications also fall within the protection scope of the claims of the present invention.

Claims (10)

1. A business processing method, characterized in that being applied to the first process, comprising: receiving the service request message sent by the second process; Determine the set of services to be processed according to the service request message; in the business collection determine the first business subset to be answered; After all the services in the first service subset are processed, a response message is sent to the second process. 2. The service processing method according to claim 1, wherein the determining the first service subset to be answered in the service set comprises: For each service in the service set, if the service is a service to be answered, the service is added to the first service subset. 3. The business processing method according to claim 1, characterized in that, after sending the reply message to the second process, or while sending the reply message to the second process, further comprising: : Processing services in the service set that are not the first service subset. 4. The service processing method according to any one of claims 1 to 3, characterized in that, after the service set to be processed is determined according to the service request message, the service set to be processed is determined in the service set Before the first business subset of the answer, also include: judging whether the target performance parameter value is less than a preset first threshold; If yes, perform the operation of determining the first service subset to be answered in the service set. 5. The service processing method according to claim 4, wherein when judging that the target performance parameter value is greater than or equal to the first threshold, further comprising: After processing all the services in the service set, send a response message to the second process. 6. A business processing device, characterized in that it is applied to the first process, comprising: A service request message receiving module, configured to receive a service request message sent by the second process; A service set determination module, configured to determine a service set to be processed according to the service request message; A first service subset determination module, configured to determine a first service subset to be answered in the service set; A response message sending module, configured to send a response message to the second process after processing all services in the first service subset is completed. 7. The service processing device according to claim 6, wherein the first service subset determination module is specifically used for: For each service in the service set, if the service is a service to be answered, the service is added to the first service subset. 8. The business processing device according to claim 6, further comprising a business processing module for: After the sending of the response message to the second process, or at the same time as the sending of the response message to the second process, the services in the service set that are not the first service subset are processed. 9. The service processing device according to any one of claims 6 to 8, further comprising a judging module for: After determining the service set to be processed according to the service request message and before determining the first service subset to be answered in the service set, judging whether the target performance parameter value is less than a preset first threshold; If yes, trigger the first service subset determining module. 10. The service processing device according to claim 9, wherein the response message sending module is also used for: When it is judged that the target performance parameter value is greater than or equal to the first threshold, after all services in the service set are processed, a response message is sent to the second process.