CN106383668B - Information storage method, storage management device and client - Google Patents

Abstract

The invention provides an information storage method, a storage management device and a client. The method comprises the following steps: the client sends an information storage request to the storage management equipment; the storage management equipment responds to the information storage request, selects a storage device as a target storage device of the client according to a preset rule, and sends the information of the target storage device to the client; the method comprises the steps that a client establishes transmission connection with a target storage device, the duration of the transmission connection is monitored, when the duration of the transmission connection reaches a first preset duration, the transmission connection is released, and a new information storage request is sent to a storage management device again. The information storage method can be applied to the storage management equipment and the client. Through the design, the information to be stored in the client can be uniformly distributed in each storage device according to time, so that the load balance of each storage device is realized.

Description

Information storage method, storage management device and client

technical field

The present invention relates to the technical field of distributed storage, and in particular, to an information storage method, a storage management device and a client.

Background technique

In a distributed file system, load balancing is one of the key technologies to improve system performance, which can ensure system stability and service quality. Therefore, it is necessary to ensure that the information to be stored by each client can be evenly distributed on all storage devices. Most of the existing distributed file systems are implemented by centralized streaming storage, that is, each client directly sends the information to be stored to the data distribution device, and then the data distribution device uniformly distributes the information to different storage devices. equipment.

However, the above-mentioned storage method is highly dependent on the data distribution device, and when a problem occurs with the data distribution device, the information of all clients cannot be stored. Moreover, with the increase of the amount of information to be stored, the same data distribution device may be connected to thousands of clients. In this case, the performance requirements of the data distribution device are relatively high, and the performance of the data distribution device will directly affect the performance of the data distribution device. Affects the performance of the entire distributed file system.

SUMMARY OF THE INVENTION

In view of this, the purpose of the present invention is to provide an information storage method, a storage management device and a client, so as to solve the problem that the existing distributed file system has a strong dependence on the data distribution device.

A preferred embodiment of the present invention provides an information storage method, which is applied to a storage management device, and the storage management device can communicate with a client and multiple storage devices, and the method includes:

receiving an information storage request sent by the client at a first preset time interval;

For each information storage request, select a storage device as the target storage device of the client according to a preset rule;

The information of the target storage device is sent to the client, so that the client establishes a transmission connection with the target storage device.

Another preferred embodiment of the present invention provides an information storage method, which is applied to a client, and the client can communicate with a storage management device and multiple storage devices, and the method includes:

sending an information storage request to the storage management device;

receiving the information of the target storage device sent by the storage management device, and establishing a transmission connection with the target storage device;

Monitoring the duration of maintaining the transmission connection, releasing the transmission connection when the duration of maintaining the transmission connection reaches a first preset duration, and sending a new information storage request to the storage management device again.

Another preferred embodiment of the present invention provides a storage management device, the storage management device can communicate with a client and multiple storage devices, and the storage management device includes a storage request receiving module, a storage target selection module, and target information sending module;

The storage request receiving module is configured to receive an information storage request sent by the client every first preset duration;

The storage target selection module is configured to select a storage device as the target storage device of the client according to a preset rule for each information storage request; and

The target information sending module is configured to send the information of the target storage device to the client, so that the client can establish a transmission connection with the target storage device.

Another preferred embodiment of the present invention provides a client, which can communicate with a storage management device and a plurality of storage devices, and the client includes a storage request sending module, a transmission connection establishment module, and a transmission connection monitoring module ;

The storage request sending module is configured to send an information storage request to the storage management device;

the transmission connection establishment module, configured to receive the information of the target storage device sent by the storage management device, and establish a transmission connection with the target storage device; and

The transmission connection monitoring module is configured to monitor the duration of the transmission connection, release the transmission connection when the transmission connection is maintained for a first preset duration, and re-send a new transmission connection to the storage management device. Information storage request.

Compared with the prior art, in the information storage method, the storage management device and the client provided by the embodiment of the present invention, the client applies to the storage management device for a target storage device at a first preset time interval, and the storage management device stores the target storage device according to preset rules. The new target storage device is allocated to the client, so that the client can directly send the information to be stored to the target storage device for storage. The management and distribution of the storage management device can ensure that the information to be stored in the client is evenly distributed among the storage devices according to time, avoiding the storage method of using a data distribution device to receive the information of all clients and then uniformly distributing it in the prior art. series of issues.

Description of drawings

In order to illustrate the technical solutions of the embodiments of the present invention more clearly, the following briefly introduces the accompanying drawings used in the embodiments. It should be understood that the following drawings only show some embodiments of the present invention, and therefore do not It should be regarded as a limitation of the scope, and for those of ordinary skill in the art, other related drawings can also be obtained according to these drawings without any creative effort.

FIG. 1 is a schematic block diagram of a distributed file system according to an embodiment of the present invention.

