Method, device and vehicle for message deduplication

Patent metadata

Field	Value
Publication number	US-11050814-B2
Application number	US-201916553927-A
Country	US
Kind code	B2
Filing date	Aug 28, 2019
Priority date	Aug 30, 2018
Publication date	Jun 29, 2021
Grant date	Jun 29, 2021

Abstract

Embodiments of the present disclosure provide a method, a device and a vehicle for message deduplication. The method includes: determining a node relationship with each publishing node by a subscribing node based on property information of the publishing node under the same topic as the subscribing node; determining a communication mode with each publishing node according to the node relationship; registering management modules corresponding to different communication modes according to the communication modes, so that after receiving a service message from the publishing node, a management module determines which subscribing nodes the service message is transmitted to based on a registration content and a unique identification of the publishing node carried in the service message. The service message may be transmitted to the corresponding subscribing node based on the registration content specifying the publishing node from which the service message is received under a certain communication mode.

First claim

What is claimed is:

1. A method for message deduplication based on a distributed system, wherein the distributed system comprises at least two subsystems, the at least two subsystems comprise two scenarios of belonging to the same host and belonging to different hosts, each subsystem comprises at least one node, the at least one node subscribes to or publishes a topic-based service message, the method comprises:
determining a first node relationship with each publishing node by a subscribing node based on property information of the publishing node under the same topic as the subscribing node, wherein the first node relationship comprises in-process, inter-process, or inter-host;
determining a first communication mode with each publishing node by the subscribing node according to the first node relationship, wherein the first communication mode comprises a pointer passing communication mode, a shared memory communication mode, or a Socket communication mode, in which when the first node relationship comprises in-process, the first communication mode comprises the pointer passing communication mode; when the first node relationship comprises inter-process, the first communication mode comprises the shared memory communication mode; and when the first node relationship comprises inter-host, the first communication mode comprises the Socket communication node;
registering by the subscribing node to a management module corresponding to the first communication mode according to the first communication mode, in which there two or more first communication modes with each publishing node, the subscribing node registers a management module corresponding to one of the two or more first communication modes, so that after receiving a service message from each publishing node, the management module determines that the server message is transmitted to the subscribing node based on a registration content and an unique identification of each publishing node carried in the service message, wherein the registration content is configured to specify the publishing node from which the service message is received under a certain first communication mode; and
receiving the server message that is sent from the publishing node to the management module, from the management module.

2. The method according to claim 1 , wherein the property information of the publishing node comprises a node name, a subsystem to which the publishing node belongs, a process name of a process in which the publishing node is located, and/or a host name of a host to which the publishing node belongs.

3. The method according to claim 1 , further comprising:
determining a second node relationship with each subscribing node by a publishing node based on property information of the subscribing nodes under the same topic as the publishing node, wherein the second node relationship comprises in-process, inter-process, or inter-host;
determining a second communication mode with each subscribing node by the publishing node according to the second node relationship;
transmitting by the publishing node the service message to management modules corresponding to respective second communication modes according to different second communication modes, wherein, the service message at least carries a unique identification of the publishing node, so that the management module determines which subscribing nodes the service message is transmitted to based on a preregistered content of each subscribing node and the unique identification of the publishing node, wherein the registration content is configured for the subscribing node to specify the publishing node from which the service message is received under a certain second communication mode.

4. The method according to claim 1 , further comprising:
receiving by a management module in the distributed system, a service message from each publishing node, wherein the service message at least carries a unique identification of the publishing node and a message topic;
determining by the management module a subscribing node set under the message topic according to the message topic;
determining by the management module which subscribing nodes in the subscribing nodes set the service message is transmitted to according to preregistered content of each subscribing node and the unique identification of the publishing node, wherein the registration content is configured for the subscribing node to specify the publishing node from which the service message is received under a certain communication mode.

5. A distributed system, comprising:
at least two subsystems, the at least two subsystems comprising two scenarios of belonging to the same host and belonging to different hosts, each subsystem comprises at least one node, the at least one node subscribes to or publishes a topic-based service message,
wherein the subscribing node is configured to implement:
determining a first node relationship with each publishing node based on property information of the publishing node under the same topic as the subscribing node, wherein the first node relationship comprises in-process, inter-process, or inter-host;
determining a first communication mode with each publishing node according to the first node relationship, wherein the first communication mode comprises a pointer passing communication mode, a shared memory communication mode, or a Socket communication mode, in which when the first node relationship comprises in-process, the first communication mode comprises the pointer passing communication mode; when the first node relationship comprises inter-process, the first communication mode comprises the shared memory communication mode; and when the first node relationship comprises inter-host, the first communication mode comprises the Socket communication node;
registering a management module corresponding to the first communication mode according to the first communication mode, in which there two or more first communication modes with each publishing node, the subscribing node registers a management module corresponding to one of the two or more first communication modes, so that after receiving a service message from each publishing node, the management module determines that the server message is transmitted to the subscribing node based on a registration content and an unique identification of each publishing node carried in the service message, wherein the registration content is configured to specify the publishing node from which the service message is received under a certain first communication mode; and
receiving the server message that is sent from the publishing node to the management module, from the management module.

6. The system according to claim 5 , wherein the property information of the publishing node comprises a node name, a subsystem to which the publishing node belongs, a process name of a process in which the publishing node is located, and/or a host name of a host to which the publishing node belongs.

7. The system according to claim 5 , wherein the publishing node is configured to implement:
determining a second node relationship with each subscribing node based on property information of the subscribing nodes under the same topic as the publishing node, wherein the second node relationship comprises in-process, inter-process, or inter-host;
determining a second communication mode with each subscribing node according to the second node relationship;
transmitting the service message to management modules corresponding to respective second communication modes according to different second communication modes, wherein, the service message at least carries a unique identification of the publishing node, so that the management module determines which subscribing nodes the service

Assignees

• Baidu online network technology beijing co ltd

Inventors

• Ni Zhongjun
• Yao Weifeng
• Xia Liming
• Xin Jiankang
• Deng Chengliang
• Chen Zhuo

Classifications

• H04L67/60

  Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources (admission control or resource allocation H04L47/70) · CPC title

• H04L67/55 Primary

  Push-based network services · CPC title

• H04L67/10 Primary

  in which an application is distributed across nodes in the network (software deployment G06F8/60; multiprogramming arrangements G06F9/46) · CPC title

• H04L65/1073

  Registration or de-registration · CPC title

• H04W4/40

  for vehicles, e.g. vehicle-to-pedestrians [V2P] · CPC title