# US 2021/0344589 A1 · Method, server, and system for data stream redirecting > Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt - Number: US 2021/0344589 A1 - Document ID: US20210344589A1 - Status: Published application - Kind: A1 - Application number: 16/327,957 - Filed: 2018-02-27 - Published: 2021-11-04 - Earliest claimed: 2017-12-29 - Assignees: Wangsu Science & Technology Co., Ltd. - Applicants: Wangsu Science & Technology Co., Ltd. - Inventors: Kailin CHEN; Xiaopeng LIU - Web page: https://patentgrep.com/patent/US20210344589A1 ## CPC - H04L 47/2483: involving identification of individual flows - H04L 45/037: Routes obligatorily traversing service-related nodes - H04L 45/306: {Route determination based on the nature of the carried application} - H04L 45/38: {Flow based routing} - H04L 45/74: Address processing for routing - H04L 45/745: Address table lookup; Address filtering - H04L 47/2475: for supporting traffic characterised by the type of applications - H04L: TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION (arrangements common to telegraphic and telephonic communication H04M) ## Abstract Method, server, and system for data stream redirecting are provided. The method is applied to a service node and includes: redirecting a data stream based on a first global database, wherein the first global database includes at least one piece of destination address information and application identities corresponding to the at least one piece of destination address information; based on destination address information of data streams that traverse within a first preset period and application identities corresponding to the destination address information, determining variance information of the first global database; uploading the variance information to a central node; updating, by the central node, the first global database based on variance information uploaded by at least one service node, to generate a second global database; and acquiring the second global database from the central node and, based on the second global database, redirecting the data stream. ## Claims ### Claim 1 A data stream redirecting method, applicable to at least one service node, comprising: redirecting data streams based on a first global database, wherein the first global database includes at least one piece of destination address information and application identities corresponding to the at least one piece of destination address information; based on destination address information of data streams that traverse the service node within a first preset period and application identities corresponding to the destination address information, determining variance information of the first global database; uploading the variance information to a central node, and updating, by the central node, the first global database based on variance information uploaded by the at least one service node, to generate a second global database; and acquiring the second global database from the central node and, based on the second global database, redirecting data streams. ### Claim 2 (depends on 1) The data stream redirecting method according to claim 1, wherein based on the destination address information of the data streams that traverse within the first preset period and the application identities corresponding to the destination address information, determining the variance information of the first global database comprises: determining whether the destination address information of a data stream exists in the first global database; if the destination address information of the data stream exists in the first global database, recording a matching record that includes the destination address information and a corresponding application identity; and if the destination address information of the data stream does not exist in the first global database, performing, by the service node, feature recognition on the data stream, and recording, by the service node, a result of feature recognition. ### Claim 3 (depends on 2) The data stream redirecting method according to claim 2, wherein the variance information of the first global database includes: update information and incremental information, the matching record that includes destination address information and a corresponding application identity is counted as the update information, and the result of feature recognition is counted as the incremental information. ### Claim 4 (depends on 2) The data stream redirecting method according to claim 2, wherein the result of feature recognition comprises: the destination address information of the data stream, and an application identity obtained by the service node through feature recognition that corresponds to the destination address information; and destination address information of data streams to which application identities that are unable to be obtained through feature recognition. ### Claim 5 (depends on 1) The method according to claim 1, wherein redirecting the data stream based on the first global database comprises: parsing out destination address information from the data stream; and determining whether the destination address information exists in the first global database, if the destination address information exists in the first global database, acquiring an application identity corresponding to the destination address information, and redirecting the data stream based on a preset routing strategy corresponding to the application identity, and if the destination address information does not exist in the first global database, performing feature recognition on the data stream, and redirecting the data stream based on a recognition result. ### Claim 6 (depends on 1) The data stream redirecting method according to claim 1, wherein the destination address information includes any one or more of destination IP addresses, destination port addresses, and transport layer protocols. ### Claim 7 A data stream redirecting method, applicable to a central node, comprising: receiving variance information of a first global database respectively uploaded by at least one service node, wherein the first global database includes multiple pieces of destination address information and application identities corresponding to the multiple pieces of destination address information; processing the variance information uploaded by each service node, to obtain total variance information; and based on the total variance information, updating the first global database to obtain a second global database. ### Claim 8 (depends on 7) The data stream redirecting method according to claim 7, wherein the variance information of the first global database includes incremental information, wherein: the incremental information includes: destination address information that is obtained by a service node through a feature recognition within a first preset period and that is not included in the first global database, and application identities corresponding to the destination address information, and processing the variance information uploaded by each service node includes: performing a conflict resolution process on the incremental information uploaded by each service node. ### Claim 9 (depends on 8) The data stream redirecting method according to claim 8, wherein the incremental information further includes destination address information of data streams received by the service node within the first preset period that is not included in the first global database, and destination address information of application identities that are unable to be obtained through the feature recognition; and the processing the variance information uploaded by each service node includes: querying and recording, by the central node, application identities corresponding to the destination address information. ### Claim 10 (depends on 8) The data stream redirecting method according to claim 8, wherein the based on the total variance information, updating the first global database to obtain a second global database, includes: adding a conflict processing result and/or a recording result obtained through querying to the first global database. ### Claim 11 (depends on 7) The data stream redirecting method according to claim 7, wherein the variance information of the first global database includes update information, and the update information includes destination address information included in the first global database that is matched successfully by a service node within a first preset period, and the update information includes the destination address information and corresponding matching time, each piece of destination address information in the first global database is configured with a time-out value; and processing the variance information uploaded by each service node further includes: organizing the update information uploaded by each service node, and acquiring latest matching time of each piece of destination address information. ### Claim 12 (depends on 11) The data stream redirecting method according to claim 11, wherein the based on the total variance information, updating the first global database to obtain a second global database, includes: based on a time-out value of the destination address information in the first global database and the update information obtained through processing, updating the first global database; and under situations in which a preset condition of a time-out process is satisfied, deleting records of time-out destination address information and corresponding application identities, to obtain the second global database. ### Claim at position 13 -15. (canceled) ### Claim 16 A server, comprising: at least one processor; and a memory in communication connection with the at least one processor; wherein the memory stores instructions executable by the at least one processor, and the instructions are executed by the at least one processor, such that the at least one processor executes a data stream redirecting method of: redirecting data streams based on a first global database, wherein the first global database includes at least one piece of destination address information and application identities corresponding to the at least one piece of destination address information; based on destination address information of data streams that traverse the service node within a first preset period and application identities corresponding to the destination address information, determining variance information of the first global database; uploading the variance information to a central node, and updating, by the central node, the first global database based on variance information uploaded by at least one service node, to generate a second global database; and acquiring the second global database from the central node and, based on the second global database, redirecting data streams. ### Claim 17 (depends on 16) The server according to claim 16, wherein based on destination address information of data streams that traverse within a first preset period and application identities corresponding to the destination address information, determining variance information of the first global database comprises: determining whether the destination address information of a data stream exists in the first global database; if the destination address information of the data stream exists in the first global database, recording a matching record that includes the destination address information and a corresponding application identity; and if the destination address information of the data stream does not exist in the first global database, performing, by the service node, feature recognition on the data stream, and recording, by the service node, a result of feature recognition. ### Claim 18 (depends on 17) The server according to claim 17, wherein the variance information of the first global database includes: update information and incremental information, the matching record that includes destination address information and a corresponding application identity is counted as the update information, and the result of feature recognition is counted as the incremental information. ### Claim 19 (depends on 17) The server according to claim 17, wherein the result of feature recognition comprises: the destination address information of the data stream, and an application identity obtained by the service node through a feature recognition that corresponds to the destination address information; and destination address information of data streams to which application identities that unable to be obtained through the feature recognition correspond. ### Claim 20 (depends on 16) The server according to claim 16, wherein redirecting the data stream based on the first global database comprises: parsing out destination address information from the data stream; and determining whether the destination address information exists in the first global database, if the destination address information exists in the first global database, acquiring an application identity corresponding to the destination address information, and redirecting the data stream based on a preset routing strategy corresponding to the application identity, and if the destination address information does not exist in the first global database, performing feature recognition on the data stream, and redirecting the data stream based on a recognition result. ### Claim 21 (depends on 16) The server according to claim 16, wherein the destination address information include any one or more of destination IP addresses, destination port addresses, and transport layer protocols.