FIG. 2 is a schematic block diagram of a storage management device according to an embodiment of the present invention.

FIG. 3 is a schematic flowchart of an information storage method according to an embodiment of the present invention.

FIG. 4 is a schematic diagram of sub-steps of step S102 in FIG. 3 .

FIG. 5 is a schematic flowchart of another information storage method provided by an embodiment of the present invention.

FIG. 6 is a schematic flowchart of another information storage method provided by an embodiment of the present invention.

FIG. 7 is a schematic diagram of sub-steps of step S301 in FIG. 6 .

FIG. 8 is a functional module block diagram of a storage management device according to an embodiment of the present invention.

FIG. 9 is a block diagram of sub-module connections of a storage target selection module according to an embodiment of the present invention.

FIG. 10 is a block diagram of functional modules of a client according to an embodiment of the present invention.

FIG. 11 is a block diagram of sub-module connections of a storage request sending module according to an embodiment of the present invention.

Icon: 100 - distributed file system; 110 - storage management device; 111 - storage; 112 - storage controller; 113 - processor; 114 - peripheral interface; 115 - input and output unit; 116 - communication unit; 1101 - storage 1102-storage target selection module; 201-information record query sub-module; 202-first selection sub-module; 203-second selection sub-module; 1103-target information sending module; 1104-task number receiving module; 1105 -Report monitoring module; 120-Client; 121-Storage request sending module; 1211-Identity acquisition sub-module; 1212-Search sub-module; 1213-Request sending sub-module; 122-Transmission connection establishment module; 123-Transmission connection monitoring module ; 130 - storage device; 200 - network.

Detailed ways

In order to make the purposes, technical solutions and advantages of the embodiments of the present invention clearer, the technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments These are some embodiments of the present invention, but not all embodiments. The components of the embodiments of the invention generally described and illustrated in the drawings herein may be arranged and designed in a variety of different configurations.

Thus, the following detailed description of the embodiments of the invention provided in the accompanying drawings is not intended to limit the scope of the invention as claimed, but is merely representative of selected embodiments of the invention. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.

It should be noted that like numerals and letters refer to like items in the following figures, so once an item is defined in one figure, it does not require further definition and explanation in subsequent figures.

Please refer to FIG. 1 , which is a schematic block diagram of a distributed file system 100 according to an embodiment of the present invention. The distributed file system 100 includes a storage management device 110 , a client 120 and a plurality of storage devices 130 . The client 120 and the plurality of storage devices 130 are respectively connected to the storage management device 110 in communication through the network 200, and the client 120 and the plurality of storage devices 130 can establish transmission connections through the network 200 for data communication or interaction .

Wherein, according to actual requirements, the client 120 may be an information collection device, and may also include an exchange server and a plurality of information collection devices in communication with the exchange server.

The storage management device 110 and the storage device 130 may be devices with storage and information processing capabilities, such as a server, a computer, and a terminal.

As shown in FIG. 2 , it is a schematic block diagram of a storage management device 110 provided by an embodiment of the present invention. The storage management device 110 includes a memory 111 , a storage controller 112 , a processor 113 , a peripheral interface 114 , an input and output unit 115 and a communication unit 116 .

The elements of the memory 111 , the storage controller 112 , the processor 113 , the peripheral interface 114 , the input/output unit 115 and the communication unit 116 are directly or indirectly electrically connected to each other to realize data transmission or interaction. For example, these elements may be electrically connected to each other through one or more communication buses or signal lines.

Wherein, the memory 111 may be, but not limited to, random access memory (Random Access Memory, RAM), read only memory (Read Only Memory, ROM), programmable read only memory (Programmable Read-Only Memory, PROM), or Erasable Programmable Read-Only Memory (EPROM), Electrical Erasable Programmable Read-Only Memory (EEPROM), etc.

The memory 111 can be used to store software programs and modules. After receiving the execution instructions, the processor 113 executes the software programs and modules stored in the memory 111 to execute corresponding functional applications and information processing.

The processor 113 may be an integrated circuit chip with information processing capability. The processor 113 may be a general-purpose processor, including a central processing unit (Central Processing Unit, CPU for short), a network processor (Network Processor, NP for short), and the like. It may also be a digital signal processor (DSP), an application specific integrated circuit (ASIC), an off-the-shelf programmable gate array (FPGA) or other programmable logic device, discrete gate or transistor logic, discrete hardware components. The methods, steps, and logic block diagrams disclosed in the embodiments of the present invention can be implemented or executed. A general purpose processor may be a microprocessor or the processor 113 may be any conventional processor or the like.

The peripheral interface 114 is used to couple various input/output devices to the processor 113 and the memory 111 . In some embodiments, the peripheral interface 114, the processor 113, and the memory controller 112 may be implemented in a single chip, and in other embodiments, they may be implemented by separate chips.

