CN101741885A - Distributed system and method for processing task flow thereof - Google Patents
Distributed system and method for processing task flow thereof Download PDFInfo
- Publication number
- CN101741885A CN101741885A CN200810219253A CN200810219253A CN101741885A CN 101741885 A CN101741885 A CN 101741885A CN 200810219253 A CN200810219253 A CN 200810219253A CN 200810219253 A CN200810219253 A CN 200810219253A CN 101741885 A CN101741885 A CN 101741885A
- Authority
- CN
- China
- Prior art keywords
- task
- executing
- client
- module
- server
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Landscapes
- Multi Processors (AREA)
- Computer And Data Communications (AREA)
Abstract
The invention discloses a distributed system and a method for processing a task flow thereof, and the method comprises the following steps: acquiring a task flow and an executable task in the task flow by a server, distributing a client side for executing the executable task to the executable task and transmitting the task executing information for executing the executable task to the client side, wherein the information executing information comprises the executable task; receiving and executing the executable task by the client side, and transmitting the task executing result to the server; receiving and storing the task executing result information by the server. When the task flow is processed by the scheme in the invention, aiming at different executable tasks in the task flow, the server can respectively distribute different client sides to the different executable tasks for processing, thus realizing distributed processing on the task flow and network collaboration of the task flow.
Description
Technical field
The present invention relates to the Computer Applied Technology field, the method for particularly a kind of distributed system and distributed system Processing tasks stream.
Background technology
Growing along with computer technology, computer is as a kind of efficient, quick and easy instrument, in increasing organisations and institutions, bringing into play the effect that becomes more and more important, the computer application function is increasing, the application scale also constantly increases, having developed into present networking from initial stand-alone application uses, in networking is used, computer on the network is by the information of the carrying out transmission that links together of wired or wireless mode, increased ageingly, and enriched user's experience.
Computer application is actually by computer and carries out a series of task, for example duplicate a file, start a process, close window or the like, complicated along with computer application, merely only carry out a task and still can not satisfy growing application demand, so the execution sequence be made up of a plurality of tasks occurred, this is carried out sequence and forms task flow, to finish a big task object jointly, the prior art mode of each task in the stream of executing the task, be on a computer, to carry out, after a task in task flow executes, carry out next task again, according to this mode, all tasks in the task flow all are to carry out on same computer, certainly will increase the burden of computer, in addition, growing along with the applications of computer network, demand to the mutual collaborative work between each computer in the network increases day by day, and according to task processing mode of the prior art, it is only to carry out on unit, can't be applied in the network cooperating work, fully appliance computer and Internet resources.
Summary of the invention
At above-mentioned problems of the prior art, the object of the present invention is to provide the method for a kind of distributed task scheduling system and distributed system Processing tasks stream, it can carry out distributed treatment to the task in the task flow, realizes the network cooperating work of task flow.
For achieving the above object, the present invention by the following technical solutions:
A kind of method of distributed system Processing tasks stream, described distributed system comprises server and more than one client, described method comprises step:
Server obtains executing the task in task flow and this task flow, distributes and carries out this client that can execute the task, and send the described task execution information of executing the task of carrying out to described client;
Described client receives described task and carries out information, carries out described executing the task, and task execution result information is sent to described server.
A kind of distributed processing system(DPS) comprises server and more than one client,
Described server comprises:
Be used to store the task memory module of described task flow;
With the task scheduling modules that described task memory module is connected, be used for obtaining task flow from described task memory module, and each task executions order in definite described task flow;
The task trigger module that is connected with described task scheduling modules is used for obtaining described executing the task from described task flow;
With the Task Distribution module that described task trigger module is connected, be used to described executing the task to distribute the described client of executing the task of execution;
With the server com-munication module that described task memory module, described Task Distribution module are connected, be used for sending described task execution information to carrying out described client of executing the task, receive the described task execution result information that described client is returned;
Described client comprises:
The client communication module that is connected with described server is used to receive described task and carries out information, and the described task execution result information that the task action result collection module is collected sends to described server;
With the task status administration module that described client communication module is connected, be used to store described state information of executing the task;
With the task executing units administration module that described task status administration module is connected, be used to search and the described task executing units of executing the task of definite execution,
With the task execution module that described task executing units administration module is connected, be used to adopt described task executing units to carry out described executing the task;
Task action result collection module with described task execution module, described client communication module are connected is used to collect described task execution result information.
Scheme according to the invention described above, it is to become distributed task processing system by server with more than one groups of clients, when task flow is handled, server is to the corresponding client of the executed the task distribution in the task flow, and to client transmission task execution information, this can be executed the task to bring in execution by the client, and task execution result information returned to server, because to each execution that can execute the task, be to bring in execution by the corresponding client of server notification, thereby for each different the executing the task in the task flow, server can be respectively it and distribute different clients, promptly, in the task flow each can be executed the task, can bring in execution by variant client respectively, thereby realize distributed treatment to task flow, realize the network cooperating work of task flow, in addition, can execute the task the distribution client to each the time, be to be undertaken by the server unification, and can return task action result to server after the intact task of each client executing, be convenient to the task implementation status of each client of server monitoring, help centralized management.
Description of drawings
Fig. 1 is the structural representation of distributed system specific embodiment of the present invention;
Fig. 2 is the schematic flow sheet of the specific embodiment one of distributed system Processing tasks stream of the present invention;
Fig. 3 is the schematic flow sheet of the specific embodiment two of distributed system Processing tasks stream of the present invention.
Embodiment
Referring to shown in Figure 1, be the structural representation of distributed system specific embodiment of the present invention, it comprises server 101 and more than one client 102 (describing with in the diagram),
System according to the invention described above, it comprises server 101 and more than one client 102, when task flow is handled, the corresponding client 102 of executed the task distribution in 101 pairs of task flow of server, and carry out this can executing the task of task to client 102 transmissions and carry out information, carrying out this after client 102 these task execution information of reception can execute the task, and task execution result information returned to server 101, for each different the executing the task in the task flow, server 101 can be respectively it and distribute different clients 102, thereby realize distributed treatment to task flow, realize the network cooperating work of task flow, in addition, can execute the task distribution client 102 to each the time, be by server 101 unified carrying out, and can return task action result to server after the intact task of each client executing, be convenient to the task implementation status of each client of server monitoring, help centralized management.
Wherein, above-mentioned server 101 specifically comprises:
With the task scheduling modules 1012 that described task memory module 1011 is connected, be used for obtaining task flow from described task memory module 1011, and each task executions order in definite described task flow;
With the task trigger module 1013 that described task scheduling modules 1012 is connected, be used for obtaining executing the task of current needs execution from described task flow;
With the Task Distribution module 1014 that described task trigger module 1013 is connected, this client that can execute the task is carried out in the executed the task distribution that is used to described task trigger module 1013 to determine;
The server com-munication module 1015 that is connected with described task memory module 1011, described Task Distribution module 1014, be used for carrying out information to carrying out the described client of executing the task 102 transmission tasks, receive the described task execution result information that described client 102 is returned, and described task execution result information sent to described task memory module 1011, stored by this task memory module 1011.
Wherein, the task execution result information that above-mentioned server com-munication module 1015 can also be returned client 102 sends to task memory module 1011, stored by task memory module 1011, thereby, can be so that after the task execution result information of respectively executing the task of server in having obtained the client executing task flow, carry out unified management at these task action result.
Wherein, above-mentioned task memory module 1011 can be provisional storage, also can be permanent storage, can be different according to the different of concrete application need and selection.In addition, the task flow of being stored in this task memory module 1011 can be in several ways to wherein adding, and at this moment, above-mentioned task scheduling modules 1012 can also be used for storing the task flow that the user adds into task memory module 1011.
In addition, described task trigger module 1013 can also be connected with described task memory module 1011, thereby, client 102 to server 101 return task execution result information and by task memory module 1011 storage after, next task trigger module 1013 can also determine that will needs which being carried out can execute the task according to task memory module 1011 stored task execution result information.
In addition, Task Distribution module 1014 is when distributing client for executing the task, for to the different of the consideration of emphasis and the difference that needs, can adopt different strategies to select, for example can divide the function of each client in advance, set promptly that executing the task of a certain type is fixing brings in execution by some clients, after having determined current executing the task of need carrying out, can distribute clients corresponding according to this type that can execute the task, perhaps, also can be the function of each client not to be distinguished, be that each client all can be carried out all types of tasks, when distributing client to executing the task, distribute according to the still surplus memory size that has of each client, can preferentially be chosen as this and can execute the task and distribute the maximum client of the last internal memory that has,, and can increase the processing speed of task flow with the task treating capacity of each client of balance.
In addition, as shown in Figure 1, described client 102 specifically can comprise:
The client communication module 1021 that is connected with server 101 is used for the task execution information that reception server 101 sends, and the task execution result information that task action result collection module 1025 is collected is sent to server 101;
The task status administration module 1022 that is connected with client communication module 1021, the state information of executing the task that is used for task execution information that the client communication module is received is stored;
The task executing units administration module 1023 that is connected with task status administration module 1022 is used to search and definite this task executing units that can execute the task of carrying out;
The task execution module 1024 that is connected with task executing units administration module 1023, the task executing units that is used to adopt task executing units administration module 1023 to determine is carried out described executing the task;
The task action result collection module 1025 that is connected with task execution module 1024, client communication module 1021 is used to collect above-mentioned task executing units and carries out the task execution result information that this can be executed the task.
Wherein, above-mentioned task execution module 1024 can also be connected with described task status administration module 1022, thereby, when task execution module 1024 is carried out above-mentioned executing the task, cause this state information that can execute the task to change after, the state information that task status administration module 1022 can be executed the task this after changing is stored, to realize the centralized management of client.
Wherein, the state information that can execute the task can comprise this task names that can execute the task, this can execute the task be used for finishing which type of function, this can be executed the task, and whether to move and carry out this order that can execute the task be to be sent or the like by which station server, can also comprise other state information.
In addition, in the above-mentioned task executing units administration module 1023, can record the information of the task executing units that this client has, promptly when the new task executing units of one of the every interpolation of this client, can be registered to this task executing units administration module, thereby when the task executing units of determining for executing the task to carry out, can determine corresponding task executing units according to this type that can execute the task.
According to the distributed system of the invention described above, when carrying out concrete distributed task scheduling processing:
The task scheduling modules 1012 of server is obtained a task flow from task memory module 1011, task trigger module 1013 is determined executing the task of a needs execution from the task flow that task scheduling modules 1012 is obtained, and be by Task Distribution module 1014 that this can be executed the task and distribute corresponding client, send to client by server com-munication module 1015 subsequently and carry out this can executing the task of task and carry out information;
After the client communication module 1021 of client 102 receives this task execution information of server 101 transmissions, by task status administration module 1022 this state information that can execute the task is stored earlier, search the task executing units that to execute the task corresponding to this by task executing units administration module 1023, and adopt this task executing units to carry out this by task execution module 1024 and can execute the task, task action result collection module 1025 feeds back to server by client communication module 1021 with this task execution result information after having collected and having carried out this task execution result information that can execute the task;
After the server com-munication module 1015 of server 101 receives the task execution result information of client 102 feedbacks, this task execution result information is sent to task memory module 1011 to be stored, so that server, helps centralized management to the supervision of the task implementation status of each client.
Referring to shown in Figure 2, be the schematic flow sheet of the method specific embodiment one of distributed system Processing tasks stream of the present invention, it comprises step:
Step S201: server obtains a task flow, and the next one that obtains in this task flow can execute the task, and enters step S202;
Step S202: server determine to be carried out above-mentioned client of executing the task, and is this and can executes the task and distribute corresponding client, and carry out information to this client transmission task, comprises in this task execution information that this can execute the task, and enters step S203;
Step S203: the task that the client reception server sends is carried out information, and carries out executing the task of comprising in this task execution information, collects and carries out this task execution result information that can execute the task, enters step S204;
Step S204: client sends the task execution result information of collecting to server, enter step S205;
Step S205: server receives the task execution result information that client sends.
Scheme according to the invention described above, when task flow is handled, server is to the corresponding client of the executed the task distribution in the task flow, and carry out this can executing the task of task to the client transmission and carry out information, client receives to be carried out this after this task execution information and can execute the task, and will carry out this task execution result information that can execute the task and return to server, for each different the executing the task in the task flow, server can be respectively it and distribute different clients, thereby realize distributed treatment to task flow, realize the network cooperating work of task flow, in addition, can execute the task the distribution client to each the time, be to be undertaken by the server unification, and can return task action result to server after the intact task of each client executing, be convenient to the task implementation status of each client of server monitoring, help centralized management.
Wherein, in described step S205, after server has received the task execution result information that client sends, this task execution result information can also be stored.Thereby, can be so that after the task execution result information of respectively executing the task of server in having obtained the client executing task flow, carry out unified management at these task action result.
Wherein, at server is in the time of can executing the task distribution server, for the difference that emphasis is considered and the difference of application need, can adopt different selection strategies, for example can preestablish that executing the task of a certain type is fixing brings in execution by some clients, after having determined current executing the task of need carrying out, can distribute clients corresponding according to this type that can execute the task, perhaps, also can be the function of each client not to be divided, be that each client all can be carried out all types of tasks, when distributing client to executing the task, distribute according to the still surplus memory size that has of each client, can preferentially be chosen as this maximum client of the last internal memory of distribution of can executing the task, with the task treating capacity of each client of balance, and can increase the processing speed of task flow.
Referring to shown in Figure 3, it is the schematic flow sheet of the method specific embodiment two of distributed system Processing tasks stream of the present invention, method in the present embodiment mainly is with the different of the foregoing description one, its further refinement the distributed treatment flow process, it specifically comprises step:
Step S301: server obtains a task flow, enters step S302;
Step S302: server judges whether this task flow is carried out, if, enter step S304, if not, then enter step S303;
Step S303: judge whether this task flow satisfies executive condition,, then enter step S304, if not, then return step S301, obtain next bar task flow if satisfy;
Step S304: the next one that obtains in this task flow can be executed the task, and enters step S305 subsequently;
Step S305: for this client that can execute the task is carried out in above-mentioned executed the task distribution of obtaining, and carry out information to this client transmission task, including this in this task execution information can execute the task, and enters step S306;
Step S306: the task that the client reception server sends is carried out information, and the state information of executing the task that is comprised in this task execution information is stored, and enters step S307 subsequently;
Step S307: client judges whether it has the task executing units that can execute the task corresponding to this, if having, then enters step S308, if do not have, then enters step S309;
Step S308: the task executing units of the above-mentioned correspondence of customer end adopted is carried out this and can be executed the task, and collect and carry out this task execution result information that can execute the task, this task execution result information can be information such as task runs succeeded, task is carried out failure, the task execution is interrupted, also can be the execution result of other types, enter step S309 subsequently;
Step S309: user end to server sends task execution result information, enters step S310 subsequently;
Step S310: server receives the task execution result information that client sends, and this task execution result information is stored.
System schema according to the invention described above, when task flow is handled, server is to the corresponding client of the executed the task distribution in the task flow, and carry out this can executing the task of task to the client transmission and carry out information, after client receives this task execution information, search the task executing units that to execute the task corresponding to this, carrying out this by task executing units can execute the task, client returns to server with task execution result information after collecting and carrying out this task execution result information that can execute the task subsequently, for each different the executing the task in the task flow, server can be respectively it and distribute different clients, thereby realize distributed treatment to task flow, realize the network cooperating work of task flow, in addition, can execute the task the distribution client to each the time, be to be undertaken by the server unification, and can return task action result to server after the intact task of each client executing, be convenient to the task implementation status of each client of server monitoring, help centralized management.
Wherein, in above-mentioned steps S303, judge when whether this task flow satisfies executive condition, the difference that imposes a condition according to each task flow, different judgment modes can be arranged, for example, task flow for some kind need just can begin to carry out after its basic task is complete, then need to judge whether this basis task is complete this moment, then need begin at specific time point to carry out for the task of some kind, for example killing poison regularly, timed backup file or the like, then need to judge whether the time point that reaches default this moment, according to the difference of the type of each task flow, also may have other executive condition, will not give unnecessary details one by one at this.
In above-mentioned steps S305, when server can be executed the task distribution server for this, for the difference that emphasis is considered and the difference of application need, can adopt different strategies to select, for example can establish in advance that executing the task of a certain type is fixing brings in execution by some clients, after having determined current executing the task of need carrying out, can distribute clients corresponding according to this type that can execute the task, perhaps, also can be the function of each client not to be divided, be that each client all can be carried out all types of tasks, when distributing client to executing the task, distribute according to the still surplus memory size that has of each client, can preferentially be chosen as this maximum client of the last internal memory of distribution of can executing the task, with the task treating capacity of each client of balance, and can increase the processing speed of task flow.
In addition, in that client executing is above-mentioned when executing the task, the carrying out to be transformed to as yet and carry out because this can be executed the task from beginning, make its state that variation take place, at this moment, client can also be stored this state information that can execute the task after changing, to help the centralized management of client.
In above-mentioned steps S309, in the task execution result information of user end to server, carry out under this situation about can execute the task having task executing units, the task execution result information of gained can be that above-mentioned task runs succeeded or task is carried out failure or task and carried out information such as be interrupted, do not have under the situation of carrying out this task executing units that can execute the task, carrying out information such as failure but the task execution result information that is sent then can be task executing units or a task of not carrying out this performance element.
Above-described each embodiment of the present invention does not constitute the qualification to protection range of the present invention.Any modification of being done within the spirit and principles in the present invention, be equal to and replace and improvement etc., all should be included within the claim protection range of the present invention.
Claims (11)
1. the method for distributed system Processing tasks stream, described distributed system comprises server and more than one client, described method comprises step:
Server obtains executing the task in task flow and this task flow, distributes and carries out this client that can execute the task, and send the described task execution information of executing the task of carrying out to described client;
Described client receives described task and carries out information, carries out described executing the task, and task execution result information is sent to described server.
2. the method for distributed system Processing tasks stream according to claim 1 is characterized in that, after described server receives described task execution result information, also described task execution result information is stored.
3. distributed task scheduling processing method according to claim 1 is characterized in that, described server obtains from described task flow and can execute the task according to described task execution result information.
4. distributed task scheduling processing method according to claim 1 is characterized in that, described client is also stored described state information of executing the task after receiving described task execution information.
5. according to any described distributed task scheduling processing method of claim 1 to 4, it is characterized in that, described server is the described distribution client of executing the task according to the last memory size or the described type of executing the task of each client when distributing client.
6. a distributed processing system(DPS) comprises server and more than one client, it is characterized in that:
Described server comprises:
Be used to store the task memory module of described task flow;
With the task scheduling modules that described task memory module is connected, be used for obtaining task flow from described task memory module, and each task executions order in definite described task flow;
The task trigger module that is connected with described task scheduling modules is used for obtaining described executing the task from described task flow;
With the Task Distribution module that described task trigger module is connected, be used to described executing the task to distribute the described client of executing the task of execution;
With the server com-munication module that described task memory module, described Task Distribution module are connected, be used for sending described task execution information to carrying out described client of executing the task, receive the described task execution result information that described client is returned;
Described client comprises:
The client communication module that is connected with described server is used to receive described task and carries out information, and the described task execution result information that the task action result collection module is collected sends to described server;
With the task status administration module that described client communication module is connected, be used to store described state information of executing the task;
With the task executing units administration module that described task status administration module is connected, be used to search and the described task executing units of executing the task of definite execution,
With the task execution module that described task executing units administration module is connected, be used to adopt described task executing units to carry out described executing the task;
Task action result collection module with described task execution module, described client communication module are connected is used to collect described task execution result information.
7. distributed task management according to claim 6 system is characterized in that described server com-munication module also is used for described task execution result information is sent to described task memory module;
Described task memory module also is used for described task execution result information is stored.
8. distributed task management according to claim 6 system, it is characterized in that, described task trigger module also is connected with described task memory module, and described task trigger module also is used for obtaining described executing the task according to described task execution result information.
9. distributed task scheduling treatment system according to claim 6 is characterized in that, described task execution module also is connected with described task status administration module.
10. according to any described distributed task scheduling treatment system of claim 6 to 9, it is characterized in that described task memory module is provisional storage or permanent storage.
11., it is characterized in that described Task Distribution module is the described distribution client of executing the task according to the last memory size of described type of executing the task or each client according to any described distributed task management system of claim 6 to 9.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN200810219253A CN101741885A (en) | 2008-11-19 | 2008-11-19 | Distributed system and method for processing task flow thereof |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN200810219253A CN101741885A (en) | 2008-11-19 | 2008-11-19 | Distributed system and method for processing task flow thereof |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN101741885A true CN101741885A (en) | 2010-06-16 |
Family
ID=42464770
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN200810219253A Pending CN101741885A (en) | 2008-11-19 | 2008-11-19 | Distributed system and method for processing task flow thereof |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN101741885A (en) |
Cited By (20)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102622265A (en) * | 2011-01-28 | 2012-08-01 | 天脉聚源(北京)传媒科技有限公司 | Method and system for task distribution |
| CN102970379A (en) * | 2012-12-19 | 2013-03-13 | 中国电子科技集团公司第十五研究所 | Method for realizing load balance among multiple servers |
| CN103905515A (en) * | 2012-12-28 | 2014-07-02 | 北大方正集团有限公司 | Distributed Internet information downloading system and method |
| CN104102740A (en) * | 2014-07-30 | 2014-10-15 | 精硕世纪科技（北京）有限公司 | Distribution type information acquisition system and method |
| CN104283958A (en) * | 2014-10-13 | 2015-01-14 | 宁波公众信息产业有限公司 | System task scheduling method |
| CN104317644A (en) * | 2014-10-13 | 2015-01-28 | 宁波公众信息产业有限公司 | Method for executing system tasks |
| CN105808588A (en) * | 2014-12-31 | 2016-07-27 | 北京瑞狮天智信息技术有限公司 | Crowdsourcing model based distributed directional vertical information search system and method |
| CN105872048A (en) * | 2016-03-30 | 2016-08-17 | 联想(北京)有限公司 | Control method and electronic equipment |
| CN105893156A (en) * | 2016-04-20 | 2016-08-24 | 北京云宏信达信息科技有限公司 | Request processing method of storage and computing system and storage and computing system |
| CN106326006A (en) * | 2016-08-23 | 2017-01-11 | 成都卡莱博尔信息技术股份有限公司 | Task management system aiming at task flow of data platform |
| CN106528189A (en) * | 2015-09-10 | 2017-03-22 | 阿里巴巴集团控股有限公司 | Backup task starting method and device and electronic equipment |
| CN106557471A (en) * | 2015-09-24 | 2017-04-05 | 上海汽车集团股份有限公司 | Method for scheduling task and device |
| CN106844018A (en) * | 2015-12-07 | 2017-06-13 | 阿里巴巴集团控股有限公司 | A kind of task processing method, apparatus and system |
| CN108170524A (en) * | 2017-12-29 | 2018-06-15 | 北京奇虎科技有限公司 | The task processing method and device of a kind of computing cluster |
| CN108255589A (en) * | 2017-08-29 | 2018-07-06 | 平安科技（深圳）有限公司 | Method for scheduling task and server |
| CN108696559A (en) * | 2017-04-11 | 2018-10-23 | 华为技术有限公司 | Method for stream processing and device |
| CN108932157A (en) * | 2017-05-22 | 2018-12-04 | 北京京东尚科信息技术有限公司 | Method, system, electronic equipment and the readable medium of distributed treatment task |
| WO2019144746A1 (en) * | 2018-01-26 | 2019-08-01 | 华为技术有限公司 | Service management method and related devices |
| CN111052683A (en) * | 2018-03-15 | 2020-04-21 | 欧姆龙株式会社 | network system |
| CN113542424A (en) * | 2021-07-19 | 2021-10-22 | 中移（杭州）信息技术有限公司 | Data processing method, apparatus, apparatus and computer program product |
-
2008
- 2008-11-19 CN CN200810219253A patent/CN101741885A/en active Pending
Cited By (28)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102622265A (en) * | 2011-01-28 | 2012-08-01 | 天脉聚源(北京)传媒科技有限公司 | Method and system for task distribution |
| CN102970379A (en) * | 2012-12-19 | 2013-03-13 | 中国电子科技集团公司第十五研究所 | Method for realizing load balance among multiple servers |
| CN103905515A (en) * | 2012-12-28 | 2014-07-02 | 北大方正集团有限公司 | Distributed Internet information downloading system and method |
| CN104102740A (en) * | 2014-07-30 | 2014-10-15 | 精硕世纪科技（北京）有限公司 | Distribution type information acquisition system and method |
| CN104317644B (en) * | 2014-10-13 | 2017-12-29 | 宁波公众信息产业有限公司 | A kind of system task performs method |
| CN104283958A (en) * | 2014-10-13 | 2015-01-14 | 宁波公众信息产业有限公司 | System task scheduling method |
| CN104317644A (en) * | 2014-10-13 | 2015-01-28 | 宁波公众信息产业有限公司 | Method for executing system tasks |
| CN104283958B (en) * | 2014-10-13 | 2018-03-20 | 宁波公众信息产业有限公司 | A kind of system task dispatching method |
| CN105808588A (en) * | 2014-12-31 | 2016-07-27 | 北京瑞狮天智信息技术有限公司 | Crowdsourcing model based distributed directional vertical information search system and method |
| CN105808588B (en) * | 2014-12-31 | 2019-06-18 | 北京瑞狮天智信息技术有限公司 | Distributed orientation vertical information search system and method based on crowdsourcing model |
| CN106528189B (en) * | 2015-09-10 | 2019-05-28 | 阿里巴巴集团控股有限公司 | A kind of method, apparatus and electronic equipment starting backup tasks |
| CN106528189A (en) * | 2015-09-10 | 2017-03-22 | 阿里巴巴集团控股有限公司 | Backup task starting method and device and electronic equipment |
| CN106557471A (en) * | 2015-09-24 | 2017-04-05 | 上海汽车集团股份有限公司 | Method for scheduling task and device |
| CN106844018A (en) * | 2015-12-07 | 2017-06-13 | 阿里巴巴集团控股有限公司 | A kind of task processing method, apparatus and system |
| CN105872048A (en) * | 2016-03-30 | 2016-08-17 | 联想(北京)有限公司 | Control method and electronic equipment |
| CN105872048B (en) * | 2016-03-30 | 2020-03-24 | 联想(北京)有限公司 | Control method and electronic equipment |
| CN105893156A (en) * | 2016-04-20 | 2016-08-24 | 北京云宏信达信息科技有限公司 | Request processing method of storage and computing system and storage and computing system |
| CN105893156B (en) * | 2016-04-20 | 2018-02-09 | 北京云宏信达信息科技有限公司 | Store the request processing method and storage computing system in computing system |
| CN106326006A (en) * | 2016-08-23 | 2017-01-11 | 成都卡莱博尔信息技术股份有限公司 | Task management system aiming at task flow of data platform |
| CN108696559A (en) * | 2017-04-11 | 2018-10-23 | 华为技术有限公司 | Method for stream processing and device |
| CN108696559B (en) * | 2017-04-11 | 2021-08-20 | 华为技术有限公司 | Stream processing method and device |
| CN108932157A (en) * | 2017-05-22 | 2018-12-04 | 北京京东尚科信息技术有限公司 | Method, system, electronic equipment and the readable medium of distributed treatment task |
| CN108255589A (en) * | 2017-08-29 | 2018-07-06 | 平安科技（深圳）有限公司 | Method for scheduling task and server |
| CN108170524A (en) * | 2017-12-29 | 2018-06-15 | 北京奇虎科技有限公司 | The task processing method and device of a kind of computing cluster |
| WO2019144746A1 (en) * | 2018-01-26 | 2019-08-01 | 华为技术有限公司 | Service management method and related devices |
| CN111052683A (en) * | 2018-03-15 | 2020-04-21 | 欧姆龙株式会社 | network system |
| US11374788B2 (en) | 2018-03-15 | 2022-06-28 | Omron Corporation | Network system having master device carrying out part of a process and slave device carrying out remainder of the process |
| CN113542424A (en) * | 2021-07-19 | 2021-10-22 | 中移（杭州）信息技术有限公司 | Data processing method, apparatus, apparatus and computer program product |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN101741885A (en) | Distributed system and method for processing task flow thereof | |
| CN105338061B (en) | A method and system for implementing lightweight message middleware | |
| CN109451072A (en) | A kind of message caching system and method based on Kafka | |
| CN104967652B (en) | Event subscription method, apparatus and system | |
| CN111966289B (en) | Partition optimization method and system based on Kafka cluster | |
| CN101345652B (en) | Data acquisition method and data acquisition equipment | |
| CN104092719B (en) | Document transmission method, device and distributed cluster file system | |
| CN105407180A (en) | Server message pushing method and device | |
| CN106155812A (en) | Method, device, system and the electronic equipment of a kind of resource management to fictitious host computer | |
| CN102739775A (en) | Method for monitoring and managing Internet of Things data acquisition server cluster | |
| CN104504006B (en) | The method and system of data acquisition and parsing to news client | |
| CN108737570A (en) | A kind of information-pushing method, apparatus and system | |
| CN114401284B (en) | Real-time data acquisition and transmission system and method for fixed pollution source treatment working condition | |
| CN103577251A (en) | Event based Internet computing processing system and method | |
| CN107070744A (en) | Server monitoring method | |
| CN102868936A (en) | Method and system for storing video logs | |
| CN103327046A (en) | P2SP system scheduling method, equipment and system based on node service capacity | |
| CN115543582A (en) | Method, system and equipment for unified scheduling of super computing power network | |
| CN103248636A (en) | Offline download system and method | |
| CN105516317B (en) | Efficient acquisition method for power consumption information with multi-level load sharing | |
| CN104038364B (en) | The fault-tolerance approach of distributed stream treatment system, node and system | |
| US20130282846A1 (en) | System and method for processing similar emails | |
| CN102480524B (en) | Web page crawler cooperating method | |
| CN105471107A (en) | Time-sharing task collection method for power grid electric energy measuring system | |
| CN103812691A (en) | Log statistical system and method for cluster load balancing system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| C12 | Rejection of a patent application after its publication | ||
| RJ01 | Rejection of invention patent application after publication |
Application publication date: 20100616 |