Nothing Special   »   [go: up one dir, main page]

CN109600436B - A kind of distributed iscsi service realization method, system and related device - Google Patents

A kind of distributed iscsi service realization method, system and related device Download PDF

Info

Publication number
CN109600436B
CN109600436B CN201811504765.3A CN201811504765A CN109600436B CN 109600436 B CN109600436 B CN 109600436B CN 201811504765 A CN201811504765 A CN 201811504765A CN 109600436 B CN109600436 B CN 109600436B
Authority
CN
China
Prior art keywords
target
node
nodes
distributed
client
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.)
Active
Application number
CN201811504765.3A
Other languages
Chinese (zh)
Other versions
CN109600436A (en
Inventor
周文帅
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
IEIT Systems Co Ltd
Original Assignee
Inspur Electronic Information Industry Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Inspur Electronic Information Industry Co Ltd filed Critical Inspur Electronic Information Industry Co Ltd
Priority to CN201811504765.3A priority Critical patent/CN109600436B/en
Publication of CN109600436A publication Critical patent/CN109600436A/en
Application granted granted Critical
Publication of CN109600436B publication Critical patent/CN109600436B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/10Protocols in which an application is distributed across nodes in the network
    • H04L67/1097Protocols in which an application is distributed across nodes in the network for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer And Data Communications (AREA)

Abstract

本申请所提供的一种分布式iscsi服务实现方法,包括:读取分布式存储系统中所有节点的节点信息;控制目标节点中的目标客户端根据节点信息向其他所有节点的服务端发送连接请求;其中,目标节点为分布式存储系统中的任一节点;利用目标客户端接收服务端发送的响应消息,建立目标节点与其他所有节点之间的单向连接;利用目标节点中的目标服务端接收其他所有节点的客户端发送的连接请求;控制目标服务端向客户端发送响应消息,建立目标节点与其他所有节点之间的双向连接。该方法实现了分布式存储系统中分布式的iscsi服务。本申请还提供一种分布式iscsi服务实现系统、分布式存储系统及计算机可读存储介质,均具有上述有益效果。

Figure 201811504765

A distributed iscsi service implementation method provided by this application includes: reading node information of all nodes in a distributed storage system; controlling a target client in a target node to send connection requests to servers of all other nodes according to the node information ; wherein, the target node is any node in the distributed storage system; use the target client to receive the response message sent by the server, and establish a one-way connection between the target node and all other nodes; use the target server in the target node Receive connection requests sent by clients of all other nodes; control the target server to send a response message to the client to establish a two-way connection between the target node and all other nodes. The method realizes the distributed iscsi service in the distributed storage system. The present application also provides a distributed iscsi service implementation system, a distributed storage system and a computer-readable storage medium, all of which have the above beneficial effects.

Figure 201811504765

Description

Distributed iscsi service implementation method, system and related device
Technical Field
The present application relates to the field of storage technologies, and in particular, to a method and a system for implementing a distributed iscsi service, a distributed storage system, and a computer-readable storage medium.
Background
Currently, iscsi services are used in distributed storage systems to provide storage block traffic externally. The iscsi technology is a SCSI command set used by hardware devices and capable of running on the upper layer of the IP protocol, and this command set can implement running SCSI protocol on the IP network, so that routing can be performed on, for example, a high-speed gigabit ethernet network.
However, the iscsi services are independently deployed on each node of the distributed storage system, and once the main node is abnormal, the iscsi services of each node in the whole distributed storage system cannot work normally.
Therefore, how to implement distributed iscsi services in a distributed storage system, and further, even if the master node is abnormal, the iscsi services of the distributed storage system can also work normally is a technical problem to be solved by those skilled in the art.
Disclosure of Invention
The purpose of the application is to provide a distributed iscsi service implementation method, a distributed iscsi service implementation system, a distributed storage system and a computer readable storage medium, which can implement distributed iscsi services in the distributed storage system, and further enable the iscsi services of the distributed storage system to work normally even if a host node is abnormal.
In order to solve the above technical problem, the present application provides a method for implementing a distributed iscsi service, including:
reading node information of all nodes in the distributed storage system;
a target client in the control target node sends a connection request to the server of all other nodes according to the node information; wherein the target node is any node in the distributed storage system;
receiving a response message sent by the server by using the target client, and establishing one-way connection between the target node and all other nodes;
receiving connection requests sent by the clients of all other nodes by using a target server in the target node;
and controlling the target server to send a response message to the client, and establishing the bidirectional connection between the target node and all other nodes.
Preferably, the step of sending a connection request to the servers of all other nodes by the target client in the control target node according to the node information includes:
controlling the target client in the target node to create a target client sub-thread;
and sending the connection request to the server sides of all other nodes by using the target client side sub-thread according to the node information.
Preferably, the receiving, by a target server in the target node, the connection request sent by the clients of all other nodes includes:
controlling the target server in the target node to create a target server sub-thread;
and receiving the connection requests sent by the clients of all other nodes by using the target service terminal thread.
Preferably, after establishing the bidirectional connection between the target node and all other nodes, the method further includes:
and binding the information corresponding to the bidirectional connection between the target node and all other nodes and the node information of all other nodes and recording the information into the target node.
The present application further provides a distributed iscsi service implementation system, including:
the node information reading module is used for reading node information of all nodes in the distributed storage system;
the connection request sending control module is used for controlling a target client in a target node to send connection requests to the servers of all other nodes according to the node information; wherein the target node is any node in the distributed storage system;
the unidirectional connection establishing module is used for receiving a response message sent by the server by using the target client and establishing unidirectional connection between the target node and all other nodes;
a connection request receiving module, configured to receive, by using a target server in the target node, connection requests sent by clients of all other nodes;
and the bidirectional connection establishing module is used for controlling the target server to send a response message to the client and establishing bidirectional connection between the target node and all other nodes.
Preferably, the connection request sending control module includes:
the target client sub-thread creation control unit is used for controlling the target client in the target node to create a target client sub-thread;
and the connection request sending unit is used for sending the connection request to the server sides of all other nodes by using the target client sub-thread according to the node information.
Preferably, the connection request receiving module includes:
the target service terminal thread creation control unit is used for controlling the target service terminal in the target node to create a target service terminal thread;
a connection request receiving unit, configured to receive, by using the target service terminal thread, the connection request sent by the client of all other nodes.
Preferably, the distributed iscsi service implementation system further includes:
and the information recording module is used for binding the information corresponding to the bidirectional connection between the target node and all other nodes and the node information of all other nodes and recording the information into the target node.
The present application further provides a distributed storage system, comprising:
a memory and a processor; the memory is used for storing a computer program, and the processor is used for implementing the steps of the distributed iscsi service implementation method when the computer program is executed.
The present application further provides a computer-readable storage medium storing a computer program, which when executed by a processor implements the steps of the distributed iscsi service implementation method described above.
The application provides a distributed iscsi service implementation method, which comprises the following steps:
reading node information of all nodes in the distributed storage system; a target client in the control target node sends a connection request to the server of all other nodes according to the node information; wherein the target node is any node in the distributed storage system; receiving a response message sent by the server by using the target client, and establishing one-way connection between the target node and all other nodes; receiving connection requests sent by the clients of all other nodes by using a target server in the target node; and controlling the target server to send a response message to the client, and establishing the bidirectional connection between the target node and all other nodes.
After the node information of all the nodes in the distributed storage system is read, the method not only establishes the connection relation between the target client of the target node and the server of all other nodes, but also establishes the connection relation between the target server of the target node and the clients of all other nodes, realizes the distributed iscsi service in the distributed storage system, and further ensures that the iscsi service of the distributed storage system can normally work even if the main node is abnormal. The application also provides a distributed iscsi service implementation system, a distributed storage system and a computer readable storage medium, which all have the beneficial effects described above and are not described herein again.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the drawings needed to be used in the description of the embodiments or the prior art will be briefly introduced below, it is obvious that the drawings in the following description are only embodiments of the present application, and for those skilled in the art, other drawings can be obtained according to the provided drawings without creative efforts.
Fig. 1 is a flowchart of a distributed iscsi service implementation method according to an embodiment of the present application;
fig. 2 is a schematic structural diagram of an acelio assembly according to an embodiment of the present application;
fig. 3 is a block diagram of a distributed iscsi service implementation system according to an embodiment of the present application.
Detailed Description
The core of the application is to provide a distributed iscsi service implementation method, which can implement distributed iscsi services in a distributed storage system, and further, even if a main node is abnormal, the iscsi services of the distributed storage system can also work normally. At the other core of the application, a distributed iscsi service implementation system, a distributed storage system and a computer readable storage medium are provided.
In order to make the objects, technical solutions and advantages of the embodiments of the present application clearer, the technical solutions in the embodiments of the present application will be clearly and completely described below with reference to the drawings in the embodiments of the present application, and it is obvious that the described embodiments are some embodiments of the present application, but not all embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present application.
Currently, iscsi services are used in distributed storage systems to provide storage block traffic externally. However, the iscsi services are independently deployed on each node of the distributed storage system, and once the main node is abnormal, the iscsi services of each node in the whole distributed storage system cannot work normally. The embodiment of the present application can implement distributed iscsi services in a distributed storage system, and then even if a host node is abnormal, the iscsi services of the distributed storage system can also work normally, specifically refer to fig. 1, where fig. 1 is a flowchart of a distributed iscsi service implementation method provided in the embodiment of the present application, and the distributed iscsi service implementation method specifically includes:
s101, reading node information of all nodes in the distributed storage system;
the embodiment of the application deploys an improved acelio component on each node in the distributed storage system, and the main improvement is that a plurality of processing modules are added on the basis of an original acelio component, so that distributed connection of iscsi service layers of each node in the distributed storage system is realized, namely distributed iscsi service is realized. The improved acelio component is mainly added with a node information processing module, a client and server message processing module and a session management module on the basis of an original acelio component, as shown in fig. 2, and fig. 2 is a schematic structural diagram of the acelio component provided by the embodiment of the present application. The node information processing module stores node information of each node; the client and server message processing module provides a client request sending interface and a server processing request interface for the application layer, and is responsible for receiving messages transmitted by the application layer, packaging request data, sending data requests, receiving requests, packaging acquired data, sending responses, receiving responses and returning data to the application layer; the session management module is responsible for managing the whole system connection network, and comprises multi-connection establishment, multi-connection destruction and connection state detection, and the connection detection module is used for detecting the connection state of the client and the server and judging whether the connection is available before the client and the server send messages. In the embodiment of the present application, node information of all nodes in the distributed storage system is read, the content of the node information is not specifically limited, and a person skilled in the art should make corresponding settings according to actual situations, where the node information generally includes a node network address, an ID number corresponding to the node address one by one, a thread name, and a thread ID. Further, after the node information of all the nodes is read, the node information is cached or recorded, and the location of caching or recording is not specifically limited herein.
S102, controlling a target client in a target node to send a connection request to the server of all other nodes according to node information; the target node is any node in the distributed storage system;
after the node information of all the nodes in the distributed storage system is read, the target client in the target node is controlled to send the connection request to the server of all other nodes according to the node information. Because the purpose of the embodiment of the application is to implement distributed iscsi services, each node in the distributed storage system needs to implement distributed connections of iscsi service layers, that is, each node in the distributed storage system needs to establish bidirectional connections with other nodes, so that the target node is any node in the distributed storage system. The number of nodes in the distributed storage system is not particularly limited, and those skilled in the art should make corresponding settings according to actual situations. As can be seen from the above, in the embodiment of the present application, an improved acelio component is deployed on each node in the distributed storage system, and each improved acelio component includes a corresponding client and a corresponding server. For example, an improved acelio component deployed on a target node includes a corresponding target client and a target server.
Further, the process of controlling the target client in the target node to send the connection request to the servers of all other nodes according to the node information is not specifically limited herein, and the process generally includes: controlling a target client in a target node to create a target client sub-thread; and sending connection requests to the server sides of all other nodes by using the target client sub-thread according to the node information. For example, if the number of nodes in the distributed storage system is n, the target node sends connection requests to n-1 other nodes, so the number of connection requests is also n-1. Wherein, controlling a target client in a target node to create a target client child thread generally comprises: and controlling a target client in the target node to start a target client thread, and creating a target client sub-thread by using the target client thread. The creating manner of the target client Thread and the target client sub-Thread is not specifically limited, and a person skilled in the art should make corresponding settings according to actual situations, for example, the Thread may be created by inheriting Thread class, the Thread may be created by implementing a Runnable interface, and the Thread may be created by using Callable and Future.
S103, receiving a response message sent by a server by using a target client, and establishing one-way connection between a target node and all other nodes;
according to the method and the device, after the target client in the control target node sends the connection request to the server of all other nodes according to the node information, the target client receives the response message sent by the server, and the one-way connection between the target node and all other nodes is established. Step S102 shows that the target node sends connection requests to n-1 other nodes, and therefore the number of the received response messages is also n-1. And when receiving a response message sent by the server of one other node, establishing the one-way connection with the node until the one-way connection between the target node and all other nodes is established. The content of the response message is not particularly limited, and the content should be set by those skilled in the art according to the actual situation.
S104, receiving connection requests sent by clients of all other nodes by using a target server in the target node;
according to the method and the device, after the unidirectional connection between the target node and all other nodes is established, the target server in the target node is used for receiving the connection requests sent by the clients of all other nodes. As can be seen from the above, the number of all other nodes is n-1, so the number of connection requests sent by the clients receiving all other nodes is also n-1. Further, the process of receiving connection requests sent by clients of all other nodes by using a target server in a target node is not specifically limited herein, and should be set by those skilled in the art according to actual situations, and the process generally includes: controlling a target server in a target node to create a target server sub-thread; and receiving connection requests sent by clients of all other nodes by using the target service terminal thread. Wherein, controlling a target server in a target node to create a target server sub-thread generally includes: and controlling a target server in the target node to start a target server thread, and creating a target server sub-thread by using the target server thread. The creating manner of the target server Thread and the target server sub-Thread is not particularly limited, and those skilled in the art should make corresponding settings according to the actual situation, for example, the Thread may be created by inheriting Thread class, the Thread may be created by implementing Runnable interface, and the Thread may be created by using Callable and Future.
S105, controlling the target server to send a response message to the client, and establishing bidirectional connection between the target node and all other nodes.
According to the method and the device, after the target server in the target node receives the connection requests sent by the clients of all other nodes, the target server is controlled to send the response message to the clients, and the bidirectional connection between the target node and all other nodes is established. The content of the response message is not particularly limited, and the content should be set by those skilled in the art according to the actual situation. Further, after establishing the bidirectional connection between the target node and all other nodes, the method generally further includes: and binding the information corresponding to the bidirectional connection between the target node and all other nodes and the node information of all other nodes and recording the information into the target node. Since the target node is any node in the distributed storage system, when each node in the distributed storage system establishes a stable bidirectional connection with other nodes, a distributed communication network is formed. Therefore, when the application layer of the upper layer, such as the iscsi service, starts a related process, a request sending interface and a request processing interface provided by the acelio component are registered, and when the application layer calls the sending interface through the client, the acelio analyzes data transmitted by the application layer. When the corresponding connection is judged to be available, the data is encapsulated and sent to the opposite terminal to form a data packet, when the server terminal of the opposite terminal receives the request, the data is analyzed and transmitted to the application layer to be processed, new data is transmitted to the server terminal after the application layer is processed, the server terminal sends a response message after encapsulating the message, and when the client terminal receives the response message, the data is analyzed and then the data is returned to the application layer. Moreover, the acelio component monitors the processing time of the request through a timer, and destroys the current request once the timeout is sent or received.
After the node information of all the nodes in the distributed storage system is read, not only the connection relation between the target client of the target node and the server of all other nodes is established, but also the connection relation between the target server of the target node and the clients of all other nodes is established, so that the distributed iscsi service in the distributed storage system is realized, and the iscsi service of the distributed storage system can also work normally even if the main node is abnormal. Moreover, when the iscsi service is upgraded online, the rapid switching of the service can be realized. Furthermore, after the distributed iscsi service in the distributed storage system is realized, the iscsi service information of the whole cluster can be acquired through a certain node.
The distributed iscsi service implementation system, the distributed storage system, and the computer-readable storage medium provided in the embodiments of the present application are introduced below, and the distributed iscsi service implementation system, the distributed storage system, and the computer-readable storage medium described below may be referred to in correspondence with the distributed iscsi service implementation method described above.
Referring to fig. 3, fig. 3 is a block diagram of a distributed iscsi service implementation system according to an embodiment of the present disclosure; the distributed iscsi service implementation system comprises:
a node information reading module 301, configured to read node information of all nodes in the distributed storage system;
a connection request sending control module 302, configured to control a target client in a target node to send a connection request to servers of all other nodes according to node information; the target node is any node in the distributed storage system;
a unidirectional connection establishing module 303, configured to utilize the target client to receive the response message sent by the server, and establish unidirectional connections between the target node and all other nodes;
a connection request receiving module 304, configured to receive, by using a target server in the target node, connection requests sent by clients of all other nodes;
and a bidirectional connection establishing module 305, configured to control the target server to send a response message to the client, and establish a bidirectional connection between the target node and all other nodes.
Based on the foregoing embodiments, the connection request sending control module 302 in this embodiment generally includes:
the target client sub-thread creation control unit is used for controlling a target client in the target node to create a target client sub-thread;
and the connection request sending unit is used for sending connection requests to the server sides of all other nodes by using the target client side sub-thread according to the node information.
Based on the foregoing embodiments, the connection request receiving module 304 in this embodiment generally includes:
the target service terminal thread creation control unit is used for controlling a target service terminal in the target node to create a target service terminal thread;
and the connection request receiving unit is used for receiving connection requests sent by the clients of all other nodes by using the target service terminal thread.
Based on any of the above embodiments, the distributed iscsi service implementation system in this embodiment generally further includes:
and the information recording module is used for binding the information corresponding to the bidirectional connection between the target node and all other nodes and the node information of all other nodes and recording the information into the target node.
The present application further provides a distributed storage system, comprising:
a memory and a processor; wherein the memory is adapted to store a computer program, and the processor is adapted to implement the steps of the distributed iscsi service implementation method of any of the above embodiments when executing the computer program.
The present application further provides a computer-readable storage medium, in which a computer program is stored, and the computer program, when executed by a processor, implements the steps of the distributed iscsi service implementation method of any of the above embodiments.
The computer-readable storage medium may include: various media capable of storing program codes, such as a usb disk, a removable hard disk, a Read-Only Memory (ROM), a Random Access Memory (RAM), a magnetic disk, or an optical disk.
The embodiments are described in a progressive manner in the specification, each embodiment focuses on differences from other embodiments, and the same and similar parts among the embodiments are referred to each other. For the system provided by the embodiment, the description is relatively simple because the system corresponds to the method provided by the embodiment, and the relevant points can be referred to the method part for description.
Those of skill would further appreciate that the various illustrative elements and algorithm steps described in connection with the embodiments disclosed herein may be implemented as electronic hardware, computer software, or combinations of both, and that the various illustrative components and steps have been described above generally in terms of their functionality in order to clearly illustrate this interchangeability of hardware and software. Whether such functionality is implemented as hardware or software depends upon the particular application and design constraints imposed on the implementation. Skilled artisans may implement the described functionality in varying ways for each particular application, but such implementation decisions should not be interpreted as causing a departure from the scope of the present invention.
The steps of a method or algorithm described in connection with the embodiments disclosed herein may be embodied directly in hardware, in a software module executed by a processor, or in a combination of the two. A software module may reside in Random Access Memory (RAM), memory, Read Only Memory (ROM), electrically programmable ROM, electrically erasable programmable ROM, registers, hard disk, a removable disk, a CD-ROM, or any other form of storage medium known in the art.
The method, system, distributed storage system and computer readable storage medium for implementing distributed iscsi service provided by the present application are described in detail above. The principles and embodiments of the present application are explained herein using specific examples, which are provided only to help understand the method and the core idea of the present application. It should be noted that, for those skilled in the art, it is possible to make several improvements and modifications to the present application without departing from the principle of the present application, and such improvements and modifications also fall within the scope of the claims of the present application.

Claims (10)

1.一种分布式iscsi服务实现方法,其特征在于,包括:1. a distributed iscsi service implementation method, is characterized in that, comprises: 读取分布式存储系统中所有节点的节点信息;Read the node information of all nodes in the distributed storage system; 控制目标节点中的目标客户端根据所述节点信息向其他所有节点的服务端发送连接请求;其中,所述目标节点为所述分布式存储系统中的任一节点;The target client in the control target node sends a connection request to the servers of all other nodes according to the node information; wherein, the target node is any node in the distributed storage system; 利用所述目标客户端接收所述服务端发送的响应消息,建立所述目标节点与所述其他所有节点之间的单向连接;Use the target client to receive the response message sent by the server, and establish a one-way connection between the target node and all other nodes; 利用所述目标节点中的目标服务端接收所述其他所有节点的客户端发送的连接请求;Use the target server in the target node to receive connection requests sent by the clients of all other nodes; 控制所述目标服务端向所述客户端发送响应消息,建立所述目标节点与所述其他所有节点之间的双向连接。The target server is controlled to send a response message to the client, and a bidirectional connection between the target node and all other nodes is established. 2.根据权利要求1所述的分布式iscsi服务实现方法,其特征在于,所述控制目标节点中的目标客户端根据所述节点信息向其他所有节点的服务端发送连接请求,包括:2. The distributed iscsi service implementation method according to claim 1, wherein the target client in the control target node sends a connection request to the servers of all other nodes according to the node information, comprising: 控制所述目标节点中的所述目标客户端创建目标客户端子线程;Controlling the target client in the target node to create a target client sub-thread; 利用所述目标客户端子线程根据所述节点信息向所述其他所有节点的所述服务端发送所述连接请求。The target client sub-thread is used to send the connection request to the server of all other nodes according to the node information. 3.根据权利要求1所述的分布式iscsi服务实现方法,其特征在于,所述利用所述目标节点中的目标服务端接收所述其他所有节点的客户端发送的连接请求,包括:3. The distributed iscsi service implementation method according to claim 1, wherein the target server in the target node is used to receive the connection request sent by the clients of all other nodes, comprising: 控制所述目标节点中的所述目标服务端创建目标服务端子线程;Controlling the target server in the target node to create a target service terminal thread; 利用所述目标服务端子线程接收所述其他所有节点的所述客户端发送的所述连接请求。The connection request sent by the client of all other nodes is received by using the target service sub-thread. 4.根据权利要求1至3任一项所述的分布式iscsi服务实现方法,其特征在于,建立所述目标节点与所述其他所有节点之间的双向连接之后,还包括:4. The distributed iscsi service implementation method according to any one of claims 1 to 3, wherein after establishing the bidirectional connection between the target node and all the other nodes, the method further comprises: 将所述目标节点与所述其他所有节点之间的所述双向连接对应的信息和所述其他所有节点的节点信息进行绑定并记录至所述目标节点中。The information corresponding to the bidirectional connection between the target node and all other nodes and the node information of all other nodes are bound and recorded in the target node. 5.一种分布式iscsi服务实现系统,其特征在于,包括:5. a distributed iscsi service implementation system, is characterized in that, comprises: 节点信息读取模块,用于读取分布式存储系统中所有节点的节点信息;The node information reading module is used to read the node information of all nodes in the distributed storage system; 连接请求发送控制模块,用于控制目标节点中的目标客户端根据所述节点信息向其他所有节点的服务端发送连接请求;其中,所述目标节点为所述分布式存储系统中的任一节点;A connection request sending control module is used to control the target client in the target node to send a connection request to the servers of all other nodes according to the node information; wherein, the target node is any node in the distributed storage system ; 单向连接建立模块,用于利用所述目标客户端接收所述服务端发送的响应消息,建立所述目标节点与所述其他所有节点之间的单向连接;a one-way connection establishment module, configured to receive the response message sent by the server by using the target client to establish a one-way connection between the target node and all other nodes; 连接请求接收模块,用于利用所述目标节点中的目标服务端接收所述其他所有节点的客户端发送的连接请求;a connection request receiving module, configured to utilize the target server in the target node to receive connection requests sent by clients of all other nodes; 双向连接建立模块,用于控制所述目标服务端向所述客户端发送响应消息,建立所述目标节点与所述其他所有节点之间的双向连接。A bidirectional connection establishment module, configured to control the target server to send a response message to the client to establish bidirectional connections between the target node and all other nodes. 6.根据权利要求5所述的分布式iscsi服务实现系统,其特征在于,所述连接请求发送控制模块,包括:6. The distributed iscsi service implementation system according to claim 5, wherein the connection request sending control module comprises: 目标客户端子线程创建控制单元,用于控制所述目标节点中的所述目标客户端创建目标客户端子线程;a target client sub-thread creation control unit for controlling the target client in the target node to create a target client sub-thread; 连接请求发送单元,用于利用所述目标客户端子线程根据所述节点信息向所述其他所有节点的所述服务端发送所述连接请求。A connection request sending unit, configured to use the target client sub-thread to send the connection request to the server of all the other nodes according to the node information. 7.根据权利要求5所述的分布式iscsi服务实现系统,其特征在于,所述连接请求接收模块,包括:7. The distributed iscsi service implementation system according to claim 5, wherein the connection request receiving module comprises: 目标服务端子线程创建控制单元,用于控制所述目标节点中的所述目标服务端创建目标服务端子线程;A target service terminal thread creation control unit, for controlling the target server in the target node to create a target service terminal thread; 连接请求接收单元,用于利用所述目标服务端子线程接收所述其他所有节点的所述客户端发送的所述连接请求。A connection request receiving unit, configured to receive the connection request sent by the client of all the other nodes by using the target service sub-thread. 8.根据权利要求5至7任一项所述的分布式iscsi服务实现系统,其特征在于,还包括:8. The distributed iscsi service implementation system according to any one of claims 5 to 7, characterized in that, further comprising: 信息记录模块,用于将所述目标节点与所述其他所有节点之间的所述双向连接对应的信息和所述其他所有节点的节点信息进行绑定并记录至所述目标节点中。An information recording module, configured to bind and record the information corresponding to the bidirectional connection between the target node and all other nodes and the node information of all other nodes into the target node. 9.一种分布式存储系统,其特征在于,包括:9. A distributed storage system, characterized in that, comprising: 存储器和处理器;其中,所述存储器用于存储计算机程序,所述处理器用于执行所述计算机程序时实现如权利要求1至4任一项所述的分布式iscsi服务实现方法的步骤。A memory and a processor; wherein, the memory is used to store a computer program, and the processor is used to implement the steps of the distributed iscsi service implementation method according to any one of claims 1 to 4 when the computer program is executed. 10.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机程序,所述计算机程序被处理器执行时实现如权利要求1至4任一项所述的分布式iscsi服务实现方法的步骤。10. A computer-readable storage medium, characterized in that, the computer-readable storage medium stores a computer program, and when the computer program is executed by a processor, the distributed storage medium according to any one of claims 1 to 4 is implemented. The steps of the iscsi service implementation method.
CN201811504765.3A 2018-12-10 2018-12-10 A kind of distributed iscsi service realization method, system and related device Active CN109600436B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201811504765.3A CN109600436B (en) 2018-12-10 2018-12-10 A kind of distributed iscsi service realization method, system and related device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201811504765.3A CN109600436B (en) 2018-12-10 2018-12-10 A kind of distributed iscsi service realization method, system and related device

Publications (2)

Publication Number Publication Date
CN109600436A CN109600436A (en) 2019-04-09
CN109600436B true CN109600436B (en) 2021-06-29

Family

ID=65962272

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201811504765.3A Active CN109600436B (en) 2018-12-10 2018-12-10 A kind of distributed iscsi service realization method, system and related device

Country Status (1)

Country Link
CN (1) CN109600436B (en)

Families Citing this family (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110149232B (en) * 2019-05-23 2020-05-29 苏州浪潮智能科技有限公司 Distributed storage block upgrade iscsi service method, system, device and storage medium
CN112311743A (en) * 2019-07-31 2021-02-02 中兴通讯股份有限公司 A method, device, storage medium and storage device for communication between storage devices
CN114115718B (en) * 2021-08-31 2024-03-29 济南浪潮数据技术有限公司 Distributed block storage system service quality control method, device, equipment and medium

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1492625A (en) * 2002-10-25 2004-04-28 华为技术有限公司 Method for displaying service flow statistics of all links on the network
CN103258036A (en) * 2013-05-15 2013-08-21 广州一呼百应网络技术有限公司 Distributed real-time search engine based on p2p
CN106452507A (en) * 2016-12-07 2017-02-22 南京万形电气有限公司 Self-healing self-networking method based on OFDM power line carrier communication
CN108366087A (en) * 2017-12-26 2018-08-03 创新科存储技术(深圳)有限公司 A kind of ISCSI service implementing methods and device based on distributed file system
CN207994724U (en) * 2017-11-08 2018-10-19 江苏第二师范学院 Intelligent grid accesses distributed self-adaption node and system

Family Cites Families (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US7904602B2 (en) * 2008-02-05 2011-03-08 Raptor Networks Technology, Inc. Distributed computing bus

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN1492625A (en) * 2002-10-25 2004-04-28 华为技术有限公司 Method for displaying service flow statistics of all links on the network
CN103258036A (en) * 2013-05-15 2013-08-21 广州一呼百应网络技术有限公司 Distributed real-time search engine based on p2p
CN106452507A (en) * 2016-12-07 2017-02-22 南京万形电气有限公司 Self-healing self-networking method based on OFDM power line carrier communication
CN207994724U (en) * 2017-11-08 2018-10-19 江苏第二师范学院 Intelligent grid accesses distributed self-adaption node and system
CN108366087A (en) * 2017-12-26 2018-08-03 创新科存储技术(深圳)有限公司 A kind of ISCSI service implementing methods and device based on distributed file system

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
"基于换装检测器的WSN节点异常度双向多重检测方法";顾晟;《计算机测量与控制》;20150120;全文 *

Also Published As

Publication number Publication date
CN109600436A (en) 2019-04-09

Similar Documents

Publication Publication Date Title
US11991153B2 (en) Systems and methods for providing communications between on-premises servers and remote devices
CN109600436B (en) A kind of distributed iscsi service realization method, system and related device
CN111049901B (en) Load balancing method, load balancing system and registration server
KR102208935B1 (en) Messaging api over http protocol to establish context for data exchange
JP2017529793A5 (en)
EP3576371B1 (en) Method and system for transmitting streaming media resource
CN109947081B (en) Networked vehicle control method and device
CN103607410B (en) A kind of contents access method and equipment
CN110417632B (en) Network communication method, system and server
CN117097702A (en) High concurrency WebRTC gateway processing method based on SIP protocol, gateway system, electronic device and storage medium
CN112671554A (en) Node fault processing method and related device
CN113949631B (en) Client disaster recovery processing method, system and electronic equipment
EP2274889B1 (en) System for delivery of content to be played autonomously
CN107343037B (en) Data transmission method and device for distributed storage system
CN110011850B (en) Management method and device for services in cloud computing system
CN112838983B (en) Data transmission method, system, device, proxy server and storage medium
CN106254103B (en) A kind of dynamically configurable method and device of RTMP group system
CN104144155B (en) Session processing system and conversation processing method for long connection
US10382274B2 (en) System and method for wide area zero-configuration network auto configuration
CN114584558B (en) Cloud edge cooperative distributed API gateway system and API calling method
KR20160102348A (en) Devices and methods for performing tcp handshakes
CN111949918B (en) Websocket connection optimization method and system based on distributed environment
CN112787970B (en) Method and device for subscribing event stream
US20170310713A1 (en) Establishing And Managing Connections For Real Time Communications
CN118660023B (en) Device scheduling access method, system, readable storage medium and program product

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
GR01 Patent grant
GR01 Patent grant