The communication unit 116 is configured to establish a communication connection between the storage management device 110 and an external communication terminal through the network 200, and the external communication terminal described here includes the client 120 and the storage device 130 in the embodiment of the present invention.

It can be understood that the structure shown in FIG. 2 is only for illustration, and the storage management device 110 may further include more or less components than those shown in FIG. 2 , or have different configurations from those shown in FIG. 2 . The components shown in FIG. 2 can be implemented in hardware, software, or a combination thereof.

It should be noted that the specific structures and connection methods of the components in the storage device 130 , the client 120 , and other servers and terminals disclosed in the embodiments of the present invention are the same as the structures of the components corresponding to the storage management device 110 . same as the connection method. For example, corresponding software programs and modules are stored in the client 120, and corresponding functional applications can be implemented by executing the software programs and modules. Corresponding software programs and modules are stored in the storage device 130, and corresponding functional applications can be implemented by executing the software programs and modules.

Please refer to FIG. 3 , which is a schematic flowchart of an information storage method provided by an embodiment of the present invention. The information storage method can be applied to the storage management device 110 shown in FIG. 1 . The specific flow and steps shown in FIG. 3 will be described in detail below.

Step S101: Receive an information storage request sent by the client 120 every first preset duration.

The client 120 sends an information storage request to the storage management device 110 every first preset time period. Optionally, the information storage request carries the identity information of the client 120 . The first preset duration may be flexibly set according to actual conditions, which is not limited in this embodiment. For example, the first preset duration may be 5 minutes.

Step S102: For each information storage request, select a storage device 130 as the target storage device of the client 120 according to a preset rule.

Each time the storage management device 110 receives an information storage request sent by the client 120, the storage management device 110 responds to the information storage request, and allocates a new target storage device to the client 120 according to preset rules.

Optionally, the preset rules may be various, for example: the storage management device 110 queries the current number of tasks of each storage device 130, and selects the storage device 130 with the least number of current tasks as the target of the client 120 storage device. The number of tasks of each storage device 130 is the number of clients 120 connected to each storage device 130 for transmission. During implementation, after receiving the information storage request, the storage management device 110 queries the number of clients 120 currently connected to each storage device 130 for transmission. For another example, the storage management device 110 queries the remaining storage space of each storage device 130 , and selects the storage device 130 with the most remaining storage space as the target storage device of the client 120 .

When the preset rule is that the storage management device 110 queries the current number of tasks of each storage device 130, and selects the storage device 130 with the least number of current tasks as the target storage device of the client 120, optionally, the storage device 130 The management device 110 can query the current number of tasks of each storage device 130 by sequentially accessing each storage device 130, or can also receive the current number of tasks reported by each storage device 130 periodically and store it, and query the number of tasks stored by itself when necessary. The query is performed by means of the current task number of the storage device 130 . It should be noted that the period in which each storage device 130 reports the current number of tasks is less than the first preset duration.

Step S103: Send the information of the target storage device to the client 120, so that the client 120 establishes a transmission connection with the target storage device.

The storage management device 110 sends the information of the target storage device to the client 120, and the client 120 establishes a transmission connection with the target storage device after receiving the information of the target storage device.

Optionally, in order to better achieve load balancing and prevent data loss, each time a target storage device is reassigned to the client 120, the storage device 130 that has established a transmission connection with the client 120 needs to be eliminated. . Each time a target storage device is allocated to a client 120, the storage management device 110 may associate the information of the target storage device with the client 120 and store it, that is, the storage management device 110 stores the information of each target storage device 110. The information record of the storage device 130 that establishes a transmission connection with the client 120 within the first preset time period.

As shown in FIG. 4 , in step S102 , the step of selecting a storage device 130 as the target storage device of the client 120 according to a preset rule may include three sub-steps of step S201 , step S202 and step S203 .

Step S201 : query whether there is a storage device 130 that has not established a transmission connection with the client 120 according to the information record. If it does not exist, the storage management device 110 executes step S202, and if it exists, the storage management device 110 executes step S203.

Step S202: Delete the information record of the storage device 130 that establishes a transmission connection with the client 120 within each of the first preset durations in the storage management device 110, and use the storage device 130 with the least number of current tasks as the storage device 130. The target storage device of the client 120.

Step S203 : Use the storage device 130 with the least number of current tasks among the storage devices 130 that have not established a transmission connection with the client 120 as the target storage device of the client 120 .

Each time a target storage device is selected for the client 120 , it is necessary to select the storage device 130 with the least number of current tasks as the target storage device for the client 120 preferentially among the storage devices 130 that have not established a transmission connection with the client 120 . After all storage devices 130 have established transmission connections with the client 120, delete the information record of the target storage device of the client 120 in the storage management device 110, re-query the current number of tasks of all storage devices 130, and re- Start recording the information recording of the target storage device of the client 120 .

