CN113391759B - Communication method and equipment - Google Patents

Abstract

The application provides a communication method and communication equipment, which are used for solving the problem of IO request processing blocking when a distributed storage system is upgraded in the prior art, and relate to the technical field of distributed computers. In the application, a management cluster responds to an identification of a server to be upgraded from an upgrading framework, and determines second routing information according to first routing information of the server to be upgraded; and sending the second routing information to the client and other servers except the server to be upgraded. Based on this scheme, the management cluster may determine the second routing information before upgrading the server to be upgraded. Because the server to be upgraded in the second routing information is not used as a main server of the data, the server to be upgraded does not receive the IO request sent by the client, and the client can send the IO request to the main server of the data in the second routing information according to the second routing information, so that the IO request can be processed in time and the high-delay requirement can be met.

Description

A communication method and device

Technical Field

The present application relates to the field of distributed computer technology, and in particular to a communication method and device.

Background technique

For a distributed storage system, an input/output (IO) request is sent from the user side to the storage pool. The entire process requires the cooperation of multiple components, including the client, server, and management cluster.

The client is responsible for accessing and processing IO requests. The client calculates the data partition where the data is located through the data routing algorithm, and then forwards the IO request to the server to which the corresponding data partition belongs according to the routing information. The IO request is used to request the server to perform data input/output operations.

The server is a component unit of the storage pool, responsible for disk management and performing specific IO operations. The distributed storage system ensures data reliability through a multi-server backup mechanism. The same data can have 2 to 3 servers. Among them, multiple servers include a primary server and multiple backup servers. The data partition on the primary server is the primary copy, and the data partition on the backup server is the backup copy. The IO request for data will only be sent to the primary server of the data. When an IO request is sent to the primary server, the primary server will copy the IO request and send it to the backup server according to the routing information, thereby achieving consistency of multi-server data.

The management cluster is responsible for generating routing information. The routing information records the mapping relationship between data partitions and servers. The management cluster can also create storage pools. For example, the management cluster will generate routing information based on the initial storage pool topology and notify each client and each server of the routing information, so that the distributed storage system can forward IO requests to the corresponding master server based on the routing information. In addition, the management cluster can also monitor the status of the server through the heartbeat detection mechanism.

The current method of upgrading the distributed storage system is to upgrade the management cluster first, and then upgrade the server or client. During the upgrade process, the server cannot report the heartbeat. At this time, the management cluster will determine that the server is faulty, and the IO request cannot be forwarded to the server. However, since the client can only send IO requests to the primary server, if the primary server is being upgraded when the IO request reaches the client, the primary server cannot receive and process the IO request sent by the client. After the management cluster selects a new primary server and updates the routing information, the client must route the IO request to the new primary server according to the updated routing information before the new primary server can process the IO request sent by the client. There is a response delay for the IO request, which is unacceptable for latency-sensitive businesses.

Summary of the invention

The present application provides a communication method and device for solving the problem of IO request processing jam during the upgrade of a distributed storage system in the prior art.

In a first aspect, an embodiment of the present application provides a communication method, which can be executed by a management cluster in a distributed storage system. The management cluster may include at least one server or a chip in a server for management. In the method, the management cluster may determine second routing information according to the first routing information of the server to be upgraded in response to an identifier of the server to be upgraded from the upgrade framework; the management cluster may also send the second routing information to the client and other servers except the server to be upgraded. In the second routing information, the server to be upgraded is not used as the main server of the data.

Based on this solution, before upgrading the server to be upgraded, the management cluster can determine the second routing information based on the first routing information of the server to be upgraded, and send the second routing information to the client and other servers except the server to be upgraded. Since the server to be upgraded in the second routing information is not the main server of the data, the server to be upgraded will not receive the IO request sent by the client, and the client will send the IO request to the new main server of the data in the second routing information according to the second routing information, so the IO request can be processed in time, which can meet the high latency requirement.

In a possible implementation, if the server to be upgraded is a primary server, the management cluster may adjust the server to be upgraded to be a backup server for the data, and may adjust one of the backup servers corresponding to the server to be upgraded to be the primary server for the data.

Based on this solution, if the server to be upgraded is the main server of the data, the server to be upgraded can be adjusted to the backup server of the data in the second routing information, and one of the corresponding backup servers can be adjusted to the main server of the data. The client can send the IO request to the main server of the data in the second routing information according to the second routing information. Therefore, the IO request can be processed in time and the high latency requirement can be met.

In a possible implementation, the second routing information may not include the server to be upgraded. Exemplarily, the management cluster may delete the server to be upgraded from the second routing information.

Based on this solution, the server to be upgraded will not receive IO requests sent by the client, nor will it receive IO requests replicated by the data's primary server. Therefore, there will be no lag when processing IO requests, and high latency requirements can be met.

In a possible implementation, the management cluster may also determine third routing information according to the second routing information; in the third routing information, the server to be upgraded is the primary server of the data; and the third routing information is sent to the client, the server to be upgraded, and other servers except the server to be upgraded. Exemplarily, the management cluster may determine the third routing information after the server to be upgraded is upgraded. Alternatively, the management cluster may send the third routing information after the server to be upgraded is upgraded.

