Asynchronous event-based distributed messaging service

Patent metadata

Field	Value
Publication number	US-11736434-B2
Application number	US-202217930642-A
Country	US
Kind code	B2
Filing date	Sep 8, 2022
Priority date	Mar 29, 2021
Publication date	Aug 22, 2023
Grant date	Aug 22, 2023

Abstract

When instantiating a requesting process that publishes a request for a response from a responding process, a method of implementing an event-based distributed messaging service includes identifying a response topic of a distributed messaging service and generating subscriptions for the response topic where each subscription includes a subscription identifier. During runtime for the requesting process, the method publishes a request message to a request topic subscribed to by the responding process where the request message includes a unique message identifier and generates a subscriber using a respective subscription identifier of a respective subscription selected from the subscriptions where the subscriber includes the unique message identifier. During runtime for the requesting process, the method also receives, at the subscriber, a filtered response message from the responding process where the filtered response message is filtered based on a subscription identifier associated with the subscriptions for the requesting process.

First claim

What is claimed is:

1. A computer-implemented method when executed by data processing hardware causes the data processing hardware to perform operations comprising:
publishing, from a requesting process, a request message to a request topic subscribed to by a responding process, the request message comprising a unique message identifier;
generating a subscriber comprising a subscription identifier and the unique message identifier; and
receiving, at the subscriber, a filtered response message from the responding process in response to the request message published to a response topic, the filtered response message filtered based on the subscription identifier and the unique message identifier.

2. The method of claim 1 , wherein the operations further comprise generating a plurality of subscriptions for the response topic, each subscription of the plurality of subscriptions comprising a respective subscription identifier.

3. The method of claim 1 , wherein generating the subscriber comprises:
selecting a subscription from a plurality of subscriptions; and
generating the subscriber using the respective subscription identifier of the selected subscription.

4. The method of claim 3 , wherein:
the subscription identifier comprises a unique filter value; and
the filtered response message is filtered based on the unique filter value of the selected subscription used to generate the subscriber.

5. The method of claim 3 , wherein the operations further comprise:
storing each respective subscription identifier of the plurality of subscriptions for the response topic at a hash map; and
selecting the subscription by randomly selecting the respective subscription identifier from the hash map.

6. The method of claim 1 , wherein the subscription identifier is unique among a plurality of instances of the requesting process.

7. The method of claim 1 , wherein the operations further comprise, during runtime for the requesting process, generating the request message for the request topic.

8. The method of claim 1 , wherein the requesting process is instantiated in response to receiving an initial request to perform a computing task.

9. The method of claim 8 , wherein the operations further comprise, upon receipt of the filtered response message from the responding process in response to the request message published to the request topic, generating an initial response to the initial request to perform the computing task.

10. The method of claim 1 , wherein the requesting process comprises an edge server.

11. A system comprising:
data processing hardware; and
memory hardware in communication with the data processing hardware, the memory hardware storing instructions that when executed on the data processing hardware cause the data processing hardware to perform operations comprising:
publishing, from a requesting process, a request message to a request topic subscribed to by a responding process, the request message comprising a unique message identifier;
generating a subscriber comprising a subscription identifier and the unique message identifier; and
receiving, at the subscriber, a filtered response message from the responding process in response to the request message published to a response topic, the filtered response message filtered based on the subscription identifier and the unique message identifier.

12. The system of claim 11 , wherein the operations further comprise generating a plurality of subscriptions for the response topic, each subscription of the plurality of subscriptions comprising a respective subscription identifier.

13. The system of claim 11 , wherein generating the subscriber comprises:
selecting a subscription from a plurality of subscriptions; and
generating the subscriber using the respective subscription identifier of the selected subscription.

14. The system of claim 13 , wherein:
the subscription identifier comprises a unique filter value; and
the filtered response message is filtered based on the unique filter value of the selected subscription used to generate the subscriber.

15. The system of claim 13 , wherein the operations further comprise:
storing each respective subscription identifier of the plurality of subscriptions for the response topic at a hash map; and
selecting the subscription by randomly selecting the respective subscription identifier from the hash map.

16. The system of claim 11 , wherein the subscription identifier is unique among a plurality of instances of the requesting process.

17. The system of claim 11 , wherein the operations further comprise, during runtime for the requesting process, generating the request message for the request topic.

18. The system of claim 11 , wherein the requesting process is instantiated in response to receiving an initial request to perform a computing task.

19. The system of claim 18 , wherein the operations further comprise, upon receipt of the filtered response message from the responding process in response to the request message published to the request topic, generating an initial response to the initial request to perform the computing task.

20. The system of claim 11 , wherein the requesting process comprises an edge server.

Assignees

• Google Llc

Inventors

• Mistry Shaunak
• Peralez Phillip Wayne

Classifications

• H04L51/214 Primary

  using selective forwarding · CPC title

• H04L51/212

  using filtering or selective blocking · CPC title

• G06F9/542

  Event management; Broadcasting; Multicasting; Notifications · CPC title

• G06F9/546

  Message passing systems or structures, e.g. queues · CPC title

• H04L51/52 Primary

  for supporting social networking services · CPC title