Optionally, during the implementation of the information storage method, each storage device 130 may periodically report the current number of tasks to the storage management device 110, so that the storage management device 110 can query its own storage content when needed. , without having to poll each storage device 130.

As shown in FIG. 5 , optionally, the information storage method may further include three steps of step S104 , step S105 and step S106 , which are described in detail as follows.

Step S104: Receive the current number of tasks sent by each storage device 130 every second preset duration.

By each storage device 130 reporting the current number of tasks to the storage management device 110 every second preset time period, the storage management device 110 can save the time for the storage management device 110 to query the current number of tasks of each storage device 130, even if the storage management When the device 110 restarts abnormally, the synchronization of the current number of tasks of each storage device 130 in the storage management device 110 can also be ensured. It should be noted that the second preset duration is shorter than the first preset duration, for example, the first preset duration is 5 minutes, and the second preset duration may be 30 seconds.

Step S105: Record the current number of tasks sent by each storage device 130, and determine whether there is a storage device 130 that has not sent the current number of tasks for a third preset duration.

Step S106 : when there is a storage device 130 that has not sent the current number of tasks for the third preset duration, determine that the storage device 130 is down, and delete the information of the storage device 130 recorded in the storage management device 110 .

The storage management device 110 records the current number of tasks sent by each storage device 130, so that the storage management device 110 can query when necessary. The storage management device 110 determines whether a storage device 130 is down by whether there is a storage device 130 that has not sent the current number of tasks for a third preset duration. When the storage management device 110 has not received the current number of tasks reported by a storage device 130 for the third preset time period, it is determined that the storage device 130 is down, and the storage device recorded in the storage management device 110 is deleted. 130, so that the information stored in the storage management device 110 is synchronized with the actual situation of each storage device 130. After the information of the storage device 130 is deleted, when the storage management device 110 reallocates the storage device 130 for the client 120, the storage device 130 is not queried any more.

Wherein, the third preset duration is greater than the second preset duration, and optionally, the third preset duration may be an integer multiple of the second preset duration. For example, when the second preset duration is 15 seconds, the third preset duration may be 30 seconds.

In the information storage method provided by the embodiment of the present invention, it is only necessary to ensure that each storage device 130 is sufficient to store the information generated by each client 120 during the retention period. Therefore, in order to save storage space, the capacity of each storage device 130 may be allocated as follows: each client 120 has a maximum amount of information collection within the preset retention period, and selects the maximum value among all the maximum information collection amounts , and the product of the maximum value and the number of the clients 120 is taken as the sum of the storage capacities of all the storage devices 130 .

The preset retention period is the time that the user wants to retain the information in each storage device 130 , and can be adjusted according to the actual situation. For example, the preset retention period may be 30 days.

Since the information storage method is to distribute evenly according to the number of tasks, rather than according to the amount of storage, in order to avoid data loss caused by the full storage of some storage devices 130 with smaller storage capacity when the retention period has not been reached, and at the same time for the purpose of To better achieve load balancing, the capacities of the storage devices 130 in this embodiment of the present invention may be equal.

According to the above capacity configuration method, when any storage device 130 is full, it can be considered that the information storage time in the storage device 130 has reached the preset retention period.

Optionally, under the above configuration, in order to prevent data loss caused by the full storage of each storage device 130, a monitoring server can be set up, and the monitoring server deletes each storage device 130 before the current time every fourth preset time period. Stored content prior to a preset retention period.

During implementation, each storage device 130 may record the storage time when storing the information sent from each client 120, and form a file directory, where the file directory includes the storage time of all the information. The monitoring server scans the file directory once every fourth preset period of time, and deletes the storage content before the scanning time is reversed by a preset retention period, so as to prevent the storage devices 130 from being full. It should be noted that the fourth preset duration is less than the retention period. For example, the preset retention period may be 30 days, and the fourth preset duration may be one day.

The capacity of each storage device 130 is allocated according to the preset retention period, and when the storage capacity of each storage device 130 is equal, it is equivalent to dividing the sum of the amount of information collected by each client 120 within the preset retention period according to The time is evenly divided among the storage devices 130 .

Assuming that there are N storage devices 130 in total, under the condition that each storage device 130 operates normally, the amount of information allocated to each storage device 130 is 1/N for each client within the preset retention period. 120 The sum of the amount of information collected.

However, in the actual application process, there may be a situation that a single storage device 130 cannot be used. When a single storage device 130 goes down, the amount of information allocated by the storage device 130 cannot be stored, that is, the time that the information stored in each storage device 130 can be retained is reduced by 1/N. Therefore, before the preset retention period has been reached, some storage devices 130 may become full, and such a situation cannot be detected.