Based on this solution, after the server to be upgraded is upgraded, the third routing information can be determined according to the second routing information, and the server to be upgraded in the third routing information is the primary server of the data. Therefore, the client can send the IO request to the server to be upgraded according to the third routing information, and the server to be upgraded can process the IO request and copy the IO request and send it to the backup server of the data, so that the backup server can also process the IO request.

In a possible implementation, the management cluster may also determine fourth routing information based on the second routing information; the fourth routing information includes the server to be upgraded. If the server to be upgraded is used as the primary server of the data in the first routing information, the server to be upgraded is used as the primary server of the data in the fourth routing information; or, if the server to be upgraded is used as the backup server of the data in the first routing information, the server to be upgraded is used as the backup server of the data in the fourth routing information. The management cluster may send the fourth routing information to the client, the server to be upgraded, and other servers except the server to be upgraded.

Based on this solution, when the server to be upgraded is the main server in the first routing information, the server to be upgraded is still the main server in the third routing information; when the server to be upgraded is the backup server in the first routing information, the server to be upgraded is still the backup server in the third routing information.

In a possible implementation, the management cluster may also stop the heartbeat detection of the server to be upgraded. Exemplarily, the management cluster may stop the heartbeat detection of the server to be upgraded after sending the second routing information.

Based on this solution, the management cluster can stop the heartbeat detection of the server to be upgraded, and avoid the update operation of the routing information triggered by the inability of the server to be upgraded to send heartbeat packets to the management cluster during the upgrade. Therefore, the IO requests sent by the client can be processed in time to meet the high latency requirements.

In a possible implementation, the management cluster may also stop the heartbeat detection of the server to be upgraded, and after sending the third routing information, resume the heartbeat detection of the server to be upgraded.

Based on this solution, after sending the third routing information to the client and the primary and backup servers of the data, a heartbeat detection is performed on the server to be upgraded. The management cluster can monitor the working status of the server to be upgraded and update the routing information of the data in time when the server to be upgraded fails.

In a possible implementation, the management cluster may also stop the heartbeat detection of the server to be upgraded; and after sending the fourth routing information, resume the heartbeat detection of the server to be upgraded.

Based on this solution, after the fourth routing information is given to the client and the primary and backup servers of the data, a heartbeat detection is performed on the server to be upgraded. The management cluster can monitor the working status of the server to be upgraded and update the routing information of the data in time when the server to be upgraded fails.

In a second aspect, an embodiment of the present application further provides a communication device, which may include: a processing unit, which can be used to determine second routing information based on first routing information of the server to be upgraded in response to an identifier of the server to be upgraded from an upgrade framework; a transceiver unit, which can be used to send the second routing information to a client and other servers except the server to be upgraded; the server to be upgraded in the second routing information is not used as the main server for data.

In a possible implementation, if the server to be upgraded is a main server, the processing unit can be specifically used to: adjust the server to be upgraded to a backup server for the data; and adjust one of the backup servers corresponding to the server to be upgraded to the main server for the data when determining the second routing information based on the first routing information of the server to be upgraded.

In a possible implementation manner, when the processing unit determines the second routing information according to the first routing information of the server to be upgraded, the second routing information may exclude the server to be upgraded.

In a possible implementation, the processing unit can also be used to: determine third routing information based on the second routing information; the server to be upgraded in the third routing information is the main server of the data; and send the third routing information to the client and other servers except the server to be upgraded.

In a possible implementation, the processing unit may also be used to: determine fourth routing information based on the second routing information; the fourth routing information includes the server to be upgraded; if the server to be upgraded is used as the primary server of the data in the first routing information, then the server to be upgraded is used as the primary server of the data in the fourth routing information, or, if the server to be upgraded is used as the backup server of the data in the first routing information, then the server to be upgraded is used as the backup server of the data in the fourth routing information; the transceiver unit may also be used to: send the fourth routing information to the client and other servers except the server to be upgraded.

In a possible implementation manner, the processing unit may also be configured to: after sending the second routing information to the client and other servers except the server to be upgraded, stop the heartbeat detection of the server to be upgraded.

In one possible implementation, the processing unit can also be used to: stop the heartbeat detection of the server to be upgraded after sending the second routing information to the client and other servers except the server to be upgraded; and, after sending the third routing information to the client and other servers except the server to be upgraded, perform heartbeat detection on the server to be upgraded.

In a possible implementation, the processing unit can also be used to: stop the heartbeat detection of the server to be upgraded after sending the second routing information to the client and other servers except the server to be upgraded; and perform heartbeat detection on the server to be upgraded after sending the fourth routing information to the client and other servers except the server to be upgraded.

In a third aspect, an embodiment of the present application further provides a communication device, which can be used to perform the operations in the above-mentioned first aspect and any possible implementation of the first aspect. For example, the communication device may include a module or unit for performing each operation in the above-mentioned first aspect or any possible implementation of the first aspect. For example, it includes a processing unit and a transceiver unit.

In a fourth aspect, an embodiment of the present application provides a computer program product, which includes: a computer program code, when the computer program code is executed by a communication unit, a processing unit or a transceiver, or a processor of a communication device, the communication device executes any method in the above-mentioned first aspect or any possible implementation of the first aspect.

