CN102271147A - Information delivery system and method thereof - Google Patents
Information delivery system and method thereof Download PDFInfo
- Publication number
- CN102271147A CN102271147A CN2010101979764A CN201010197976A CN102271147A CN 102271147 A CN102271147 A CN 102271147A CN 2010101979764 A CN2010101979764 A CN 2010101979764A CN 201010197976 A CN201010197976 A CN 201010197976A CN 102271147 A CN102271147 A CN 102271147A
- Authority
- CN
- China
- Prior art keywords
- information
- discharge device
- computing node
- gathering discharge
- information gathering
- 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.)
- Granted
Links
- 238000000034 method Methods 0.000 title claims abstract description 70
- 230000005540 biological transmission Effects 0.000 claims description 22
- 230000008569 process Effects 0.000 claims description 6
- 238000012423 maintenance Methods 0.000 claims description 5
- 230000011664 signaling Effects 0.000 claims 3
- 238000012545 processing Methods 0.000 abstract description 41
- 230000015572 biosynthetic process Effects 0.000 description 20
- 230000002452 interceptive effect Effects 0.000 description 6
- 238000004891 communication Methods 0.000 description 5
- 230000004044 response Effects 0.000 description 4
- 230000008901 benefit Effects 0.000 description 3
- 238000013479 data entry Methods 0.000 description 3
- 238000001514 detection method Methods 0.000 description 3
- 230000007246 mechanism Effects 0.000 description 3
- 230000005856 abnormality Effects 0.000 description 2
- 238000004458 analytical method Methods 0.000 description 2
- 238000004364 calculation method Methods 0.000 description 2
- 230000001419 dependent effect Effects 0.000 description 2
- 238000013461 design Methods 0.000 description 2
- 238000010586 diagram Methods 0.000 description 2
- 238000005516 engineering process Methods 0.000 description 2
- 230000006870 function Effects 0.000 description 2
- 238000004806 packaging method and process Methods 0.000 description 2
- 238000009825 accumulation Methods 0.000 description 1
- 230000000903 blocking effect Effects 0.000 description 1
- 239000008280 blood Substances 0.000 description 1
- 210000004369 blood Anatomy 0.000 description 1
- 230000008859 change Effects 0.000 description 1
- 230000006835 compression Effects 0.000 description 1
- 238000007906 compression Methods 0.000 description 1
- 238000013480 data collection Methods 0.000 description 1
- 238000012217 deletion Methods 0.000 description 1
- 230000037430 deletion Effects 0.000 description 1
- 238000005538 encapsulation Methods 0.000 description 1
- 235000003642 hunger Nutrition 0.000 description 1
- 230000000284 resting effect Effects 0.000 description 1
- 230000007480 spreading Effects 0.000 description 1
- 230000009897 systematic effect Effects 0.000 description 1
- 230000001052 transient effect Effects 0.000 description 1
Images
Landscapes
- Computer And Data Communications (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The invention discloses an information delivery system that is used for delivering information in a network. The system comprises: at least a calculating node, which is used for collecting various information from a network; at least information collection and distribution equipment, which is used for receiving and storing the information that is collected by the calculating node; and at least an information analyzer, which is used for obtaining the information from the information collection and distribution equipment and carrying out processing on the information. Each information collection and distribution equipment maintains an active information collection and distribution equipment listing and the calculating node updates an information collection and distribution equipment listing of the calculating node by utilizing the active information collection and distribution equipment listing maintained by the information collection and distribution equipment. In addition, the invention also discloses a method used in the information delivery system as well as information collection and distribution equipment applied in the method.
Description
Technical field
The present invention relates to information gathering, distribution and process field, relate in particular to a kind of distributed, from a plurality of computing node acquisition of informations and information delivery system and method that these distribution of information are handled to the respective handling system.
Background technology
In network, especially in Internet, the scope that is covered along with the network user's continuous increase and network service is more and more wider, often need a large amount of service nodes is deployed in a plurality of different network sites and Internet Service Provider place, so as fast with easily for spreading all over the world and using the user of heterogeneous networks connecting system that service is provided.Frequently, these service nodes need be collected and user-dependent information, and send to central processing node and unify to handle.In this large-scale system, service node and central processing node all are to exist with cluster and/or distributed way usually, thereby, delivery of messages and how to realize that load balancing between the node has just become an importance of this type systematic design between these nodes how.
Applicant of the present invention discloses a kind of main machine detection system in application number is 200910084545.4 patent application, this main machine detection system is based on the thought of cloud security, utilize a large amount of widely distributed detectors to collect host information, and come the host information of collecting from detector is analyzed and handled so that obtains in real time and host information accurately by central module.In this system, the detector of multiple class is adapted to different network topologies, the host information that is provided has also carried out targetedly type at different topological structures and Host Type to be revised, and therefore the host information that needs a kind of mechanism to disperse in a large number is delivered to central module and analyzes and handle.
The existing method that is used for each detector information is sent to central module directly sends to central module with host information.There are two problems in this existing method, and at first, because detector is widely distributed and quantity is huge, and the central module limited amount when a large amount of detectors send host information simultaneously, is easy to cause the communication link of central module blocked and unavailable; Secondly, when the center parts also are distributed in each position in the network, even used existing server cluster and load-balancing technique, also can only guarantee the live load equilibrium of the central module in certain cluster, and can't guarantee the balanced operation of all central modules, wherein there are several central module nodes " to die of hunger " and be easy to cause, and the situation that has other several central module nodes " to make extremely full ".
Therefore, desirablely provide a kind of improved information delivery system and method, it can send to a large amount of message from computing node apace Centroid and handle, and the obvious unbalance and communication blocking of the load that can not cause Centroid.
Summary of the invention
The object of the present invention is to provide a kind of information delivery system and method that can solve or alleviate the problems of the prior art at least, it is particularly suitable for having a large amount of computing nodes to center processing system delivery information situation about handling fast and reliably, wherein the center processing system also has a plurality of distributed Centroids, and these Centroids can be handled the information of sending from computing node with balanced way.
According to an aspect of the present invention, provide a kind of information delivery system that is used at the network delivery information, having comprised: at least one computing node is used for collecting various information from network; At least one information gathering discharge device is used to receive the collected information of described computing node, and stores described information; And at least one information analyser, be used for obtaining information to handle from described information gathering discharge device, wherein each computing node keeps the tabulation of information gathering discharge device, and therefrom select the information gathering discharge device of the information that will send to it, each information gathering discharge device keeps enlivening the tabulation of information gathering discharge device, and and out of Memory collects discharge device and carries out enlivening the tabulation of information gathering discharge device to upgrade this alternately, and described computing node utilizes the information gathering discharge device tabulation that the information gathering discharge device is tabulated and upgraded described computing node that enlivens that described information gathering discharge device kept.
According to another aspect of the present invention, a kind of method of utilizing the information delivery system to transmit information in network is provided, this information delivery system comprises that at least one is used for collecting from network computing node, at least one information gathering discharge device and at least one information analyser of various information, and the method comprising the steps of: described computing node is determined the information gathering discharge device of the information that will send to it; Determined information gathering discharge device receives and stores the collected information of described computing node; And described information analyser is obtained information to handle from described information gathering discharge device, wherein said information gathering discharge device enlivens the tabulation of information gathering discharge device by what collect with out of Memory that discharge device upgrades its maintenance alternately, described computing node is tabulated according to the information gathering discharge device of its maintenance according to the information gathering discharge device tabulation that enlivens that described information gathering discharge device keeps, and described computing node is by selecting one of information gathering discharge device to determine the information gathering discharge device of the information that will send to it from the information gathering discharge device tabulation that it kept.
According to aspect in addition of the present invention, a kind of information gathering discharge device is provided, be used to receive the information of one or more computing node collection and store described information, described information gathering discharge device comprises: message recipient, be used for receiving information from described computing node, and the information that buffer memory received; And information-storing device, be used to receive and store the information of described message recipient institute buffer memory, wherein said information gathering discharge device keeps enlivening the tabulation of information gathering discharge device, collect discharge device with out of Memory and carry out enlivening the tabulation of information gathering discharge device to upgrade this alternately, and the information gathering discharge device tabulation that enlivens that is kept is sent to described computing node to upgrade the information gathering discharge device tabulation of described computing node.
According to another aspect in addition of the present invention, provide a kind of and received information that one or more computing node collects and the method for storing described information from the information gathering discharge device, described information gathering discharge device comprises from described computing node and receives the message recipient and the reception of information and the information that buffer memory received and store the information-storing device of the information of described message recipient institute buffer memory, and described method comprises: and out of Memory is collected discharge device and is carried out alternately enlivening the tabulation of information gathering discharge device with what upgrade that described information gathering discharge device keeps; And the information gathering discharge device tabulation of enlivening that is kept sent to described computing node to upgrade the information gathering discharge device tabulation of described computing node.
Description of drawings
By reading hereinafter detailed description of the preferred embodiment, various other advantage and benefits will become cheer and bright for those of ordinary skills.Accompanying drawing only is used to illustrate the purpose of preferred implementation, and does not think limitation of the present invention.And in whole accompanying drawing, represent identical parts with identical reference symbol.In the accompanying drawings:
Figure 1A-1D schematically shows the block diagram of the various parts in information delivery system according to an embodiment of the invention and this system;
Fig. 2 A-2E schematically shows according to an embodiment of the invention, carries out the message format of the message that the information transmission adopted between each parts of information delivery system;
Fig. 3 schematically shows the flow chart that computing node is according to an embodiment of the invention determined the method for default information receiver;
Fig. 4 schematically shows the flow chart that computing node according to an embodiment of the invention sends to the information unit piece method of message recipient;
The flow chart of the method for " inquiry receiver state " message that Fig. 5 schematically shows according to an embodiment of the invention, message recipient is replied computing node;
Fig. 6 schematically shows according to an embodiment of the invention, message recipient receives from the flow chart of the method for the information unit piece of computing node transmission;
The flow chart that Fig. 7 schematically shows according to an embodiment of the invention, message recipient sends to the information unit piece method of information-storing device;
Fig. 8 schematically shows according to an embodiment of the invention, receive at the information-storing device place and storage from the flow chart of the method 800 of the information unit piece of message recipient;
The flow chart that Fig. 9 schematically shows according to an embodiment of the invention, the information-storing device of information analyser from the information gathering discharge device obtains the method 900 that information handles; And
Figure 10 schematically shows according to an embodiment of the invention, is sent in response to the information request of information analyser by information-storing device the flow chart of the method 1000 of information.
Specific embodiment
The invention will be further described below in conjunction with accompanying drawing and concrete execution mode.In order to prevent unnecessarily fuzzy flesh and blood of the present invention, omitted in the accompanying drawings and irrelevant each parts of theme of the present invention or the irrelevant function in the parts.
Figure 1A is the block diagram of information delivery system 100 according to an embodiment of the invention.As shown in Figure 1, information delivery system 100 comprises a plurality of computing nodes 110 that are widely deployed in the network
1-110
n, each computing node is applicable to from network the information that need be unified to handle by the center processing system of collecting.For example, computing node can be the range detector in the main machine detection system, and it is distributed in the different network topology structures so that collect and the analytically dependent information of host information.
Information delivery system 100 also comprises information gathering discharge device 120
1-120
n, each information gathering discharge device 120
1-120
nComprise message recipient 130
1-130
nWith information-storing device 140
1-140
nBecause information gathering discharge device 120 needs to handle the information from a large amount of computing nodes, so this equipment also is distributed usually.Though these information gathering discharge devices are dispersed on a plurality of server nodes, but each information gathering discharge device all has the autonomy of height, and the integral body of formation of cooperating mutually, and make that for carrying out mutual parts with the information gathering discharge device, the information gathering discharge device is equivalent to transparent unified parts.In the description of back, except the place that needs describe especially, all only be described, but should be understood that described feature is equally applicable to each information gathering discharge device in logic information gathering discharge device.
Message recipient 130
1-130
nThe information that reception sends over from each computing node, and these information are sent to information-storing device 140
1-140
nIn.Information-storing device 140
1-140
nUsually store the information that sends over from message recipient in the mode of message queue.Alternatively, because the information type that computing node sended over is various, therefore, message recipient can be classified to information.And information-storing device also can have to tabulate with each information category information corresponding and stores the information of same type.
According to one embodiment of present invention, the information that certain message recipient received usually can store in the information-storing device that is in same information gathering discharge device apace.Can certainly be as required with information stores that certain message recipient received in the information-storing device of other information collecting devices.All these is within protection scope of the present invention.
In addition, in the above-described embodiments, comprise message recipient 130 and corresponding information-storing device 140 although understand each information gathering discharge device 120, but because of understanding, because the relative independentability of the operation between message recipient 130 and the information-storing device 140, information gathering discharge device 120 can only comprise single message recipient or single information-storing device, perhaps comprise single message recipient and a plurality of information-storing device, perhaps comprise a plurality of message recipients and single information-storing device.In other words, message recipient and information-storing device can be used as independent parts and are present in the information delivery system 100, and irrelevant with information gathering discharge device 120.
Information delivery system 100 also comprises a plurality of information analyser 150
1-150
n, it is from information-storing device 140
1-140
nObtaining wherein canned data analyzes and handles.Alternatively, each information analyser 140 can be handled certain type information, and the information of correspondingly obtaining corresponding types from each information-storing device is handled.Perhaps each information analyser can be handled all types of information, but only handles one type information at every turn, and correspondingly obtains the information that needs to handle type from each information-storing device and handle.All these is within protection scope of the present invention.
Figure 1B-1D has illustrated the structured flowchart of each parts in the information delivery system 100 respectively.Figure 1B shows the structured flowchart of computing node 110, as shown in the figure, computing node 110 comprises that information gathering discharge device list memory 1101, default information collect discharge device and determine device 1103, information-storing device 1105, information unit piece packaging system 1107, information unit piece storage device 1108 and information unit piece dispensing device 1109.Wherein stored information is collected the discharge device tabulation in the information gathering discharge device list memory 1101, because can communicating with a plurality of information gathering discharge devices, each computing node comes to transmit collected information to one of information gathering discharge device according to priority, therefore, each computing node need be stored a plurality of information gathering discharge devices that can communicate with it.Default information collect discharge device determine device 1103 determine acquiescence default in other words, computing node will send the information gathering discharge device of collected information to it.Default information is collected discharge device and is determined that device 1103 can be according to determine default information collection discharge device below with reference to the described method of Fig. 3.Information-storing device 1105 storage by computing node collected, to send to the information gathering discharge device so that the information of further handling, information can have polytype, but because computing node collects the type information similar usually, therefore can essentially identical form with these information stores in information-storing device 1105.Many the information that information unit piece packaging system 1107 is used for that computing node is obtained are encapsulated as an information unit piece, and store in the information unit piece storage device 1108.Computing node can be collected a large amount of information usually.And, need once send many information (for example once sending 10 information) usually in order more efficiently and reliably to send information.For this reason, before transmission information, need the tectonic information cell block, each information unit piece comprises many information that are packaged together.Alternatively, can encrypt the information in each information unit piece and compress according to pre-defined algorithm.Subsequently, it is medium to be sent the information unit piece to be stored into the information unit piece storage device 1108 of computing node.Information unit piece dispensing device 1109 obtains the information unit piece that will send from information unit piece storage device 1108, and this information unit piece is sent to the default information collection discharge device that default information collection discharge device determines that device 1103 is determined.Particularly, information unit piece dispensing device 1109 is according to below in conjunction with the described method of Fig. 4 the information unit piece being sent to message recipient 120 in the information gathering discharge device.
Fig. 2 C shows the structured flowchart of information gathering discharge device 120.Shown in Fig. 2 C, information gathering discharge device 120 comprises message recipient 130, information-storing device 140, status poll device 1201, state interactive device 1202 and enlivens information gathering discharge device memory 1203.Status poll device 1201 is used to handle the equipment query information from computing node 110 or information analyser 150.Can status poll device 1201 determine to receive the information of computing node 110 according to the present load situation of information gathering discharge device 120 or to information analyser 150 transmission information.Therefore as hereinafter in conjunction with Fig. 3 described, " recoil state " message of status poll device 1201 structures message format shown in Fig. 2 B, wherein the loading condition of this information gathering discharge device 120 value with the 0-9 that quantizes is written among the field Self_state, and from enliven information gathering discharge device memory 1203, reads other that known and enliven information gathering discharge device information and be written among the field Active_peers.Generally speaking, quantized value is high more, and it is high more that descriptive information is collected the load of discharge device, and quantized value 0 descriptive information is collected discharge device does not have load substantially.And status poll device 1201 will be constructed good message and be replied computing node 110 as " recoil state " message.
State interactive device 1202 is responsible for carrying out state between information gathering discharge device 120 mutual, so that allow each information gathering discharge device know the state of out of Memory collection discharge device, particularly, the mutual content of the state between the information gathering discharge device comprises:
1, safeguards that enlivening the information gathering discharge device of storing in the information gathering discharge device memory 1203 that enlivens tabulates, and come to give priority for each information gathering discharge device according to response time and other feedback information of other information gathering discharge devices;
2, when information gathering discharge device 120 is in abnormality, message (computing node information with the information unit piece that received, message number) passes to and enliven in the information gathering discharge device tabulation other and enliven the information gathering discharge device, corresponding information is collected discharge device and is sent " resending " message to computing node, sends collected information thereby make this computing node normally to collect discharge device to this corresponding information;
3, when this information gathering discharge device 120 is in abnormality, broadcast the unavailable message of this information gathering discharge device, so as the state interactive device 1202 of other information gathering discharge devices by corresponding enliven in the information gathering discharge device memory 1203 that this information gathering discharge device information of deletion upgrades that it keeps enliven the tabulation of information gathering discharge device; And
4, when this information gathering discharge device 120 is resumed work state, the broadcasting corresponding message is so that the state interactive device 1202 of other information gathering discharge devices joins corresponding the enlivening in the tabulation of information gathering discharge device that information gathering discharge device memory 1203 kept of enlivening with this information gathering discharge device.
The mutual purpose of state between the information gathering discharge device 120 is the fail safe and the availability of guarantee information collection discharge device 120, and guarantee when certain information gathering discharge device breaks down, other information gathering discharge devices can be taken over the operation of information gathering discharge device of breaking down, thereby make the information delivery system effectively to move.As discussed previously, each information gathering discharge device has similar configuration, logically can be used as an information gathering discharge device to all information gathering discharge devices treats, but physically, these information gathering discharge devices can be distributed in a plurality of different network node places, to handle the information from computing node nearby according to network topology structure.The distribution mode of this server node is well-known to those skilled in the art, carries out state between them and also is well known to those skilled in the art alternately.Therefore, all can be in the mode of mutual above-mentioned information between the information gathering discharge device all within the protection range in the application.
Should be noted in the discussion above that message recipient 130 receives after the information unit piece from computing node 110, the information unit piece need be sent to information-storing device 140.The information unit piece processing unit 1302 preferential local information store devices of selecting to be in the same information gathering discharge device 120 140 come the stored information cell block, if the resource of local information store device 140 distributes, then will search the available information memory 140 of other information gathering discharge devices, and the information unit piece sent in this information available memory 140 store.Alternatively, consider, when the message recipient 130 in same information gathering discharge device and information-storing device 140 carry out adopting signal/semaphore transmit mode information when mutual for efficient.
Information-storing device 140 comprises information-storing device 1401, Information Access control device 1402, information receiver 1403, information unit block cache device 1404 and information transmitting apparatus 1405.The important use of information-storing device is to store classifiedly the information of collecting from computing node.Information-storing device 1401 selectively comes stored information in the formation mode, each queue stores one category information wherein, and formation is independent separately, and structure is identical.This structure can guarantee stored information efficiently.Therefore, stored information formation in the information-storing device 1401.In addition, Information Access control device 1402 is guaranteed safe and efficient read-write to the information in the Information Access device 1402 with technology known in the art.Information receiver 1403 receives the information unit piece from message recipient 130, the information unit piece that utilizes information unit block cache device 1404 to come buffer memory to receive, remove the encapsulation of information unit piece subsequently and wherein the information extracted to store in the information-storing device 1401.In with reference to figure 8 described methods, describe the processing of information receiver 1403 below in detail.Information transmitting apparatus 1404 sends to information analyser 150 with canned data in the information-storing device 1401 and handles after information-storing device 140 receives the information request of information analyser 150.The concrete processing of information transmitting apparatus 1404 has provided detailed description in the method in conjunction with Figure 10 hereinafter.
Fig. 2 D shows the structured flowchart of information analyser 150.As shown in the figure, information analyser 150 comprises that information gathering discharge device memory 1501, default information collect discharge device and determine device 1502, information-storing device 1503, information processor 1504 and information acquisition device 1505.Wherein be similar to computing node 110, information analyser 150 need determine therefrom to obtain the information gathering discharge device of information according to network state and information category to be processed, therefore, in the information gathering discharge device memory 1501 stored information collect the tabulation of discharge device and default information collect discharge device determine device 1502 determine acquiescence default in other words, information analyser 150 will therefrom obtain the information gathering discharge device of information.Default information is collected discharge device and is determined that device 1502 is with the definite information gathering discharge device of giving tacit consent to of the mode that is similar to the corresponding intrument 1103 in the computing node.Information acquisition device 1505 is collected discharge device from default information and is determined to obtain information the information-storing device 150 of device 1502 determined information gathering discharge devices, and with this information stores in information-storing device 1503, so that handle by information processor 1504.Describe the operation of information acquisition device 1505 in the method that provides below in conjunction with Fig. 9 in detail.
Below will be in more detail mutual between each parts in the descriptor delivery system 100, can reliably and apace handle by the collected information of computing node guaranteeing by information analyser.
At first, each computing node 110
1-110
nNeed to determine will the information that it is collected to send to the message recipient 130 of which information gathering discharge device
1-130
nBecause the network service situation between computing node and the information gathering discharge device, the loading condition of information gathering discharge device and operating state etc. can change, so each computing node must be monitored at any time and will carry out the information gathering discharge device of information communication with it and upgrade so that communicate with the most reliable information gathering discharge device.Fig. 3 shows the flow chart that computing node is determined the method 300 of default information collection discharge device, and wherein computing node will send to collected information this default information and collect discharge device.
As shown in Figure 3, at step S310, computing node initialization self network settings, and collect canned data collection discharge device tabulation in the discharge device list memory 1101 according to system's setting in advance or network condition initialization information simultaneously.Subsequently at step S320, default information is collected discharge device and is determined that it is that default information is collected discharge device that device 1103 is selected the highest information gathering discharge device of information gathering discharge devices tabulation medium priorities, and the state that default information is collected discharge device is set to be verified.The priority of information gathering discharge device can be according to the network connection state of computing node and this information gathering discharge device, set in advance to wait and specify.Subsequently, default information is collected discharge device and is determined that device 1103 comes alternately to determine by collecting discharge device with default information whether this default information is collected discharge device available, particularly, at step S330, default information is collected discharge device and is determined that device 1103 sends " inquiry message is collected the discharge device state " message to default information collection discharge device, collects " recoil state " message of discharge device to wait for default information." inquiry message is collected the discharge device state " message can adopt the message format shown in Fig. 2 A, and wherein the value of Message_type field is set to 0; The type of the value indicating gage operator node among the field Device_Type is classified to the information that this computing node obtained after helping.If at step S340 wait timeout, be that default information collection discharge device is not replied " inquiry message is collected the discharge device state " message, then in step S345, the information gathering discharge device that information gathering discharge device tabulation medium priority takes second place is set to default information and collects discharge device, and begins the processing of step S330 once more.On the contrary, if at step S340, default information is collected discharge device and is received " recoil state " message, then the state of collecting discharge device in step S350 default information is set to available, if " recoil state " message that is received comprises the known information of enlivening other information gathering discharge devices, then come the information gathering discharge device in the update calculation node to tabulate according to the information of these other information gathering discharge devices.Described the message format of " recoil state " message above in conjunction with Fig. 2 B, if wherein default information is collected the information that discharge device is not known other information gathering discharge devices, then the content of Active_peers field can be sky.Subsequently, default information collection discharge device determines that device 1103 utilizes method 300 states of checking default information collection discharge devices regularly, promptly regularly begins the processing of step S320.
At computing node 110
1-110
nDetermined to send to this default information to the collected information of this computing node and collect discharge device after the default information collection discharge device.As mentioned above, computing node once sends many information in the mode of information unit piece usually, therefore, in the present embodiment, is that example comes descriptive information to send with the information unit piece.Fig. 2 C shows the message format that is used to send the information unit piece, and wherein the value of field Message_type is 2; Value among the field Message_ID is the unique identification of information unit piece.Because the size of an information unit piece may be too big, and can't intactly send in a piece of news, therefore, may need multiple messages to send an information unit piece.Field Is_last indicates whether this message is the last item message of this information unit piece, and value 0 expression is not the last item message, is the last item and be worth 1 expression, when being information unit piece of each complete transmission, the field Is_last in the multiple messages can only be: 0,0, .., 1 combination.Deposit the content of information unit piece among the field Payload.
Fig. 4 schematically shows the flow chart that computing node sends to the information unit piece method of the message recipient in the information gathering discharge device.As shown in Figure 4, in step S410, at first information unit piece dispensing device 1107 judges whether default information is collected discharge device available.If it is unavailable that default information is collected discharge device, then carry out processing shown in Figure 3 and redefine default information collection discharge device.On the contrary, if default information is collected discharge device and can be used, then select the information unit piece that will send in the formation of canned data cell block in the information unit piece storage device 1100, and send this information unit piece is collected discharge device to default information message recipient at step S420.Alternatively, send an information unit piece with multiple messages if desired, then also comprised among the step S420 sending the step that constitutes the multiple messages that carries a complete information cell block.Subsequently, after the transmission of information unit piece finishes, wait for the return information of default information collection discharge device at step S430.If at step S440, information unit piece dispensing device 1107 determines not receive return information, it is wait timeout, then carry out processing shown in Figure 3 by computing node and redefine default information collection discharge device, and the transmission of blockage information cell block is till having determined that default information is collected discharge device at step S450.If receive " successfully receiving " message of returning from the message recipient of information gathering discharge device, then at step S460, information unit piece dispensing device 1107 selects the information unit piece next to be sent in the formation of information unit piece to send.If receive " successfully sending " message of returning from message recipient, then at step S470, information unit piece dispensing device 1107 discharges this information unit piece in the tabulation of information unit piece, and selects the information unit piece next to be sent in the formation of information unit piece to send.If when receiving, then then from the block of information tabulation, take out this information unit piece and send again at step S480 from " resending " message that message recipient returns.The processing among Fig. 4 is carried out in circulation, till the information unit piece that will not send in the formation of information unit piece.
According to top description with reference to the given relevant calculation node of figure 3-Fig. 4 as can be known, computing node determines that regularly default information collects the state of discharge device, to guarantee and can the information that it is collected send to the information gathering discharge device.Computing node is judged according to the information that the information gathering discharge device is returned whether information sends successful, thereby is guaranteed and information can be sent to the information gathering discharge device reliably when collected information is sent to the information gathering discharge device.For example, when message recipient returns " successfully receiving " message, this has only illustrated that message recipient receives the information unit piece that computing node sends, and can not determine the information unit piece whether successfully sent to be used in the information-storing device storage, then computing node is not deleted the information unit piece of institute's buffer memory, but only continues to send next information unit piece.And only return " successfully send " message at message recipient, promptly message recipient successfully sends to the information unit piece after the information-storing device, just deletes the information unit piece of buffer memory in the computing node.Therefore, utilize above-mentioned mechanism, can guarantee reliably the information unit piece to be stored in the information-storing device to be further processed.
In addition, the information gathering discharge device is when replying " inquiry message is collected the discharge device state " message of computing node, other that returns also that it knows enlivens the information of information gathering discharge device, thereby in the time of can guaranteeing further that this information gathering discharge device goes wrong, computing node can send to collected information other information gathering discharge devices, has increased the reliability of information delivery thus.
Fig. 5 and Fig. 6 have provided respectively flow chart corresponding with the method for the computing node shown in Fig. 3 and 4, the correlation method on the information gathering discharge device.Particularly, Fig. 5 shows the flow chart of method 500 that the information gathering discharge device is replied " inquiry message collect discharge device state " message of computing node.Method 500 starts from step S510, and wherein the information gathering discharge device carries out initialization operation, i.e. initialization self network settings, and wait is from the message of computing node.At step S520, receive " inquiry message is collected the discharge device state " message subsequently from computing node, and at step S530, the message of status poll device 1201 structures message format shown in Fig. 2 B.At step S540, status poll device 1201 will be constructed good message and be replied computing node as " recoil state " message subsequently.
Fig. 6 shows the flow chart that message recipient 130 in the information gathering discharge device receives the method 600 of the information unit piece that sends from computing node.As shown in Figure 6, at step S610, the information unit piece processing unit 1302 of message recipient 130 receives the connection request that sends information unit piece message from the request of computing node, and searches the information handling task corresponding with this computing node at step S620 in message pick-up task memory 1301.If this information handling task is also set up, then at the newly-built information handling task of step S630 corresponding to this computing node, and by this information handling task continuation subsequent operation.Subsequently, at step S640, information unit piece processing unit 1302 utilizes the information handling task corresponding to this computing node to receive from message computing node, that comprise the information unit piece (it has the message format shown in Fig. 2 C).As previous with reference to as described in the figure 4, might need multiple messages to send the content of an information unit piece, therefore, alternatively, method 600 comprises that also step S650 cause information handling task judges whether intactly to have received the content (value according to message field Is_last is judged) of an information unit piece.If also do not receive a complete information unit piece in step S650 judgement, then continue a piece of news under reception and the buffer memory by information handling task, till having received a complete information unit piece fully at step S660.After intactly having received an information unit piece, at step S670, by information unit piece processing unit 1302 utilize information handling task with the information unit block cache that received in information unit piece storage device 1303, and send the message that indication " successfully receives " the information unit piece to computing node.Subsequently step S680 by information unit piece processing unit 1302 with receive and the information unit piece of buffer memory sends to information-storing device.If successfully the information unit piece is sent to information-storing device, then utilize information handling task to return the message of " successfully sending " information unit piece to computing node by information unit piece processing unit 1302 at step S690, so that computing node discharges the information unit piece of buffer memory, message recipient also discharges the information unit piece of institute's buffer memory simultaneously.Wait at step S695 subsequently and receive this next information unit piece from this computing node, if receive next information unit piece, then continue the processing that begins from step S640, otherwise after a period of time, finish with this computing node information corresponding Processing tasks or make this information handling task enter resting state at step S697.
Should be noted in the discussion above that above-mentioned information unit piece processing unit 1302 receives the information unit pieces and processing that the information unit piece that is received is sent in the corresponding information memory can executed in parallel.In case and the processing of message recipient occurs unusually, then can send " resending " message to computing node, so that computing node resends the information unit piece.On the contrary, can't handle the information that computing node sends if the load of information gathering discharge device is too high, then can give relevant information gathering discharge device with this advisory alternately by the state between the information gathering discharge device, so that corresponding information is collected discharge device and sent " resending " message to computing node, carry out information delivery thereby make this computing node continuation and this corresponding information collect between discharge device.
The message of above-mentioned " successfully receiving " information unit piece, the message of " successfully sending " information unit piece and " resending " message can be used the message format shown in Fig. 2 D.Particularly, the field Message_ID in this message indicates the unique information number of related information unit piece, to identify the related information unit piece of this message.Value 0,1 and 2 among the field Rcv_state is represented above-mentioned three kinds of states respectively, i.e. " successfully reception ", " successfully sending " and " resending ".
Fig. 7 shows the flow chart that message recipient sends to the information unit piece method of information-storing device.At step S710, information unit piece processing unit 1302 is determined the classification of information according to the information of information unit piece, subsequently at step S 720 inquiry local information store devices, to determine whether the local information store device has memory space to store this information unit piece.If determine that at step S730 the local information store district has not had memory space, then step S740 place information unit piece processing unit 1302 from enliven information gathering discharge device tabulation, choose priority high enliven the information gathering discharge device, and to this equipment " solicited message formation " message takes place at step S750 and with the specified queue of inquiring the information that is used to store respective classes in the information-storing device in this equipment whether idle memory space is arranged.If at step S760, information unit piece processing unit 1302 does not receive " formation can with " message or receives " formation is unavailable " message from this equipment from this equipment, promptly the information-storing device of this equipment does not have the respective stored space to store this information-storing device, then enlivens the information gathering discharge device with what continue to choose other from enliven the tabulation of information gathering discharge device returning step S740.
After having determined information-storing device, utilize information handling task to send the information unit piece to this information-storing device at step S770 information unit piece processing unit 1302.As mentioned above, an information unit piece needs multiple messages to send usually.After the content that sends whole information unit piece, judge whether to receive " receiving " message at step S780 from information-storing device, if in a period of time, do not receive this message, be the response timeout of information-storing device, then turn back to the processing that step S720 restarts to send the information unit piece.On the contrary, if information unit piece processing unit 1302 has been received " receiving " message from information-storing device, then the descriptive information cell block is received and is stored by information-storing device, therefore at step S790, information unit piece processing unit 1302 utilizes information handling task to return " successfully sending " message to the computing node that sends this information unit piece, this information unit piece of buffer memory in step S795 release information unit piece storage device 1303, and the processing of ending method 700.
That Fig. 8 shows is corresponding with method shown in Figure 7, receive at information-storing device 140 places and storage from the flow chart of the method 800 of the information unit piece of message recipient.As shown in Figure 8, in step S810, information-storing device carries out initialization, be included in information accumulation device and be used in the memory space of stored information in 1401 minutes, dividing with the formation of information category information corresponding, in information unit block cache device 1404 of constructing in memory space is used in the information unit piece formation of cache information cell block, and distributes a plurality of progresses of work that message pick-up is handled of carrying out.Subsequently in step S820, information receiver 1403 receives the request of " the solicited message formation " of local information receivers or external information receiver, and judges at step S 830 whether information-storing device is used to store the resource of corresponding information cell block available.Judge whether available standard comprises for the resource of information-storing device: whether whether information unit piece formation full, that information unit block cache device 1404 is used for the cache information cell block is full to be used for storing the message queue of this information in the information-storing device 1401, can not apply for temporary space if be full of, whether local operating state enters critical condition.If can use in step S830 judgement resource, then revise and the memory block user mode that will receive the formation of information category information corresponding and the formation of information unit piece of information (making the memory space that is used to store the maximum fault information that once sends in advance), and return " formation can be used " message to message recipient at step S840 information receiver 1403.Otherwise at step S850, information receiver 1403 returns " formation is unavailable " message to message recipient, so that message recipient can be stored to out of Memory memory requests information unit piece.At step S860 place, information receiver 1403 receives the information unit piece, because each information unit piece needs multiple messages to transmit, therefore information-storing device is according to the sign of each message, be that value among the field Message_ID is stored these message, till having received whole information unit piece.At step S870, information receiver 1403 is assembled these information unit pieces and is carried out decompress(ion)/decryption processing alternatively to restore many information that comprise in the information unit piece, in the corresponding information formation of storing information-storing device 1401 into subsequently.Method is then carried out the processing of step S880, and wherein information receiver 1403 returns " receiving " message to message recipient, and is released in the information unit piece of buffer memory in that step S860 distributes, the information unit block cache device 1404 at step S890.
According to as can be known above-mentioned, message recipient not only can send to the information unit piece local information store device that is in the same information gathering discharge device, but also can be when the local information store device be unavailable, the information unit piece is sent to other information-storing devices reliably store, thereby further guaranteed the reliability of information delivery.In addition, according to top flow chart with reference to figure 3-8, only after information stores is in the respective queue of information-storing device, just progressively discharge the memory space of temporary transient stored information in message recipient and the computing node, thereby guaranteed that collected information can send to information-storing device safely and reliably.
Fig. 9 and 10 shows the information interactive method between information analyser and the information gathering discharge device.Particularly, Fig. 9 shows the information-storing device of information analyser 150 from the information gathering discharge device and obtains the method 900 that information is handled.Therefore, at first, at step S910, information analyser 150 is selected therefrom to obtain the information gathering discharge device that information is handled.Be similar to computing node, information analyser 150 also has the tabulation of information gathering discharge device, and can determine default information collection discharge device to be similar to reference to method shown in Figure 3.Subsequently, at step S920, the network topology structure situation that the information acquisition device 1505 of information analyser 150 is collected between discharge device 120 and the information analyser 150 according to default information is selected information transmission mode, for example, whether whether whether information will encrypt, compress, many information are packed or the like.After having determined information transmission mode, at step S930, the information-storing device 150 that information analyser 150 solicited messages are collected in the discharge device 120 sends the information that specifies number that belongs to certain classification.Particularly, send " solicited message " message to information-storing device 150.The concrete form of this message is shown in Fig. 2 E.The type of the information that field queue_type indication wherein will be handled; Field Message_Num specifies an information transmitted number; Field Is_Compact is a Boolean, indicates whether whether will compress when transmission information (its intermediate value 0 indication is not compressed, and compresses and be worth 1 indication); Field Is_Encrypt is a Boolean, and whether indication will carry out encryption (its intermediate value 0 indication is not encrypted, and is worth 1 indication encryption) when transmission information.Subsequently, at step S940, the information list that information acquisition device 1505 is waited for from information-storing device.If receive corresponding information, then carry out alternatively and decompress or decryption processing at step S950, and with the information stores obtained in the pending information list of information-storing device 1503 so that further handle by information processor 1504.On the contrary, if at step S940 wait timeout, then information acquisition device 1505 turns back to the processing of step S910, handles to select new default information collection discharge device to obtain information from the tabulation of information gathering discharge device.In addition, if at step S960, information acquisition device 1505 determines that the information of obtaining from the information gathering discharge device is less than required predetermined entries to be processed, then can be at step S970, information acquisition device 1505 definite data entries that will continue to obtain, and turn back to step S910, handle from the tabulation of information gathering discharge device, to select new default information collection discharge device to obtain information.
Figure 10 has illustrated with the described method of Fig. 9 corresponding, is sent the method 1000 of information in response to the information request of information analyser 150 by information-storing device 140.This method starts from step S1010, wherein information-storing device 140 receives after " solicited message " message from information analyser 150, determine the type of information by information transmitting apparatus 1405 according to the value among the field queue_type, and in information-storing device 1401, locate the information list of storage the type information.If determine not have in this message queue number to reach the information of the clauses and subclauses of Message_Num appointment, then read full detail clauses and subclauses in this information list at step S1030 at step S1020.Otherwise from this information list, read the data entries of specified number among the field Message_Num at step S1040.Subsequently in step S1050, information transmitting apparatus 1405 is prepared the information that will send according to the transmission means of appointment in " solicited message " message (as whether encrypting and compression etc.).And at step S1060, information transmitting apparatus 1405 sends to the information requested analyzer with ready information, and finishes the transmission of this time information at step S1070, and removes the data entries that has sent from corresponding information list.
Because the quantity of information analyser 150 is general all much smaller than the quantity of computing node, and its usually and the network connection architecture between the information gathering discharge device 120 also comparatively simple, so its TCP reliable transmission that is connected with the information gathering discharge device guarantees time generally just can meet the requirements.So it is simply many that the assurance of the transmission here mechanism is compared with the transmission of information gathering discharge device compared with computing node, and also can accelerate the processing speed of information stores and distribution greatly.
In summary, in information delivery according to the present invention system, computing node to information gathering discharge device transmission data, has increased the flexibility of transmission with the enciphered message block mode; The multiple accepting state feedback of information gathering discharge device is guaranteed the integrality in the information distribution procedure.In addition, computing node is classified to information in the acquisition of information process, has simplified the handling process in early stage of information analyser; The easier employing set form of similar information is transmitted/is resolved, and has also saved transmission bandwidth and parsing time.Information delivery system's employing distributed deployment mode according to the present invention is disposed node, if a station information collection analysis equipment is busy or it is unusual to occur, computing node can send information to available information collection analysis equipment apace, thereby make that main frame delivery system according to the present invention has the reliability height, the advantage that availability is good.
Though above the present invention has been described with reference to embodiment, should be appreciated that can be according to practical application, and each parts of information delivery system are split and merge.For example can there be the information gathering discharge device, but message recipient wherein and information-storing device be present in the information delivery system with parts independently respectively, and message recipient and information-storing device have the state interactive function of information gathering discharge device respectively.
It should be noted the foregoing description the present invention will be described rather than limit the invention, and those skilled in the art can design alternative embodiment under the situation of the scope that does not break away from claims.In the claims, any reference symbol between bracket should be configured to restriction to claim.Word " comprises " not to be got rid of existence and is not listed in element or step in the claim.Being positioned at word " " before the element or " one " does not get rid of and has a plurality of such elements.The present invention can realize by means of the hardware that includes some different elements and by means of the computer of suitably programming.In having enumerated the unit claim of some devices, several in these devices can be to come imbody by same hardware branch.Any order is not represented in the use of word first, second and C grade.Can be title with these word explanations.
Claims (20)
1. information delivery system that is used at the network delivery information comprises:
At least one computing node is used for collecting various information from network;
At least one information gathering discharge device is used to receive the collected information of described computing node, and stores described information; And
At least one information analyser is used for obtaining information handling from described information gathering discharge device,
Wherein each computing node keeps the tabulation of information gathering discharge device, and therefrom selects the information gathering discharge device of the information that will send to it,
Each information gathering discharge device keeps enlivening the tabulation of information gathering discharge device, and collects discharge device with out of Memory and carry out enlivening the tabulation of information gathering discharge device to upgrade this alternately, and
Described computing node utilizes the information gathering discharge device tabulation that the information gathering discharge device is tabulated and upgraded described computing node that enlivens that described information gathering discharge device kept.
2. information delivery as claimed in claim 1 system, wherein said information gathering discharge device also comprises:
Message recipient is used for receiving information from described computing node, and the information that buffer memory received; And
Information-storing device is used to receive and store the information of described message recipient institute buffer memory,
When wherein said message recipient does not have the space to store the information of institute's buffer memory at described information-storing device, the information of institute's buffer memory is sent to the information-storing device of out of Memory collection discharge device.
3. information delivery as claimed in claim 2 system wherein after the information of described message recipient institute buffer memory is received by described information-storing device, discharge the information of institute's buffer memory in the described message recipient, and described computing node discharges collected information.
4. as claim 2 or 3 described information delivery systems, wherein said computing node encapsulated one or more of information with the form of information unit piece before transmission information; And described information-storing device is before the described information of storage, and decapsulation information unit piece is to take out one or more of information wherein.
5. as the described information delivery of among the claim 1-4 any system, wherein each information analyser keeps the tabulation of information gathering discharge device, and therefrom selects therefrom to obtain the information gathering discharge device that information is handled, and
Described information analyser is utilized the information gathering discharge device tabulation that the information gathering discharge device is tabulated and upgraded described information analyser that enlivens that described information gathering discharge device kept.
6. as the described information delivery of among the claim 1-5 any system, wherein said computing node determined from the tabulation of information gathering discharge device and will collect discharge device to its default information that send information before sending collected information, and
Whether described computing node is made regular check on described default information collection discharge device available.
7. as the described information delivery of among the claim 1-6 any system, if wherein described information gathering discharge device breaks down in the information process that receives from computing node, then can give another information gathering discharge device, so that described another information gathering discharge device receives information again from described computing node with this signalling trouble.
8. method of utilizing the information delivery system in network, to transmit information, this information delivery system comprises that at least one is used for collecting from network computing node, at least one information gathering discharge device and at least one information analyser of various information, and the method comprising the steps of:
Described computing node is determined the information gathering discharge device of the information that will send to it;
Determined information gathering discharge device receives and stores the collected information of described computing node; And
Described information analyser is obtained information handling from described information gathering discharge device,
Wherein said information gathering discharge device enlivens the tabulation of information gathering discharge device by what collect with out of Memory that discharge device upgrades its maintenance alternately,
Described computing node enlivens the information gathering discharge device tabulation that the information gathering discharge device is tabulated and upgraded its maintenance according to what described information gathering discharge device kept, and
Described computing node is by selecting one of information gathering discharge device to determine the information gathering discharge device of the information that will send to it from the information gathering discharge device tabulation that it kept.
9. the method for in network, transmitting information as claimed in claim 8, wherein said information gathering discharge device also comprises message recipient and information-storing device, and the step that described information gathering discharge device received and stored the collected information of described computing node comprises:
Described message recipient receives information from described computing node, and the information that buffer memory received; And
Described information-storing device receives and stores the information of described message recipient institute buffer memory,
Wherein when described information-storing device did not have the space to store the information of institute's buffer memory, described method also comprised step: described message recipient sends to the information-storing device that out of Memory is collected discharge device with the information of institute's buffer memory.
10. the method for transmitting information in network as claimed in claim 9 also comprises step:
After described information-storing device has received the information of described message recipient institute buffer memory, discharge the information of institute's buffer memory in the described message recipient, and described computing node discharges collected information.
11., also comprise step as claim 9 or the 10 described methods of in network, transmitting information:
Described computing node encapsulated one or more of information with the form of information unit piece before transmission information; And
Described information-storing device is before the described information of storage, and decapsulation information unit piece is to take out one or more of information wherein.
12. as any the described method of in network, transmitting information among the claim 8-11, wherein each information analyser keeps the tabulation of information gathering discharge device, and therefrom select therefrom to obtain the information gathering discharge device that information is handled, and described method also comprises step:
Described information analyser is utilized the information gathering discharge device tabulation that the information gathering discharge device is tabulated and upgraded described information analyser that enlivens that described information gathering discharge device kept.
13. any the described method of transmitting information in network as among the claim 8-12 also comprises step:
Whether described computing node is made regular check on described default information collection discharge device available.
14. as any the described method of in network, transmitting information among the claim 8-13, also comprise step: if described information gathering discharge device breaks down in the information process that receives from computing node, then give another information gathering discharge device, so that described another information gathering discharge device receives information again from described computing node with this signalling trouble.
15. an information gathering discharge device is used to receive the information of one or more computing node collection and store described information, described information gathering discharge device comprises:
Message recipient is used for receiving information from described computing node, and the information that buffer memory received; And
Information-storing device is used to receive and store the information of described message recipient institute buffer memory,
Wherein said information gathering discharge device keeps enlivening the tabulation of information gathering discharge device, collect discharge device with out of Memory and carry out enlivening the tabulation of information gathering discharge device to upgrade this alternately, and the information gathering discharge device tabulation that enlivens that is kept is sent to described computing node to upgrade the information gathering discharge device tabulation of described computing node.
16. when information gathering discharge device as claimed in claim 15, wherein said message recipient do not have the space to store the information of institute's buffer memory at described information-storing device, the information of institute's buffer memory is sent to the information-storing device of out of Memory collection discharge device.
17. as claim 15 or 16 described information gathering discharge devices, one of them a plurality of information analyser is obtained information from described information gathering discharge device and is handled, and described information gathering discharge device sends to described information analyser to upgrade the information gathering discharge device tabulation of described information analyser with the information gathering discharge device tabulation that enlivens that is kept.
18. as any the described information gathering discharge device among the claim 15-17, if wherein described information gathering discharge device breaks down in the information process that receives from computing node, then can give another information gathering discharge device, so that described another information gathering discharge device receives information again from described computing node with this signalling trouble.
19. one kind receives information that one or more computing node collects and the method for storing described information from the information gathering discharge device, described information gathering discharge device comprises from described computing node and receives the message recipient and the reception of information and the information that buffer memory received and store the information-storing device of the information of described message recipient institute buffer memory, and described method comprises:
Collecting discharge device with out of Memory carries out tabulating with the information gathering discharge device that enlivens that upgrades described information gathering discharge device maintenance alternately; And
The information gathering discharge device tabulation that enlivens that is kept is sent to described computing node to upgrade the information gathering discharge device tabulation of described computing node.
20. method as claimed in claim 19 also comprises step:
When described information-storing device did not have the space to store the information of institute's buffer memory, described method also comprised step: described message recipient sends to the information-storing device that out of Memory is collected discharge device with the information of institute's buffer memory.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN 201010197976 CN102271147B (en) | 2010-06-03 | 2010-06-03 | Information delivery system and method thereof |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN 201010197976 CN102271147B (en) | 2010-06-03 | 2010-06-03 | Information delivery system and method thereof |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN102271147A true CN102271147A (en) | 2011-12-07 |
| CN102271147B CN102271147B (en) | 2013-12-25 |
Family
ID=45053310
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN 201010197976 Expired - Fee Related CN102271147B (en) | 2010-06-03 | 2010-06-03 | Information delivery system and method thereof |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN102271147B (en) |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104137494A (en) * | 2012-02-29 | 2014-11-05 | 瑞典爱立信有限公司 | Compound masking and entropy for data packet classification using tree-based binary pattern matching |
| CN106529951A (en) * | 2016-12-30 | 2017-03-22 | 杭州云象网络技术有限公司 | Node consensus verification method under league chain network through asynchronous mode |
| CN108881378A (en) * | 2018-05-02 | 2018-11-23 | 象翌微链科技发展有限公司 | A kind of transmission method of file, system and equipment |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1175832A (en) * | 1996-08-28 | 1998-03-11 | 冲电气工业株式会社 | Information transmission system, information memory and providing device, and information receiving device |
| CN1512363A (en) * | 2002-12-31 | 2004-07-14 | 联想(北京)有限公司 | Method for improving serviceability of business machine group |
| CN1577314A (en) * | 2003-07-24 | 2005-02-09 | 国际商业机器公司 | Cluster data port services for clustered computer system |
| CN1998217A (en) * | 2004-05-28 | 2007-07-11 | 慕斯特有限公司 | System and method for replication, integration, consolidation and mobilisation of data |
| CN101312457A (en) * | 2002-03-28 | 2008-11-26 | 普里凯许公司 | Method, router, apparatus and the network used in a publish-subscribe network |
| CN101490665A (en) * | 2006-07-12 | 2009-07-22 | 国际商业机器公司 | Systems, methods and computer program products for performing remote data storage for client devices |
| CN101681340A (en) * | 2007-04-17 | 2010-03-24 | 肯尼思·托拉 | Non-intrusive method and system for collecting information transmitted over a network |
-
2010
- 2010-06-03 CN CN 201010197976 patent/CN102271147B/en not_active Expired - Fee Related
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1175832A (en) * | 1996-08-28 | 1998-03-11 | 冲电气工业株式会社 | Information transmission system, information memory and providing device, and information receiving device |
| CN101312457A (en) * | 2002-03-28 | 2008-11-26 | 普里凯许公司 | Method, router, apparatus and the network used in a publish-subscribe network |
| CN1512363A (en) * | 2002-12-31 | 2004-07-14 | 联想(北京)有限公司 | Method for improving serviceability of business machine group |
| CN1577314A (en) * | 2003-07-24 | 2005-02-09 | 国际商业机器公司 | Cluster data port services for clustered computer system |
| CN1998217A (en) * | 2004-05-28 | 2007-07-11 | 慕斯特有限公司 | System and method for replication, integration, consolidation and mobilisation of data |
| CN101490665A (en) * | 2006-07-12 | 2009-07-22 | 国际商业机器公司 | Systems, methods and computer program products for performing remote data storage for client devices |
| CN101681340A (en) * | 2007-04-17 | 2010-03-24 | 肯尼思·托拉 | Non-intrusive method and system for collecting information transmitted over a network |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104137494A (en) * | 2012-02-29 | 2014-11-05 | 瑞典爱立信有限公司 | Compound masking and entropy for data packet classification using tree-based binary pattern matching |
| CN104137494B (en) * | 2012-02-29 | 2017-06-06 | 瑞典爱立信有限公司 | The composite shielding and entropy of the sorting packets matched using the binary mode based on tree |
| CN106529951A (en) * | 2016-12-30 | 2017-03-22 | 杭州云象网络技术有限公司 | Node consensus verification method under league chain network through asynchronous mode |
| CN108881378A (en) * | 2018-05-02 | 2018-11-23 | 象翌微链科技发展有限公司 | A kind of transmission method of file, system and equipment |
Also Published As
| Publication number | Publication date |
|---|---|
| CN102271147B (en) | 2013-12-25 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108009028B (en) | Message processing method, device, equipment and computer readable storage medium | |
| KR101887581B1 (en) | Flow-based packet transport device and packet management method thereof | |
| CN113596150B (en) | Message pushing method, device, computer equipment and storage medium | |
| CN101114978A (en) | System and method for sending client request from cache to application server | |
| CN101938502B (en) | Server cluster system and load balancing method | |
| KR101618989B1 (en) | Method of failover for network device in software defined network environment | |
| US20100229182A1 (en) | Log information issuing device, log information issuing method, and program | |
| US9237077B2 (en) | Monitoring persistent client connection status in a distributed server environment | |
| JP6200376B2 (en) | In-vehicle information system and information processing method thereof | |
| CN110096381B (en) | Method, device, equipment and medium for realizing remote procedure call | |
| KR101916799B1 (en) | Apparatus And Method For Big Data Server Load Balancing Control | |
| CN102271147B (en) | Information delivery system and method thereof | |
| CN114401258A (en) | Short message sending method, device, electronic device and storage medium | |
| JPWO2016129275A1 (en) | Information processing apparatus, log management system, log management method, and program | |
| US7603423B2 (en) | Communication system with primary device and standby device to prevent suspension of service of the system | |
| KR20200018343A (en) | Paging failure prediction method using nwdaf, and paging failure prediction device by performing the method | |
| JP2005309838A (en) | Information management system, information management method, and information management subsystem therefor | |
| CN108270839B (en) | Access frequency control system and method | |
| WO2022152230A1 (en) | Information flow identification method, network chip, and network device | |
| JP5408620B2 (en) | Data distribution management system and data distribution management method | |
| US11226887B1 (en) | User code deployment across compute resource partitions | |
| US20150358403A1 (en) | Method, system, apparatus and computer program product for communication management | |
| JP6117345B2 (en) | Message system that avoids degradation of processing performance | |
| CN115114361B (en) | Resource retrieval method and system based on unified interface of container cloud platform | |
| CN107483384B (en) | Network data interaction method and device |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| C14 | Grant of patent or utility model | ||
| GR01 | Patent grant | ||
| ASS | Succession or assignment of patent right |
Owner name: NSFOCUS TECHNOLOGY CO., LTD. Effective date: 20140318 |
|
| C41 | Transfer of patent application or patent right or utility model | ||
| TR01 | Transfer of patent right |
Effective date of registration: 20140318 Address after: 100089 Beijing city Haidian District Road No. 4 North wa Yitai five storey building Patentee after: NSFOCUS INFORMATION TECHNOLOGY Co.,Ltd. Patentee after: NSFOCUS TECHNOLOGIES Inc. Address before: 100089 Beijing city Haidian District Road No. 4 North wa Yitai three storey building Patentee before: NSFOCUS INFORMATION TECHNOLOGY Co.,Ltd. |
|
| CP01 | Change in the name or title of a patent holder | ||
| CP01 | Change in the name or title of a patent holder |
Address after: 100089 Beijing city Haidian District Road No. 4 North wa Yitai five storey building Patentee after: NSFOCUS Technologies Group Co.,Ltd. Patentee after: NSFOCUS TECHNOLOGIES Inc. Address before: 100089 Beijing city Haidian District Road No. 4 North wa Yitai five storey building Patentee before: NSFOCUS INFORMATION TECHNOLOGY Co.,Ltd. Patentee before: NSFOCUS TECHNOLOGIES Inc. |
|
| CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20131225 |
|
| CF01 | Termination of patent right due to non-payment of annual fee |