Because the information storage method provided in this embodiment allocates target storage devices to each client 120 according to the current number of tasks of each storage device 130 , and the current number of tasks of each storage device 130 refers to the transmission connection to each storage device 130 Due to the number of clients 120, some clients 120 may continue to select the storage device 130 that has been fully stored for information storage, thereby causing data loss.

In order to solve the above problem, optionally, the information storage method may further include the following steps: each storage device 130 sends an alarm signal to the monitoring server when the storage device 130 is full.

When the monitoring server receives the alarm signal, it can remind the user so that the user can check whether there is a downed storage device 130. When there is a downed storage device 130, it can be manually deleted according to the number of downed storage devices 130. Part of the content in each storage device 130 to avoid data loss.

As shown in FIG. 6 , an information storage method provided by another embodiment of the present invention is applied to the client 120 , and the client 120 can communicate with the storage management device 110 and multiple storage devices 130 . The specific flow and steps shown in FIG. 6 will be described in detail below.

Step S301: Send an information storage request to the storage management device 110.

According to actual requirements, the client 120 may be an information collection device for collecting image information, parameter information, and the like. In this embodiment, taking the collection of image information as an example, the information collection device may be a camera, a video camera, or the like, and is used to collect image information of a vehicle passing through a traffic checkpoint.

During implementation, a task control block may be pre-stored in the client 120, and a timer is set in the task control block. The timer sends an information storage request to the storage management device 110 every time the first preset time period expires, so that the storage management device 110 allocates a storage device to the client 120 according to the information storage request 130.

Step S302: Receive the information of the target storage device sent by the storage management device 110, and establish a transmission connection with the target storage device.

Optionally, the client 120 needs to establish a transmission connection with a storage device 130 within each of the first preset duration, regardless of whether the client 120 has collected information within the preset duration. Through the above design, it can be ensured that the information collected by the client 120 is evenly distributed among the storage devices 130 according to time.

Step S303 : Monitor the maintained duration of the transmission connection, release the transmission connection when the maintained duration of the transmission connection reaches a first preset duration, and re-send a new information storage request to the storage management device 110 .

During implementation, the client 120 may monitor the length of time that the transmission connection is maintained through the timer. The timer may start timing from the moment the client 120 sends the request to the storage management device 110, or may start timing from the moment the client 120 establishes a transmission connection with the target storage device, because two The time difference between the times is in milliseconds, and the specific time from which time is started has no effect on the implementation of the solution, which is not limited in this embodiment.

When the timer expires for the first preset time period, the client 120 releases the transmission connection, and re-sends a new information storage request to the storage management device 110, and the timer starts counting again.

That is, the client 120 needs to send an information storage request to the storage management device 110 every first preset duration, so that the storage management device 110 can re-create the storage management device 110 according to the current number of tasks of each storage device 130. The client 120 allocates the target storage device, so that the information to be stored by the client 120 can be evenly distributed among the storage devices 130 according to time.

According to actual requirements, optionally, the client 120 may include an exchange server and a plurality of the information collection devices that are communicatively connected to the exchange server.

In the above case, as shown in FIG. 7 , the step S301 may include three sub-steps of step S401 , step S402 and step S403 .

Step S401: The exchange server acquires the identity information of the information collection device.

Step S402: The exchange server searches out the task control block corresponding to the identity information according to the identity information.

During implementation, a plurality of the information collection devices send the collected information to the exchange server for storage, and the information carries the identity information of each information collection device. The exchange server stores a plurality of task control blocks, and the corresponding relationship between each task control block and the identity information of each information collection device, and the corresponding relationship can be stored in the form of a hash table.

Wherein, each task control block corresponds to an information collection device, and each time the exchange server receives information sent by the information collection device, it needs to query the task control block corresponding to the identity information of the information collection device. If the task control block corresponding to the identity information of the information collection device cannot be found, a new task control block is created corresponding to the identity information. Optionally, the identity information may be encoded information of the information collection device.

According to actual requirements, during implementation, there may be multiple clients 120 , and multiple clients 120 are connected to the storage management device 110 in communication through the network 200 .

Wherein, when the client 120 is an information collection device, the distributed file system 100 includes a storage management device 110, a plurality of storage devices 130 and a plurality of information collection devices. When the client 120 includes an exchange server and a plurality of the information collection devices connected to the exchange server, the distributed file system 100 includes a storage management device 110, a plurality of storage devices 130, and a plurality of exchange servers and a plurality of information collection devices, the plurality of information collection devices are divided into multiple groups, and each group of information collection devices is communicatively connected to one of the exchange servers.

Step S403: The found task control block sends an information storage request to the storage management device 110.

Through the above design, the information collected by the client 120 can be evenly distributed to each storage device 130 for storage according to the number of tasks, that is, according to time, so as to better achieve load balancing.

Please refer to FIG. 8 , which is a functional block diagram of a storage management device 110 according to an embodiment of the present invention, where the storage management device 110 can communicate with the client 120 and multiple storage devices 130 .