In a fifth aspect, an embodiment of the present application provides a computer-readable storage medium, which stores a program, and the program enables a communication device to execute any method in the above-mentioned first aspect or any possible implementation of the first aspect.

In a sixth aspect, an embodiment of the present application provides a chip or a chip system for executing any method in the above-mentioned first aspect or any possible implementation of the first aspect. The chip may include a processor, or include a processor and a memory and/or a transceiver. The chip system may include the chip.

The technical effects that can be achieved by any of the second to sixth aspects and any possible design in any of the aspects can be referred to the description of the beneficial effects of the method shown in the first aspect.

BRIEF DESCRIPTION OF THE DRAWINGS

FIG1 is a distributed storage system provided by the present application;

FIG2 is one of the exemplary flow charts of the common method provided by the present application;

FIG3 is one of the exemplary flow charts of the common method provided by the present application;

FIG4 is one of the exemplary flow charts of the common method provided by the present application;

FIG5 is a schematic diagram of a communication device provided by the present application;

FIG6 is a schematic diagram of a communication device provided in the present application.

Detailed ways

In order to facilitate understanding of the technical solution of the embodiments of the present application, the distributed storage system is first briefly explained and illustrated below.

The distributed storage system may include a client, a server, and a management cluster. For an IO request from a user side, the processing of the distributed storage system may include the following process.

First, the client can be used to access and process IO requests. The client calculates the data partition where the data corresponding to the aforementioned IO request is located through the data routing algorithm, and then forwards the IO request to the server corresponding to the data partition according to the routing information.

Secondly, the specific IO operation can be performed by the server, which may include a primary server and at least one backup server. The client can send an IO request to the primary server, and the primary server will copy the IO request and send it to the backup server. The primary server and the backup server perform IO operations respectively to keep data synchronized.

It should be understood that the primary server and the backup server refer to data, that is, there is a primary server and at least one backup server corresponding to the same data. The same data here can be data of the same user and/or the same service, for example, the data of the same client and/or the same service can be stored in the same primary server and the same at least one backup server.

In a distributed storage system, the management cluster may be responsible for generating routing information, which can be used to determine the server storing the data. Exemplarily, the routing information may specifically be a data routing table. The data routing table may record the mapping relationship between data partitions and servers, and the data partitions may correspond to the primary server and/or backup server of the data, so that the primary server and/or backup server corresponding to the data may be determined based on the mapping relationship. The routing information may record multiple servers storing the data. At the same time, the management cluster monitors the status of the server through a heartbeat detection mechanism.

For the upgrade of the distributed storage system, the upgrade process in the prior art may include: checking the environment, replacing the executable file, updating the configuration and restarting the process. If the server fails to report the heartbeat during the upgrade process, the management cluster will update the routing information. After the server is successfully upgraded and re-reports the heartbeat, the routing information will be updated again so that the IO request can be sent to the server.

During the server upgrade process, if the client sends an IO request to the server being upgraded, the server cannot process the IO request in time and needs to wait until the server upgrade is complete before processing the IO request. Therefore, there is a processing delay for the IO request. However, this is unacceptable for latency-sensitive businesses.

In view of this, an embodiment of the present application provides a communication method. The technical solution of the embodiment of the present application can be applied to a distributed storage system, for example, a distributed storage system with server-level security, a distributed storage system with cabinet-level security, etc.

To facilitate understanding of the embodiments of the present application, a distributed storage system applicable to the embodiments of the present application is first described in detail using the distributed storage system shown in Figure 1 as an example. As shown in Figure 1, an exemplary distributed storage system 100 may include a client 101, a primary server 102, a backup server 103, and a management cluster 104.

It should be understood that the client 101, the primary server 102, the backup server 103 and the management cluster 104 may also include multiple components related to signal transmission and reception (eg, processors, modulators, multiplexers, demodulators or demultiplexers, etc.).

The client 101 may be a terminal device. The terminal device may also be referred to as a user equipment (UE), an access terminal device, a user unit, a user station, a mobile station, a mobile station, a remote station, a remote terminal device, a mobile device, a user terminal device, a terminal device, a wireless communication device, a user agent or a user device. The terminal device in the embodiment of the present application may specifically be a mobile phone, a tablet computer, a computer with a wireless transceiver function, a virtual reality (VR) terminal device, an augmented reality (AR) terminal device, a wireless terminal device in industrial control, a wireless terminal device in self driving, a wireless terminal device in remote medical, a wireless terminal device in smart grid, a wireless terminal device in transportation safety, a wireless terminal device in smart city, a wireless terminal device in smart home, and the like. The embodiment of the present application does not limit the application scenario. In the present application, a terminal device with a wireless transceiver function and a chip that can be set in the aforementioned terminal device may be collectively referred to as a terminal device.

Among them, the management cluster 104, the main server 102 and the backup server 103 can be devices with wireless transceiver functions or chips in the devices respectively; the management cluster 104, the main server 102 and the backup server 103 can be a server respectively, or a server cluster composed of multiple servers; or they can be servers or chips in server clusters.

