Summary of the invention
The embodiment of the present invention provides a kind of multi-server Distributed data processing method, can realize dynamically adding data source, and can adapt to various network.The embodiment of the present invention additionally provides corresponding server and system.
A kind of multi-server Distributed data processing method, comprising:
Central server reads after the data pick-up mission bit stream of remote agent server information and described remote agent server and data merge mission bit stream, send described data pick-up mission bit stream to described remote agent server, described remote agent server is made to extract the data required in described data pick-up mission bit stream, and return the data after compress-encrypt, carry the database server address requiring the data place extracted in described data pick-up mission bit stream;
Receive the data after described compress-encrypt, and the data after the described compress-encrypt that decompresses;
Mission bit stream is merged, by the data composite shipment after decompression in data warehouse according to described data.
A kind of multi-server Distributed data processing method, comprising:
Remote agent server receives data pick-up mission bit stream, carries the database server address requiring the data place extracted in described data pick-up mission bit stream;
Connect according to described database server address and described database server;
The data required in described data pick-up mission bit stream are extracted from described database server;
To the described data compression that is drawn into and encryption;
Send the data after described compress-encrypt to central server.
A kind of central server, comprising:
Transmitting element, after merging mission bit stream at the data pick-up mission bit stream and data that read remote agent server information and described remote agent server, the database server address requiring the data place extracted is carried in described data pick-up mission bit stream, send described data pick-up mission bit stream to described remote agent server, make described remote agent server extract the data required in described data pick-up mission bit stream, and return the data after compress-encrypt;
Receiving element, for receiving the data after described compress-encrypt;
Decompression processing unit, after the data after described receiving element receives compress-encrypt, the data after the described compress-encrypt that decompresses;
Composite shipment unit, for merging mission bit stream according to described data, the data composite shipment after described decompression processing unit being decompressed is in data warehouse.
A kind of remote agent server, comprising:
Receiving element, for receiving data pick-up mission bit stream, carries the database server address requiring the data place extracted in described data pick-up mission bit stream;
Set up unit, connect for the described database server address that receives according to described receiving element and described database server;
Data pick-up unit, for setting up after unit and described database server connect described, extracts the data required in described data pick-up mission bit stream from described database server;
Compress-encrypt processing unit, for the data compression that is drawn into described data pick-up unit and encryption;
Transmitting element, for compressing at described compress-encrypt processing unit and after the data be drawn into described in encrypting, sending the data after described compress-encrypt to central server.
A kind of multi-server Distributed data handling system, comprising:
Central server, remote agent server and database server, described remote agent server has multiple, and the data interaction between described central server and each remote agent server is unrelated;
Central server reads after the data pick-up mission bit stream of remote agent server information and described remote agent server and data merge mission bit stream, carry the database server address requiring the data place extracted in described data pick-up mission bit stream, send described data pick-up mission bit stream to described remote agent server;
Remote agent server receives described data pick-up mission bit stream, the database server address requiring the data place extracted is carried in described data pick-up mission bit stream, connect according to described database server address and described database server, the data required in described data pick-up mission bit stream are extracted from described database server, to the described data compression that is drawn into and encryption, send the data after described compress-encrypt to central server;
Described central server receives the data after described compress-encrypt, and the data after the described compress-encrypt that decompresses, merge mission bit stream according to described data, by the data composite shipment after decompression in data warehouse.
The multi-server Distributed data processing method that the embodiment of the present invention provides, central server is adopted to read after the data pick-up mission bit stream of remote agent server information and described remote agent server and data merge mission bit stream, send described data pick-up mission bit stream to described remote agent server, described remote agent server is made to extract the data required in described data pick-up mission bit stream, and return the data after compress-encrypt, the database server address requiring the data place extracted is carried in described data pick-up mission bit stream, receive the data after described compress-encrypt, and the data after the described compress-encrypt that decompresses, mission bit stream is merged according to described data, by the data composite shipment after decompression in data warehouse.Compared with prior art, the multi-server Distributed data processing method that the embodiment of the present invention provides, can realize dynamically adding data source, and can adapt to various network environment and network quality.
Figure of description
Fig. 1 is an embodiment schematic diagram of distributed data processing method in the embodiment of the present invention;
Fig. 2 is another embodiment schematic diagram of distributed data processing method in the embodiment of the present invention;
Fig. 3 is central server and remote agent server one embodiment schematic diagram in the embodiment of the present invention;
Fig. 4 is central server and another embodiment schematic diagram of remote agent server in the embodiment of the present invention;
Fig. 5 is distributed data processing system one embodiment schematic diagram in the embodiment of the present invention.
Embodiment
The embodiment of the present invention provides a kind of multi-server Distributed data processing method, can realize dynamically adding data source, and can adapt to various network.The embodiment of the present invention additionally provides corresponding server and system.Below be described in detail respectively.
Consult Fig. 1, from the angle of central server, the multi-server Distributed data processing method that the embodiment of the present invention provides comprises:
101, central server reads after the data pick-up mission bit stream of remote agent server information and described remote agent server and data merge mission bit stream, sends described data pick-up mission bit stream to described remote agent server.
Central server reads user configured mission bit stream, find remote agent server information and mission bit stream, described mission bit stream comprises described data pick-up mission bit stream and described data merge mission bit stream, described data are got mission bit stream and are sent to described remote agent server by central server, described remote agent server is made to extract the data required in described data pick-up mission bit stream, and return the data after compress-encrypt, carry the database server address requiring the data place extracted in described data pick-up mission bit stream.
102, the data after described compress-encrypt are received, and the data after the described compress-encrypt that decompresses.
103, mission bit stream is merged according to described data, by the data composite shipment after decompression in data warehouse.
After data decompression after compress-encrypt, merge mission bit stream according to data, by the data composite shipment after decompression in data warehouse, realize the transfer from data source to data warehouse.
In the embodiment of the present invention, central server is adopted to read after the data pick-up mission bit stream of remote agent server information and described remote agent server and data merge mission bit stream, send described data pick-up mission bit stream to described remote agent server, described remote agent server is made to extract the data required in described data pick-up mission bit stream, and return the data after compress-encrypt, the database server address requiring the data place extracted is carried in described data pick-up mission bit stream, receive the data after described compress-encrypt, and the data after the described compress-encrypt that decompresses, mission bit stream is merged according to described data, by the data composite shipment after decompression in data warehouse.Compared with prior art, the multi-server Distributed data processing method that the embodiment of the present invention provides, can realize dynamically adding data source, and can adapt to various network environment and network quality.
Alternatively, on the basis of embodiment corresponding to above-mentioned Fig. 1, can also comprise before step 101: receive user configured remote agent server information and mission bit stream, described mission bit stream comprises described data pick-up mission bit stream, and described data merge mission bit stream and task execution time information.
Alternatively, on the basis of above-described embodiment, can also comprise after step 103: upgrade described task execution time information.
Consult Fig. 2, from remote agent server angle, the multi-server Distributed data processing method that the embodiment of the present invention provides comprises:
201, remote agent server receives data pick-up mission bit stream, carries the database server address requiring the data place extracted in described data pick-up mission bit stream.
202, connect according to described database server address and described database server.
Remote agent server is connected by Agent and database server.
203, from described database server, extract the data required in described data pick-up mission bit stream;
204, to the described data compression that is drawn into and encryption;
205, the data after described compress-encrypt are sent to central server.
In the embodiment of the present invention, remote agent server receives data pick-up mission bit stream, the database server address requiring the data place extracted is carried in described data pick-up mission bit stream, connect according to described database server address and described database server, the data required in described data pick-up mission bit stream are extracted from described database server, to the described data compression that is drawn into and encryption, send the data after described compress-encrypt to central server.Compared with prior art, the multi-server Distributed data processing method that the embodiment of the present invention provides, can realize dynamically adding data source, and can adapt to various network environment and network quality.
Alternatively, on the basis of embodiment corresponding to above-mentioned Fig. 2, can also comprise before the step 204: change and the data be drawn into described in cleaning.
Alternatively, on the basis of above-described embodiment, while step 203, also comprise flag data extract position.
Consult Fig. 3, an embodiment of central server of the present invention and remote agent server comprises: central server 30 and remote agent server 40, and described central server 30 comprises:
Transmitting element 301, after merging mission bit stream at the data pick-up mission bit stream and data that read remote agent server information and described remote agent server, the database server address requiring the data place extracted is carried in described data pick-up mission bit stream, send described data pick-up mission bit stream to described remote agent server, make described remote agent server extract the data required in described data pick-up mission bit stream, and return the data after compress-encrypt;
Receiving element 302, for receiving the data after described compress-encrypt;
Decompression processing unit 303, after the data after described receiving element 302 receives compress-encrypt, the data after the described compress-encrypt that decompresses;
Composite shipment unit 304, for merging mission bit stream according to described data, the data composite shipment after described decompression processing unit 303 being decompressed is in data warehouse.
Described remote agent server 40 comprises:
Receiving element 401, for receiving data pick-up mission bit stream, carries the database server address requiring the data place extracted in described data pick-up mission bit stream;
Set up unit 402, connect for the described database server address that receives according to described receiving element 401 and described database server;
Data pick-up unit 403, for setting up after unit 402 connects with described database server described, extracts the data required in described data pick-up mission bit stream from described database server;
Compress-encrypt processing unit 404, for the data compression that is drawn into described data pick-up unit 403 and encryption;
Transmitting element 405, for compressing at described compress-encrypt processing unit 404 and after the data be drawn into described in encrypting, sending the data after described compress-encrypt to central server.
In the embodiment of the present invention, the transmitting element 301 of central server 30 sends described data pick-up mission bit stream to the receiving element 401 of described remote agent server 40, set up unit 402 to connect in the described database server address that described receiving element 401 receives and described database server 50, data pick-up unit 403 is set up after unit 402 connects with described database server described, the data required in described data pick-up mission bit stream are extracted from described database server, the data compression that compress-encrypt processing unit 404 is drawn into described data pick-up unit 403 encryption, transmitting element 405 sends the data after described compress-encrypt to the receiving element 302 of central server 30, after the data of decompression processing unit 303 after described receiving element 302 receives compress-encrypt, decompress the data after described compress-encrypt, composite shipment unit 304, mission bit stream is merged according to described data, data composite shipment after described decompression processing unit 303 being decompressed is in data warehouse.The central server that the embodiment of the present invention provides and remote agent server can realize dynamically adding data source, and can adapt to various network environment and network quality.
Consult Fig. 4, alternatively, on the basis of above-described embodiment, central server 30 can also comprise:
Described receiving element 302, also for receiving the mission bit stream of user configured remote agent server information and described remote agent server, described mission bit stream comprises described data pick-up mission bit stream, and described data merge mission bit stream and task execution time information.
Updating block 305, for described composite shipment unit by decompress after data composite shipment in data warehouse after, upgrade described task execution time information.
Remote agent server 40 can also comprise:
Conversion cleaning processing unit 406, for compressing at described compress-encrypt processing unit and changing before the data be drawn into described in encrypting and the data be drawn into described in cleaning.
Data markers unit 407, for when described data pick-up unit 403 extracted data, flag data extracts position.
In the embodiment of the present invention, data markers unit 407 is when described data pick-up unit 403 extracted data, and flag data extracts position.After generation network failure, data pick-up unit 403 from the position continuation process of extracted data last time, can reduce the impact that Network Abnormal brings.
Consult Fig. 5, the multi-server Distributed data handling system that the embodiment of the present invention provides comprises:
Central server 30, remote agent server 40 and database server 50, described remote agent server has 4, and the data interaction between described central server 30 and each remote agent server 40 is unrelated;
Central server 30 reads after the data pick-up mission bit stream of remote agent server information and described remote agent server and data merge mission bit stream, carry the database server address requiring the data place extracted in described data pick-up mission bit stream, send described data pick-up mission bit stream to described remote agent server;
Remote agent server 40 receives described data pick-up mission bit stream, the database server address requiring the data place extracted is carried in described data pick-up mission bit stream, connect according to described database server address and described database server, the data required in described data pick-up mission bit stream are extracted from described database server, to the described data compression that is drawn into and encryption, send the data after described compress-encrypt to central server.
Described central server 30 receives the data after described compress-encrypt, and the data after the described compress-encrypt that decompresses, merge mission bit stream according to described data, by the data composite shipment after decompression in data warehouse.
The multi-server Distributed data handling system that the embodiment of the present invention provides carries out compress-encrypt to the data extracted on remote agent server, again the data after compress-encrypt are transferred to central server, ensure that the network security of data, on the other hand, central server is executed the task according to user configuration information, when the data source that adds when there being new data source or have been friends in the past reduces, central server is read by information and just can find, thus achieves and dynamically add data source.And data interaction between central server and any one remote agent server is unrelated, after having a remote agent server to go wrong, other servers can not be affected, and this data interactive mode can make multiple remote agent service carry out data interaction with central server simultaneously, accelerate data interaction speed, improve systematic function.
Only give 4 remote agent servers 40 in the embodiment of the present invention, in fact remote agent server can have multiple, and the quantity of the present invention to remote agent server does not limit.
One of ordinary skill in the art will appreciate that all or part of step realized in above-described embodiment method is that the hardware that can carry out instruction relevant by program completes, this program can be stored in a kind of computer-readable recording medium, the above-mentioned storage medium mentioned can be read-only memory, disk or CD etc.
Above multi-server Distributed data processing method provided by the present invention, server and system are described in detail, for one of ordinary skill in the art, according to the thought of the embodiment of the present invention, all will change in specific embodiments and applications, therefore, this description should not be construed as limitation of the present invention.