The storage management device 110 includes a storage request receiving module 1101 , a storage target selecting module 1102 and a target information sending module 1103 .

The storage request receiving module 1101 is configured to receive an information storage request sent by the client 120 every first preset duration. For a detailed description of the storage request receiving module 1101 , reference may be made to the description of step S101 shown in FIG. 3 , that is, step S101 can be performed by the storage request receiving module 1101 .

The storage target selection module 1102 is configured to select a storage device 130 as the target storage device of the client 120 according to preset rules for each information storage request. For a detailed description of the storage target selection module 1102 , reference may be made to the description of step S102 shown in FIG. 3 , that is, step S102 can be executed by the storage target selection module 1102 .

The target information sending module 1103 is configured to send the information of the target storage device to the client 120, so that the client 120 establishes a transmission connection with the target storage device. For a detailed description of the target information sending module 1103 , reference may be made to the description of step S103 shown in FIG. 3 , that is, step S103 can be executed by the target information sending module 1103 .

Optionally, the storage management device 110 may further include a task number receiving module 1104 and a report monitoring module 1105 .

The task number receiving module 1104 is configured to receive the current task number sent by each storage device 130 every second preset duration. For a detailed description of the task number receiving module 1104 , reference may be made to the description of step S104 shown in FIG. 5 , that is, step S104 may be executed by the task number receiving module 1104 .

The reporting and monitoring module 1105 is used to record the current number of tasks sent by each storage device 130, and determine whether there is a storage device 130 that does not send the current number of tasks for a third preset duration, and does not send the current task when there is a third preset duration. When the number of storage devices 130 is reached, it is determined that the storage device 130 is down, and the information of the storage device 130 recorded in the storage management device 110 is deleted. Wherein, the third preset duration is greater than the second preset duration.

For a detailed description of the reporting monitoring module 1105, reference may be made to the description of the two steps of step S105 and step S106 shown in FIG.

Optionally, the storage management device 110 stores information records of the storage device 130 that establishes a transmission connection with the client 120 within each of the first preset durations. As shown in FIG. 9 , the storage target selection module 1102 includes an information record query sub-module 201 , a first selection sub-module 202 and a second selection sub-module 203 .

The information record query sub-module 201 is configured to query whether there is a storage device 130 that has not established a transmission connection with the client 120 according to the information record. For a detailed description of the information record query sub-module 201, reference may be made to the description of step S201 shown in FIG.

The first selection sub-module 202 is configured to delete each storage device 130 within the first preset duration in the storage management device 110 when there is no storage device 130 that has not established a transmission connection with the client 120. The client 120 establishes an information record of the storage device 130 connected by the transmission, and uses the storage device 130 with the least number of current tasks as the target storage device of the client 120 . For a detailed description of the first selection sub-module 202 , reference may be made to the description of step S202 shown in FIG. 4 , that is, step S202 may be performed by the first selection sub-module 202 .

The second selection sub-module 203 is used to select the current number of tasks in each storage device 130 that has not established a transmission connection with the client 120 when there is a storage device 130 that has not established a transmission connection with the client 120. The least storage device 130 serves as the target storage device for the client 120 . For a detailed description of the second selection sub-module 203 , reference may be made to the description of step S203 shown in FIG. 4 , that is, step S203 may be performed by the second selection sub-module 203 .

Please refer to FIG. 10 , which is a functional block diagram of a client 120 according to another embodiment of the present invention. The client 120 can communicate with the storage management device 110 and a plurality of storage devices 130 , and the client 120 includes a storage request sending device. Module 121 , transmission connection establishment module 122 and transmission connection monitoring module 123 .

The storage request sending module 121 is configured to send an information storage request to the storage management device 110 . For a detailed description of the storage request sending module 121 , reference may be made to the description of step S301 shown in FIG. 6 , that is, step S301 can be performed by the storage request sending module 121 .

The transmission connection establishing module 122 is configured to receive the information of the target storage device sent by the storage management device 110, and establish a transmission connection with the target storage device. For a detailed description of the transmission connection establishment module 122, reference may be made to the description of step S302 shown in FIG. 6 , that is, step S302 can be executed by the transmission connection establishment module 122 .

The transmission connection monitoring module 123 is configured to monitor the duration of the transmission connection maintained, release the transmission connection when the transmission connection maintained duration reaches the first preset duration, and re-send a new transmission connection to the storage management device 110. information storage request. For a detailed description of the transmission connection monitoring module 123 , reference may be made to the description of step S303 shown in FIG. 6 , that is, step S303 may be performed by the transmission connection monitoring module 123 .

Optionally, the client 120 may include an exchange server and a plurality of information collection devices in communication with the exchange server, and the exchange server includes a plurality of task control blocks. At this time, as shown in FIG. 11 , the storage request module may include an identity acquisition submodule 1211 , a search submodule 1212 and a request sending submodule 1213 stored in the exchange server.