In the distributed storage system 100, the main server 102 and the management cluster 104 can communicate with one or more clients (including but not limited to the client 101 shown in the figure). The main server 102 and the management cluster 104 can communicate with one or more terminal devices such as the client 101. It should be understood that the distributed storage system 100 shown in FIG. 1 can have one or more backup servers 103, and the main server 102 and the management cluster 104 can communicate with one or more backup servers 103.

It should be understood that FIG. 1 is only a simplified schematic diagram for ease of understanding, and the distributed storage system may also include other clients or other backup servers, which are not shown in FIG. 1 .

The embodiments of the present application are described in detail below with reference to the accompanying drawings.

It should be understood that the technical solution of the present application can be applied to a distributed storage system, for example, the distributed storage system 100 shown in FIG. 1 , where the communication system may include at least one management cluster and at least one client, at least one primary server and at least one backup server.

FIG2 is an exemplary flow chart of a communication method provided by an embodiment of the present application from the perspective of device interaction. As shown in FIG2 , the method may include:

Step 201: The upgrade framework sends the identifier of the server to be upgraded to the management cluster.

The identifier of the server to be upgraded from the upgrade framework is used to indicate the server to be upgraded that needs to be upgraded.

The upgrade framework here is used to upgrade the server. The upgrade framework can be a program with an upgrade function, or it can also be a package or carrier of a program with an upgrade function. The upgrade framework and the management cluster can be arranged in a centralized or distributed manner.

It should be understood that the upgrade framework may only send the identifier of the server to be upgraded to the management cluster, or may carry the identifier of the server to be upgraded in the upgrade request and send it to the management cluster. The upgrade request may carry the identifier of one or more servers to be upgraded.

Step 202: The management cluster determines second routing information according to the first routing information of the server to be upgraded in response to the identifier of the server to be upgraded.

The routing information may include a mapping relationship between data partitions and servers, and may also include fault information. For example, when standby server 1 fails, the routing information may store fault information of standby server 1. Then, when the primary server replicates an IO request, it will not send the replicated IO request to standby server 1. The above fault information can be used to mark a server with a fault, and/or to mark what kind of fault the server has.

The first routing information here may be the routing information determined by the management cluster for the data before the management cluster receives the identifier of the server to be upgraded. In the first routing information, the server to be upgraded may be used as the primary server or backup server of the data. In the second routing information, the server to be upgraded is not used as the primary server of the data. The following specifically introduces the implementation method of upgrading the second routing information according to the first routing information.

In one example, if the server to be upgraded is the primary server of the data, the management cluster can adjust the server to be upgraded to the backup server of the data. Adjusting the server to be upgraded to the backup server of the data here may mean that the management cluster adjusts the identity of the server to be upgraded in the routing information from the primary server of the data to the backup server of the data; or in other words, the management cluster deletes the information of the server to be upgraded from the information of the primary server of the data in the routing information, and adds the information of the server to be upgraded to the information of the backup server of the data. The identity of the server to be upgraded is, for example, the primary server or the backup server of the data.

The management cluster can also adjust one of the standby servers corresponding to the server to be upgraded to be the primary server of the data. Similarly, the adjustment of one of the standby servers corresponding to the server to be upgraded to be the primary server of the data mentioned here can refer to the management cluster adjusting the identity of one of the standby servers corresponding to the server to be upgraded in the routing information from the standby server of the data to the primary server of the data; or, in other words, the management cluster deletes the information of the standby server from the information of the standby server of the data in the routing information, and adds the information of the standby server to the information of the primary server of the data. Among them, the management cluster can adjust one of the standby servers corresponding to the server to be upgraded that is not faulty to be the primary server of the data. It should be understood that after the server to be upgraded is adjusted to be the standby server, the primary server will not send the replicated IO request to the server to be upgraded, so the server to be upgraded does not need to respond to the IO request.

For example, the primary server of data A in the first routing information is primary server 1, and the backup servers include backup server 1, backup server 2, and backup server 3, where backup server 2 is a faulty server. The management cluster can generate second routing information according to the first routing information in response to the identifier of primary server 1 sent by the upgrade framework. In the second routing information, primary server 1 is adjusted to a backup server, and a backup server is selected from backup server 1 and backup server 3 to be adjusted to the primary server, for example, backup server 3 is adjusted to the primary server. Then, the server to be upgraded (i.e., primary server 1) will no longer receive IO requests replicated by the primary server (backup server 3) in the second routing information.

In another example, if the server to be upgraded is a backup server of the data, the management cluster may delete the backup server from the first routing information. Deleting the backup server from the first routing information mentioned here may mean that the management cluster deletes the information of the server to be upgraded from the information of the backup server of the data in the first routing information. Alternatively, the management cluster may also mark the server to be upgraded as a failure, and the primary server of the data will not send the replicated IO request to the server to be upgraded.

For example, the primary server of data A in the first routing information is primary server a, and the backup servers include backup server b, backup server c, and backup server d. The management cluster generates second routing information according to the first routing information in response to backup server b. The second routing information may not include relevant information of backup server b. Alternatively, backup server b may be marked as faulty in the second routing information.

