Methods and storage media for transmitting message

Patent metadata

Field	Value
Publication number	US-11218571-B2
Application number	US-202016866469-A
Country	US
Kind code	B2
Filing date	May 4, 2020
Priority date	May 17, 2019
Publication date	Jan 4, 2022
Grant date	Jan 4, 2022

Abstract

The present disclosure provides a method and a storage medium for transmitting a message. The method includes: sending a current message transmission packet to an output device, the current message transmission packet including current message data and transmission progress information; obtaining an acknowledgement packet from the output device; and sending transmission progress information in the acknowledgement packet to a persistent storage system, such that the persistent storage system stores the transmission progress information in the acknowledgement packet as input progress information of the current message data.

First claim

What is claimed is:

1. A method for transmitting a message, executable by an input device, and comprising:
sending a current message transmission packet to an output device, the current message transmission packet comprising current message data and transmission progress information;
obtaining an acknowledgement packet containing the transmission progress information from the output device;
sending the transmission progress information in the acknowledgement packet to a persistent storage system, such that the persistent storage system stores the transmission progress information in the acknowledgement packet as input progress information of the current message data; and
when detecting that the persistent storage system stores the input progress information of the current message data, generating a removing duplication instruction for the current message data, and sending the removing duplication instruction to the message provider, to indicate the message provider to delete the current message data.

2. The method of claim 1 , further comprising:
obtaining the current message data from a message provider; and
generating the current message transmission packet based on the current message data.

3. The method of claim 2 , wherein obtaining the current message data from the message provider comprises:
obtaining the current message data from the message provider by a subscribing mode.

4. The method of claim 1 , wherein the transmission progress information comprises a global system message-transmission progress and position information of the current message data in the message provider.

5. A method for transmitting a message, executable by an output device, and comprising:
when a streaming transmission system is in a normal transmission state, receiving a current message transmission packet from an input device, the current message transmission packet comprising current message data and transmission progress information;
sending output compress information of the current message data to the persistent storage system;
feeding back an acknowledgement packet containing the transmission progress information to the input device after sending the current message data to a message storage device, such that the input device sends the transmission progress information in the acknowledgement packet to a persistent storage system;
when the streaming transmission system is in an abnormal restarting state, after receiving any current message transmission packet sent by the input device, determining whether the persistent storage system stores output compress information of the current message data; and
when the persistent storage system stores the output compress information of the current message data, feeding back the acknowledgement packet to the input device, such that the input device indicates the message provider to perform removing duplication on the current message data based on the acknowledgement packet for the current message data.

6. The method of claim 5 , further comprising:
when the persistent storage system does not store the output compress information of the current message data, switching the streaming transmission system to the normal transmission state and performs message transmission operation.

7. The method of claim 5 , wherein the transmission progress information comprises a global system message-transmission progress and position information of the current message data in the message provider.

8. A non-transient computer readable medium having a computer program stored thereon, wherein a method for transmitting a message is implemented when executed by the computer program, and the method comprises:
sending a current message transmission packet to an output device, the current message transmission packet comprising current message data and transmission progress information;
obtaining an acknowledgement packet containing the transmission progress information from the output device;
sending the transmission progress information in the acknowledgement packet to a persistent storage system, such that the persistent storage system stores the transmission progress information in the acknowledgement packet as input progress information of the current message data; and
when detecting that the persistent storage system stores the input progress information of the current message data, generating a removing duplication instruction for the current message data, and sending the removing duplication instruction to the message provider, to indicate the message provider to delete the current message data.

9. The non-transient computer readable medium of claim 8 , wherein the method further comprises:
obtaining the current message data from a message provider; and
generating the current message transmission packet based on the current message data.

10. The non-transient computer readable medium of claim 9 , wherein obtaining the current message data from the message provider comprises:
obtaining the current message data from the message provider by a subscribing mode.

11. The non-transient computer readable medium of claim 8 , wherein the transmission progress information comprises a global system message-transmission progress and position information of the current message data in the message provider.

Assignees

• Beijing Baidu Netcom Sci & Tech Co Ltd

Inventors

• Xing Yue
• Zhao Derun
• Wang Ting
• Zhan Yang

Classifications

• H04L67/56

  Provisioning of proxy services (store-and-forward switching systems in data switching networks H04L12/54) · CPC title

• H04W36/02

  Buffering or recovering information during reselection {; Modification of the traffic flow during hand-off} · CPC title

• H04L47/193

  at the transport layer, e.g. TCP related · CPC title

• G06F13/4068

  Electrical coupling · CPC title

• H04L1/1671 Primary

  the supervisory signal being transmitted together with control information · CPC title