The identity acquisition sub-module 1211 is used to acquire the identity information of the information collection device. For a detailed description of the identity acquisition sub-module 1211 , reference may be made to the description of step S401 shown in FIG. 7 , that is, step S401 may be performed by the identity acquisition sub-module 1211 .

The search sub-module 1212 is used to find out the task control block corresponding to the identity information according to the identity information, wherein the exchange server pre-stores the multiple task control blocks and the multiple information collection devices. The corresponding relationship of the identity information. For a detailed description of the search sub-module 1212 , reference may be made to the description of step S402 shown in FIG. 7 , that is, step S402 may be performed by the search sub-module 1212 .

The request sending sub-module 1213 is configured to control the found task control block to send an information storage request to the storage management device 110 . For a detailed description of the request sending sub-module 1213 , reference may be made to the description of step S403 shown in FIG. 7 , that is, step S403 may be performed by the request sending sub-module 1213 .

To sum up, the information storage method, the storage management device 110 and the client 120 provided by the embodiments of the present invention allocate the target storage device to the client 120 according to preset rules, so that the information to be stored in each client 120 can be evenly distributed over time Distributing in each storage device 130 avoids the problem that the prior art relies heavily on data distribution devices.

In the several embodiments provided by the embodiments of the present invention, it should be understood that the disclosed system and method may also be implemented in other manners. The system and method embodiments described above are merely illustrative, for example, the flowcharts and block diagrams in the accompanying drawings illustrate the architecture, possible implementations of systems, methods and computer program products according to various embodiments of the present invention function and operation. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code that contains one or more functions for implementing the specified logical function(s) executable instructions. It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It is also noted that each block of the block diagrams and/or flowchart illustrations, and combinations of blocks in the block diagrams and/or flowchart illustrations, can be implemented in dedicated hardware-based systems that perform the specified functions or actions , or can be implemented in a combination of dedicated hardware and computer instructions.

In addition, each functional module in each embodiment of the present invention may be integrated to form an independent part, or each module may exist independently, or two or more modules may be integrated to form an independent part.

If the functions are implemented in the form of software function modules and sold or used as independent products, they can be stored in a computer-readable storage medium. Based on this understanding, the technical solution of the present invention can be embodied in the form of a software product in essence, or the part that contributes to the prior art or the part of the technical solution. The computer software product is stored in a storage medium, including Several instructions are used to cause a computer device (which may be a personal computer, an electronic device, or a network device, etc.) to execute all or part of the steps of the methods described in the various embodiments of the present invention. The aforementioned storage medium includes: U disk, mobile hard disk, Read-Only Memory (ROM, Read-Only Memory), Random Access Memory (RAM, Random Access Memory), magnetic disk or optical disk and other media that can store program codes . It should be noted that, herein, the terms "comprising", "comprising" or any other variation thereof are intended to encompass non-exclusive inclusion, such that a process, method, article or device comprising a series of elements includes not only those elements, It also includes other elements not expressly listed or inherent to such a process, method, article or apparatus. Without further limitation, an element qualified by the phrase "comprising a..." does not preclude the presence of additional identical elements in a process, method, article or apparatus that includes the element.

The above are only specific embodiments of the present invention, but the protection scope of the present invention is not limited thereto. Any person skilled in the art can easily think of changes or substitutions within the technical scope disclosed by the present invention. should be included within the protection scope of the present invention. Therefore, the protection scope of the present invention should be based on the protection scope of the claims.

Claims (8)

1. An information storage method applied to a storage management device, wherein the storage management device can communicate with a client and a plurality of storage devices, the method comprising:

receiving an information storage request sent by the client at intervals of a first preset duration; the storage management device stores information records of storage devices which establish transmission connection with the client within each first preset time length;

for each information storage request, inquiring whether storage equipment which is not in transmission connection with the client exists or not according to the information record;

when no storage device which is not in transmission connection with the client exists, deleting the information record of the storage device which is in transmission connection with the client within each first preset time length in the storage management device, and taking the storage device with the minimum current task number as the target storage device of the client; the current task number refers to the number of clients which are in current transmission connection with the storage device;

when a storage device which does not establish transmission connection with the client exists, taking the storage device which does not establish transmission connection with the client as a target storage device of the client;

and sending the information of the target storage equipment to the client so as to enable the client to establish transmission connection with the target storage equipment.

2. The information storage method of claim 1, further comprising:

receiving the current task number sent by each storage device every second preset time interval;

recording the current task number sent by each storage device, judging whether a storage device which does not send the current task number for a third preset time length exists, judging that the storage device is down when the storage device which does not send the current task number for the third preset time length exists, and deleting the information of the storage device recorded in the storage management device, wherein the third preset time length is longer than the second preset time length.