If the upgrade request sent by the upgrade framework contains the identifiers of two or more servers to be upgraded, the management cluster can generate the second routing information for each server to be upgraded. For example, among the two or more servers to be upgraded, a server to be upgraded that has not been upgraded yet is randomly selected, and the second routing information of the randomly selected server to be upgraded is generated, and the upgrade framework can subsequently upgrade the randomly selected server to be upgraded. After the upgrade framework upgrades the server to be upgraded, another server to be upgraded that has not been upgraded yet is randomly selected from the aforementioned two or more servers to be upgraded. And so on, until all two or more servers to be upgraded are upgraded.

Alternatively, the management cluster may also select a specified number of servers to be upgraded from two or more servers to be upgraded, and generate second routing information of the selected specified number of servers to be upgraded, and the upgrade framework may subsequently upgrade the specified number of servers to be upgraded. In addition, after the specified number of servers to be upgraded are upgraded, a specified number (or other number other than the specified number) of servers to be upgraded that have not yet been upgraded are again selected from the aforementioned two or more servers to be upgraded, and the upgrade framework upgrades the specified number of servers to be upgraded, and so on, until all the servers to be upgraded are upgraded. With this design, it is possible to avoid upgrading all the servers to be upgraded at the same time, so as to improve the response speed of the distributed storage system to IO requests.

For example, in the first routing information, the main server of data A is main server 1, and the standby servers include standby server 1, standby server 2, standby server 3 and standby server 4. The upgrade request sent by the upgrade framework includes main server 1, standby server 1 and standby server 2. The management cluster can select any two servers to be upgraded in the upgrade request and generate the second routing information of the any two servers to be upgraded. For example, main server 1 and standby server 2 can be selected, and the specific update method is the same as the aforementioned method, which will not be repeated here. In this way, the IO request for data A can also be processed by standby server 1, standby server 2 and standby server 4. Even if any two of the standby servers 1, standby server 2 and standby server 4 fail, the IO request for data A can still be processed.

It should be noted that, according to the second routing information, the server to be upgraded will not receive the IO request sent by the client, nor will it receive the IO request replicated by the main server. Since the server is in the process of upgrading, if the server is the main server, it cannot receive the IO request sent by the client, and needs to wait for the management cluster to update the routing information. The client can send the IO request to the updated main server according to the updated routing information. If the server is a backup server, when receiving the IO request replicated by the main server, it needs to wait until the upgrade is completed before processing the IO request. Based on the above scheme, the server to be upgraded will not receive the IO request sent by the client, nor will it receive the IO request replicated by the main server. This can ensure that the IO request is processed in a timely manner without waiting for the routing information to be updated or waiting for the upgrade of the server to be upgraded to be completed, which can meet the high latency requirements of the business.

Step 203: The management cluster sends the second routing information to the client and other servers except the server to be upgraded.

Among them, other servers except the server to be upgraded may include the main server corresponding to the data in the second routing information and other backup servers except the server to be upgraded.

Optionally, the management cluster can perform heartbeat detection on the master server and backup server of the data according to the second routing information. The management cluster can stop performing heartbeat detection on the server to be upgraded. In this way, the second routing information can monitor the working status of each server of the data according to the heartbeat detection, and the second routing information can be updated in time when the monitored server fails. The server to be upgraded does not need to send a heartbeat packet to the management cluster, and during the upgrade, it will not cause the failure to send a heartbeat packet to trigger the management cluster to update the second routing information, which can ensure that IO requests with high latency requirements are processed in time.

Optionally, the management cluster may also send a response message for the identifier of the server to be upgraded to the upgrade framework. The upgrade framework may upgrade the server to be upgraded in response to the response message.

Based on the above solution, the management cluster can update the routing information according to the identifier of the server to be upgraded, so that the server to be upgraded will not receive data IO requests during the upgrade, which can ensure that the IO requests are processed in time and improve the response speed of the distributed system to IO requests.

In an embodiment of the present application, after the server to be upgraded is successfully upgraded, the management cluster can update the second routing information and restore the identity of the server to be upgraded to its identity in the first routing information. FIG3 is an exemplary flow chart of the communication method provided by an embodiment of the present application from the perspective of device interaction. In FIG3, the server to be upgraded is the primary server of the data in the first routing information.

Step 301: After the server to be upgraded is upgraded successfully, the upgrade framework sends the identifier of the server to be upgraded to the management cluster.

Step 302: The management cluster determines third routing information according to the second routing information.

In the third routing information here, the server to be upgraded is the main server of the data. It should be understood that since the server to be upgraded in the first routing information is the main server, the server to be upgraded in the third routing information is also the main server.

In a possible implementation, the management cluster can perform heartbeat detection on the server to be upgraded, and the server to be upgraded can send a heartbeat packet to the management cluster at a specified period, wherein the specified period can be predetermined based on empirical values, such as 10s, 15s, etc., which is not specifically limited in this application.

Step 303: The management cluster sends the third routing information to the client, the server to be upgraded, and other servers except the server to be upgraded.

