Data processing method, electronic device, and computer-readable storage medium

Patent metadata

Field	Value
Publication number	US-12526349-B2
Application number	US-202318559035-A
Country	US
Kind code	B2
Filing date	May 19, 2023
Priority date	Dec 5, 2022
Publication date	Jan 13, 2026
Grant date	Jan 13, 2026

Abstract

Disclosed are a data processing method, an electronic device, and a computer-readable storage medium. During uplink transmission, upon receiving a first QUIC message from a client device over a target UDP port, an NGINX server sends the first QUIC message to the QUIC protocol stack, such that the QUIC protocol stack processes the first QUIC message to derive application layer data, and sends a first data stream including a first application layer data packet to an upstream server. During downlink transmission, the NGINX server receives a second data stream from the upstream server, caches a second application layer data packet included in the second data stream into a second cache, and delivers the second application layer data packet to the QUIC protocol stack for processing when the QUIC protocol stack is writable to derive a second QUIC message and sends the second QUIC message to the client device.

First claim

What is claimed is:

1 . A data processing method, applicable to an NGINX server integrated with a QUIC protocol stack, the method comprising:
receiving a first QUIC message from a client device over a target UDP port, the target UDP port supporting a variety of application layer protocols; sending the first QUIC message to the QUIC protocol stack, and processing, by the QUIC protocol stack, the first QUIC message to derive application layer data; sending a first data stream including a first application layer data packet to an upstream server according to a protocol type of the first application layer data packet, the first application layer data packet including at least the application layer data corresponding to one of first QUIC messages; receiving a second data stream including a second application layer data packet from the upstream server; caching the second application layer data packet to a sending cache; sending the second application layer data packet in the sending cache to the QUIC protocol stack in response to the QUIC protocol stack being writable, such that the QUIC protocol stack processes the second application layer data packet to derive a second QUIC message; and sending the second QUIC message to the client device over the target UDP port; wherein sending the second application layer data packet in the sending cache to the QUIC protocol stack in response to the QUIC protocol stack being writable comprises: hooking a first send interface of the NGINX server, and writing the second application layer data packet in the sending cache into the QUIC protocol stack over the first send interface in response to a protocol type of the second application layer data packet being HTTP/1.1 or HTTP/2.0; and hooking a second send interface of the NGINX server, and writing the second application layer data packet in the sending cache into the QUIC protocol stack by the second send interface in response to the protocol type of the second application layer data packet being RTMP.

2 . The method according to claim 1 , wherein the method further comprises: prior to sending the first data stream including the first application layer data packet to the upstream server according to the protocol type of the first application layer data packet comprises:
reading the first application layer data packet from the QUIC protocol stack; caching the first application layer data packet to a receiving cache in response to the QUIC protocol stack being readable; and reading the first application layer data packet from the receiving cache.

3 . The method according to claim 2 , wherein the method further comprises:
prior to reading the first application layer data packet from the receiving cache, hooking a first receive interface based on HTTP of an application layer of the NGINX server; reading the first application layer data packet from the receiving cache over the first receive interface; and prior to sending the first data stream including the first application layer data packet to the upstream server according to the protocol type of the first application layer data packet, detecting the protocol type of the first application layer data packet, the protocol type including HTTP/1.1, HTTP/2.0, or RTMP.

4 . The method according to claim 3 , wherein detecting the protocol type of the first application layer data packet comprises:
creating an application layer connection for the first application layer data packet using a first file descriptor fd, the first file descriptor fd being different from a second file descriptor fd of the target UDP port; adding a detection interface for the application layer connection; and detecting the protocol type of the first application layer data packet using the detection interface.

5 . The method according to claim 3 , wherein reading the first application layer data packet from the receiving cache and sending the first data stream including the first application layer data packet to the upstream server according to the protocol type of the first application layer data packet comprises:
hooking a second receive interface based on RTMP of the application layer of the NGINX server, and reading the first application layer data packet from the receiving cache over the second receive interface and sending the first application layer data packet to the upstream server in response to the protocol type of the first application layer data packet being RTMP; and reading the first application layer data packet from the receiving cache over the first receive interface and sending the first application layer data packet to the upstream server in response to the protocol type of the first application layer data packet being HTTP/1.1 or HTTP/2.0.

6 . The method according to claim 1 , further comprising:
registering a callback event to the QUIC protocol stack in response to a worker process of the NGINX server being initialized, the callback event including a stream read event and a stream write event.

7 . The method according to claim 1 , wherein sending the first QUIC message to the QUIC protocol stack comprises:
hooking a read event handler function of the target UDP port; and sending the first QUIC message to the QUIC protocol stack using the read event handler function.

8 . The method according to claim 4 , wherein reading the first application layer data packet from the receiving cache and sending the first data stream including the first application layer data packet to the upstream server according to the protocol type of the first application layer data packet comprises:
hooking a second receive interface based on RTMP of the application layer of the NGINX server, and reading the first application layer data packet from the receiving cache over the second receive interface and sending the first application layer data packet to the upstream server in response to the protocol type of the first application layer data packet being RTMP; and reading the first application layer data packet from the receiving cache over the first receive interface and sending the first application layer data packet to the upstream server in response to the protocol type of the first application layer data packet being HTTP/1.1 or HTTP/2.0.

9 . An electronic device, comprising: a processor, a memory, and one or more computer programs that are stored in the memory and executable by the processor; wherein the one or more computer programs, when loaded and executed by the processor, cause the electronic device to perform a data processing method;
wherein the method is applicable to an NGINX server integrated with a QUIC protocol stack, and comprises: receiving a first QUIC message from a client device over a target UDP port, the target UDP port supporting a variety of application layer protocols; sending the first QUIC message to the QUIC protocol stack, and processing, by the QUIC protocol stack, the first QUIC message to derive application layer data; sending a first data stream including a first application layer data packet to an upstream server according to a protocol type of the first application layer data packet, the first application layer data packet including at least the application layer data corresponding to one of first QUIC messages; receiving a second data stream including a second application layer data packet from the upstream server; caching the second application layer data packet to a sending cache; sending the second application layer data packet in the sending cache to the QUIC protocol stack in response to the QUIC protocol stack being writable, such that the QUIC protocol stack processes the second application layer data packet to derive a second QUIC message; and send

Assignees

• Wangsu Science & Tech Co Ltd

Inventors

• Chen Xiangxiang
• Zhuang Xiaochuan

Classifications

• H04L67/02

  based on web technology, e.g. hypertext transfer protocol [HTTP] · CPC title

• H04L69/161

  Implementation details of TCP/IP or UDP/IP stack architecture; Specification of modified or new header fields · CPC title

• H04L69/326

  in the transport layer [OSI layer 4] (H04L69/16 takes precedence) · CPC title

• H04L69/16

  Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP] · CPC title

• H04L69/329

  in the application layer [OSI layer 7] · CPC title