3. An information storage method is applied to a client and is characterized in that the client can communicate with a storage management device and a plurality of storage devices, wherein the storage management device stores information records of the storage devices which establish transmission connection with the client within each first preset time length; the method comprises the following steps:

sending an information storage request to the storage management device;

receiving information of a target storage device sent by the storage management device, and establishing transmission connection with the target storage device;

monitoring the duration of the transmission connection holding, releasing the transmission connection when the duration of the transmission connection holding reaches a first preset duration, and resends a new information storage request to the storage management device, so that when the storage management device receives the information storage request, inquiring whether a storage device which does not establish transmission connection with the client exists according to the information record, when no storage device which is not in transmission connection with the client exists, deleting the information record of the storage device which is in transmission connection with the client within each first preset time length in the storage management device, and taking the storage device with the minimum current task number as the target storage device of the client, and when the storage device which does not establish transmission connection with the client exists, taking the storage device which does not establish transmission connection with the client as a target storage device of the client.

4. The information storage method according to claim 3, wherein the client includes a switching server and a plurality of information collecting devices communicating with the switching server, the switching server including a plurality of task control blocks;

the step of sending an information storage request to the storage management device includes:

the exchange server acquires identity information of the information acquisition equipment;

the exchange server searches out task control blocks corresponding to the identity information according to the identity information, wherein the exchange server is pre-stored with corresponding relations between the plurality of task control blocks and the identity information of the plurality of information acquisition devices; and

and the searched task control block sends an information storage request to the storage management equipment.

5. The storage management equipment is characterized by being capable of communicating with a client and a plurality of storage equipment and comprising a storage request receiving module, a storage target selecting module and a target information sending module;

the storage request receiving module is used for receiving information storage requests sent by the client every first preset time interval; the storage management device stores information records of storage devices which establish transmission connection with the client within each first preset time length;

the storage target selection module is configured to:

for each information storage request, inquiring whether storage equipment which is not in transmission connection with the client exists or not according to the information record; when no storage device which is not in transmission connection with the client exists, deleting the information record of the storage device which is in transmission connection with the client within each first preset time length in the storage management device, and taking the storage device with the minimum current task number as the target storage device of the client; the current task number refers to the number of clients which are in current transmission connection with the storage device; when a storage device which does not establish transmission connection with the client exists, taking the storage device which does not establish transmission connection with the client as a target storage device of the client; and

and the target information sending module is used for sending the information of the target storage equipment to the client so as to enable the client to establish transmission connection with the target storage equipment.

6. The storage management device according to claim 5, wherein the storage management device further comprises a task number receiving module and a report monitoring module;

the task number receiving module is used for receiving the current task number sent by each storage device at intervals of second preset time; and

the report monitoring module is configured to record the current task number sent by each storage device, determine whether there is a storage device for which the third preset time length does not send the current task number, determine that the storage device is down when there is a storage device for which the third preset time length does not send the current task number, and delete the information of the storage device recorded in the storage management device, where the third preset time length is greater than the second preset time length.

7. The client is characterized in that the client can communicate with a storage management device and a plurality of storage devices, wherein information records of the storage devices which establish transmission connection with the client within each first preset time length are stored in the storage management device; the client comprises a storage request sending module, a transmission connection establishing module and a transmission connection monitoring module;

the storage request sending module is used for sending an information storage request to the storage management equipment;

the transmission connection establishing module is used for receiving the information of the target storage device sent by the storage management device and establishing transmission connection with the target storage device; and

the transmission connection monitoring module is configured to monitor a duration of the transmission connection, release the transmission connection when the duration of the transmission connection reaches a first preset duration, and send a new information storage request to the storage management device again, so that the storage management device, when receiving the information storage request, queries whether there is a storage device that has not established a transmission connection with the client according to the information record, when there is no storage device that has not established a transmission connection with the client, deletes the information record of the storage device that has established a transmission connection with the client within each first preset duration in the storage management device, and uses the storage device with the smallest number of current tasks as a target storage device of the client, when there is a storage device that has not established a transmission connection with the client, and taking the storage equipment which has not established transmission connection with the client as the client to obtain target storage equipment.

8. The client of claim 7, wherein the client comprises a switching server and a plurality of information gathering devices in communication with the switching server, wherein the switching server comprises a plurality of task control blocks;

the storage request sending module comprises an identity acquisition sub-module, a search sub-module and a request sending sub-module;

the identity acquisition submodule is used for acquiring identity information of the information acquisition equipment;

the search submodule is used for searching the task control blocks corresponding to the identity information according to the identity information, wherein the corresponding relations between the plurality of task control blocks and the identity information of the plurality of information acquisition devices are prestored in the exchange server;

and the request sending submodule is used for controlling the searched task control block to send an information storage request to the storage management equipment.

Images