Among them, other servers except the server to be upgraded may include the backup server corresponding to the data in the third routing information. In this way, the IO request of the client can be sent to the main server (i.e., the server to be upgraded) according to the third routing information, and the main server can also copy the IO request and send it to the corresponding backup server.

It should be understood that the process shown in FIG. 3 above may be executed after step 203 .

If the server to be upgraded is a backup server for data in the first routing information, the management cluster can generate fourth routing information based on the second routing information to restore the identity of the server to be upgraded to its identity in the first routing information. FIG4 is an exemplary flow chart of a communication method provided by an embodiment of the present application from the perspective of device interaction.

Step 401: After the server to be upgraded is upgraded successfully, the upgrade framework sends the identifier of the server to be upgraded to the management cluster.

Step 402: The management cluster determines fourth routing information according to the second routing information.

If the server to be upgraded in the first routing information is the primary server of the data, then the server to be upgraded in the fourth routing information is the primary server of the data. If the server to be upgraded in the first routing information is the backup server of the data, then the backup server of the data in the fourth routing information is the backup server of the data.

The management cluster can also perform heartbeat detection on the server to be upgraded, and the server to be upgraded can send a heartbeat packet to the management cluster at a specified period.

Step 403: The management cluster sends the fourth routing information to the client, the server to be upgraded, and other servers except the server to be upgraded.

Among them, other servers except the server to be upgraded may include the main server corresponding to the data in the fourth routing information and other backup servers except the server to be upgraded.

In this way, the IO request of the client can be sent to the primary server according to the fourth routing information, and the primary server can replicate the IO request and send the replicated IO request to each standby server according to the fourth routing information.

It should be understood that the process shown in FIG. 4 above can be executed after step 203 .

The communication method of the embodiment of the present application is described in detail above in conjunction with Figures 1 to 4. The communication device of the embodiment of the present application is described in detail below in conjunction with Figure 5.

FIG5 shows a schematic diagram of the structure of a communication device 500 provided in an embodiment of the present application. The communication device 500 can be used to implement the method described in the above method embodiment, which can be implemented by the management cluster 104 shown in FIG1 , and the details can be referred to the description in the above method embodiment. The communication device 500 can be a chip or a server cluster, etc.

The communication device 500 includes one or more processors 501. The processor 501 may be a general-purpose processor or a dedicated processor, etc. For example, it may be a baseband processor or a central processing unit. The baseband processor may be used to process the communication protocol and the communication data, and the central processing unit may be used to control the communication device (such as a server, a server cluster, or a chip, etc.), execute the software program, and process the data of the software program. The communication device may include a transceiver unit 505 to realize the input (reception) and output (transmission) of the signal. For example, the communication device may be a chip, and the transceiver unit 505 may be the input and/or output circuit of the chip, or a communication interface. The chip may be used for a terminal device or a server or a server cluster. For another example, the communication device may be a terminal device, a server or a server cluster, etc., and the transceiver unit may be a transceiver, a radio frequency chip, etc.

The communication device 500 includes one or more processors 501, and the one or more processors 501 can implement the methods in the embodiments shown in Figures 2 to 4.

In one possible design, the communication device 500 includes a means for determining second routing information according to first routing information of the server to be upgraded. The second routing information and how to generate the second routing information can refer to the relevant description in the above method embodiment. For example, the identifier of the server to be upgraded can be received through a transceiver, or an input/output circuit, or an interface of a chip, and the second routing information can be generated through one or more processors. Optionally, in addition to implementing the methods of the embodiments shown in Figures 2 to 4, the processor 501 can also implement other functions.

Optionally, in one design, the processor 501 may execute an instruction 503 so that the communication device 500 executes the method described in the above method embodiment. The instruction 503 may be stored in whole or in part in the processor, or in whole or in part in a memory 502 coupled to the processor.

In yet another possible design, the communication device 500 may also include a circuit, which may implement the functions of the aforementioned method embodiment.

In another possible design, the communication device 500 may include one or more memories 502, on which instructions 504 are stored, and the instructions can be executed on the processor so that the communication device 500 performs the method described in the above method embodiment. Optionally, data can also be stored in the memory. Instructions and/or data can also be stored in the optional processor. For example, the one or more memories 502 can store the second routing information described in the above embodiment, or the third routing information involved in the above embodiment, etc. The processor and memory can be set separately or integrated together.

In a possible implementation, the communication device 600 shown in FIG6 may be used as the management cluster involved in the above method embodiment, and execute the steps performed by the management cluster in the above method embodiment. As shown in FIG6, the communication device 600 may include a communication unit 601 and a processing unit 602, and the above communication unit 601 and the processing unit 602 are coupled to each other. The communication unit 601 can be used to support the communication device 600 to communicate, and the communication unit 601 can have a wired communication function. The processing unit 602 can be used to support the communication device 600 to perform the processing actions in the above method embodiment, including but not limited to: generating information and messages sent by the communication unit 601, and/or, parsing the signal received by the communication unit 601, etc.

When executing the action performed by the first communication device in the above method embodiment, the communication unit 601 can be used to receive the identifier of the server to be upgraded from the upgrade framework; or, it can also be used to send the second routing information to the client and other servers except the server to be upgraded.

The processing unit 602 can be used to respond to the identifier of the server to be upgraded from the upgrade framework and determine the second routing information according to the first routing information of the server to be upgraded. The second routing information and how to generate the second routing information can refer to the relevant description in the above method embodiment.

In one design, the processing unit 602 can also be used to determine third routing information based on the second routing information. The third routing information and how to determine the third routing information can be found in the relevant description of the above method embodiment; the communication unit 601 can also be used to send the third routing information to the client, the server to be upgraded, and other servers except the server to be upgraded.

In one design, the processing unit 602 can also be used to determine fourth routing information based on the second routing information. The fourth routing information and how to determine the fourth routing information can be found in the relevant description of the above-mentioned method embodiment; the communication unit 601 can also be used to send the fourth routing information to the client, the server to be upgraded and other servers except the server to be upgraded.

In one design, the processing unit 602 may also be used to stop the heartbeat detection of the server to be upgraded. Alternatively, the processing unit 602 may also be used to perform heartbeat detection on the server to be upgraded. For how to perform heartbeat detection on the server to be upgraded, please refer to the relevant description in the above method embodiment.

It should be noted that the processor in the embodiment of the present application can be an integrated circuit chip with signal processing capabilities. In the implementation process, each step of the above method embodiment can be completed by the hardware integrated logic circuit or software instructions in the processor. The above processor can be a general processor, a digital signal processor (digitalsignal processor, DSP), an application specific integrated circuit (application specific integrated circuit, ASIC), a field programmable gate array (field programmable gate array, FPGA) or other programmable logic devices, discrete gates or transistor logic devices, discrete hardware components. The methods, steps and logic block diagrams disclosed in the embodiments of the present application can be implemented or executed. The general processor can be a microprocessor or the processor can also be any conventional processor, etc. The steps of the method disclosed in the embodiment of the present application can be directly embodied as a hardware decoding processor to perform, or the hardware and software modules in the decoding processor can be combined to perform. The software module can be located in a mature storage medium in the field such as a random access memory, a flash memory, a read-only memory, a programmable read-only memory or an electrically erasable programmable memory, a register, etc. The storage medium is located in the memory, and the processor reads the information in the memory and completes the steps of the above method in combination with its hardware.

It can be understood that the memory in the embodiments of the present application can be a volatile memory or a non-volatile memory, or can include both volatile and non-volatile memories. Among them, the non-volatile memory can be a read-only memory (ROM), a programmable read-only memory (PROM), an erasable programmable read-only memory (EPROM), an electrically erasable programmable read-only memory (EEPROM), or a flash memory. The volatile memory can be a random access memory (RAM), which is used as an external cache. By way of example and not limitation, many forms of RAM are available, such as static RAM (SRAM), dynamic RAM (DRAM), synchronous DRAM (SDRAM), double data rate SDRAM (DDR SDRAM), enhanced SDRAM (ESDRAM), synchronous link DRAM (SLDRAM), and direct RAM bus RAM (DR RAM). It should be noted that the memory of the systems and methods described herein is intended to include, but is not limited to, these and any other suitable types of memory.

An embodiment of the present application further provides a computer-readable medium on which a computer program is stored. When the computer program is executed by a computer, the communication method described in any of the above method embodiments is implemented.

An embodiment of the present application also provides a computer program product, which, when executed by a computer, implements the communication method described in any of the above method embodiments.

In the above embodiments, it can be implemented in whole or in part by software, hardware, firmware or any combination thereof. When implemented using software, it can be implemented in whole or in part in the form of a computer program product. The computer program product includes one or more computer instructions. When the computer instructions are loaded and executed on a computer, the process or function described in the embodiment of the present application is generated in whole or in part. The computer can be a general-purpose computer, a special-purpose computer, a computer network, or other programmable device. The computer instructions can be stored in a computer-readable storage medium, or transmitted from one computer-readable storage medium to another computer-readable storage medium. For example, the computer instructions can be transmitted from a website site, computer, server or data center by wired (e.g., coaxial cable, optical fiber, digital subscriber line (digital subscriber line, DSL)) or wireless (e.g., infrared, wireless, microwave, etc.) mode to another website site, computer, server or data center. The computer-readable storage medium can be any available medium that a computer can access or a data storage device such as a server or data center that includes one or more available media integrations. The available medium may be a magnetic medium (eg, a floppy disk, a hard disk, a magnetic tape), an optical medium (eg, a high-density digital video disc (DVD)), or a semiconductor medium (eg, a solid state disk (SSD)).

An embodiment of the present application also provides a communication device, including a processor and an interface; the processor is used to execute the communication method described in any of the above method embodiments.

It should be understood that the above-mentioned processing device can be a chip, and the processor can be implemented by hardware or by software. When implemented by hardware, the processor can be a logic circuit, an integrated circuit, etc.; when implemented by software, the processor can be a general-purpose processor, which is implemented by reading the software code stored in the memory. The memory can be integrated in the processor, or can be located outside the processor and exist independently.

In addition, each functional unit in each embodiment of the present application may be integrated into one processing unit, or each unit may exist physically separately, or two or more units may be integrated into one unit. The above-mentioned integrated unit may be implemented in the form of hardware or in the form of software functional units.

Claims (18)

1. A communication method, comprising: In response to an identifier of a server to be upgraded from an upgrade framework, second routing information is determined according to first routing information of the server to be upgraded; the first routing information includes a mapping relationship between data partitions and servers; The second routing information is sent to the client and other servers except the server to be upgraded, wherein the second routing information includes a mapping relationship between data partitions and servers, and the server to be upgraded in the second routing information is not used as a main server of data. 2. The method according to claim 1, wherein if the server to be upgraded is a main server, then determining the second routing information according to the first routing information of the server to be upgraded comprises: Adjusting the server to be upgraded to be a backup server for the data; One of the backup servers corresponding to the server to be upgraded is adjusted to be the primary server of the data. 3. The method according to claim 1, wherein determining the second routing information according to the first routing information of the server to be upgraded comprises: The second routing information does not include the server to be upgraded. 4. The method according to claim 2, characterized in that the method further comprises: Determine third routing information according to the second routing information; the server to be upgraded in the third routing information is the main server of the data; The third routing information is sent to the client, the server to be upgraded, and other servers except the server to be upgraded. 5. The method according to claim 3, characterized in that the method further comprises: Determine fourth routing information according to the second routing information; the fourth routing information includes the server to be upgraded; if the server to be upgraded is used as the primary server of the data in the first routing information, the server to be upgraded is used as the primary server of the data in the fourth routing information, or if the server to be upgraded is used as the backup server of the data in the first routing information, the server to be upgraded is used as the backup server of the data in the fourth routing information; The fourth routing information is sent to the client, the server to be upgraded, and other servers except the server to be upgraded. 6. The method according to any one of claims 1 to 5, characterized in that after sending the second routing information to the client and other servers except the server to be upgraded, it also includes: Stop the heartbeat detection of the server to be upgraded. 7. The method according to claim 4, characterized in that after sending the second routing information to the client and other servers except the server to be upgraded, it also includes: Stop the heartbeat detection of the server to be upgraded; After sending the third routing information to the client, the server to be upgraded and other servers except the server to be upgraded, the method further includes: Perform a heartbeat detection on the server to be upgraded. 8. The method according to claim 5, characterized in that after sending the second routing information to the client and other servers except the server to be upgraded, it also includes: Stop the heartbeat detection of the server to be upgraded; After sending the fourth routing information to the client, the server to be upgraded and other servers except the server to be upgraded, the method further includes: Perform a heartbeat detection on the server to be upgraded. 9. A communication device, comprising: a processing unit, configured to determine second routing information according to first routing information of the server to be upgraded in response to an identifier of the server to be upgraded from the upgrade framework; The transceiver unit is used to send the second routing information to the client and other servers except the server to be upgraded; the server to be upgraded in the second routing information is not used as the main server of the data. 10. The device according to claim 9, wherein if the server to be upgraded is a main server, when the processing unit determines the second routing information according to the first routing information of the server to be upgraded, it is specifically used to: Adjusting the server to be upgraded to be a backup server for the data; One of the backup servers corresponding to the server to be upgraded is adjusted to be the primary server of the data. 11. The device according to claim 9, wherein when the processing unit determines the second routing information according to the first routing information of the server to be upgraded, it is specifically used to: The second routing information does not include the server to be upgraded. 12. The device according to claim 10, characterized in that the processing unit is further used for: Determine third routing information according to the second routing information; the server to be upgraded in the third routing information is the main server of the data; and send the third routing information to the client and other servers except the server to be upgraded. 13. The device according to claim 11, wherein the processing unit is further configured to: Determine fourth routing information according to the second routing information; the fourth routing information includes the server to be upgraded; if the server to be upgraded is used as the primary server of the data in the first routing information, the server to be upgraded is used as the primary server of the data in the fourth routing information, or if the server to be upgraded is used as the backup server of the data in the first routing information, the server to be upgraded is used as the backup server of the data in the fourth routing information; The transceiver unit is further used to send the fourth routing information to the client and other servers except the server to be upgraded. 14. The device according to any one of claims 9 to 13, wherein the processing unit is further configured to: After sending the second routing information to the client and other servers except the server to be upgraded, the heartbeat detection of the server to be upgraded is stopped. 15. The device according to claim 12, wherein the processing unit is further configured to: After sending the second routing information to the client and other servers except the server to be upgraded, stop the heartbeat detection of the server to be upgraded; and, after sending the third routing information to the client and other servers except the server to be upgraded, perform heartbeat detection on the server to be upgraded. 16. The device according to claim 13, wherein the processing unit is further configured to: After sending the second routing information to the client and other servers except the server to be upgraded, stopping the heartbeat detection of the server to be upgraded; After sending the fourth routing information to the client and other servers except the server to be upgraded, a heartbeat detection is performed on the server to be upgraded. 17. A communication device, comprising: a memory storing a computer program; and A processor, configured to execute the computing program stored in the memory so that the device executes the method according to any one of claims 1 to 8. 18. A computer-readable storage medium, characterized in that it stores computer-executable instructions, wherein the computer-executable instructions are used to enable a computer to execute the method according to any one of claims 1 to 8.