Interservice communication optimization for microservices

Patent metadata

Field	Value
Publication number	US-12255807-B2
Application number	US-202418630928-A
Country	US
Kind code	B2
Filing date	Apr 9, 2024
Priority date	Aug 4, 2022
Publication date	Mar 18, 2025
Grant date	Mar 18, 2025

Abstract

A communication broker service of a microservices platform may direct a distributed queue management service to monitor multiple data distribution outboxes of a plurality of microservices of the microservices platform for message data. The communication broker service may receive an indication from the distributed queue management service that the distributed queue management service has retrieved message data from a data distribution outbox of a first microservice. The communication broker service may apply a business logic to identify one or more second microservices that are configured to receive the message data from the first microservice. The communication broker server may then direct the distributed queue management service to distribute the message data of the first microservice from a data store of the distributed queue management service to one or more corresponding data distribution inboxes of the one or more second microservices.

First claim

What is claimed is:

1. A system, comprising:
one or more processors; and
memory including a plurality of computer-executable components that are executable by the one or more processors to perform a plurality of actions, the plurality of actions comprising:
receiving data provided by a data source at a microservices platform;
determining a data type of the data;
in response to determining the data type is non-real-time communication data, routing the non-real-time communication data via a distributed queue management service to a data distribution inbox of a microservice for processing by the microservice; and
in response to determining the data type is real-time communication data, routing the real-time communication data via a data routing service directly to the microservice or another microservice for processing without using the distributed queue management service.

2. The system of claim 1 , wherein the plurality of actions further comprises:
in response to determining the data type is real-time communication data, routing the real-time communication data via a data broker by the data routing service to a web service.

3. The system of claim 1 , wherein the plurality of actions further comprises:
in response to determining the data type is real-time communication data, routing the real-time communication data concurrently by the data routing service to a web service.

4. The system of claim 1 ,
wherein the real-time communication data comprises a real-time geolocation;
wherein the plurality of actions further comprises rendering the real-time geolocation on a digital map accessible to a web browser.

5. The system of claim 1 , wherein the real-time communication data comprises a real-time notification indicating an ongoing event at a corresponding geolocation.

6. The system of claim 1 , wherein the real-time communication data corresponds to an ongoing law enforcement activity or event.

7. The system of claim 1 , wherein the data routing service comprises a Message Queuing Telemetry Transport (MQTT) data routing service.

8. The system of claim 1 , wherein the plurality of actions further comprises:
distributing the real-time communication data via a gRPC protocol to the microservice or the another microservice for processing without using the distributed queue management service.

9. One or more non-transitory computer-readable media storing computer-executable instructions that, upon execution, cause one or more processors to perform acts comprising:
receiving data provided by a data source at a microservices platform;
determining a data type of the data;
in response to determining the data type of the data is non-real-time communication data, routing the non-real-time communication data via a distributed queue management service to a data distribution inbox of a microservice for processing by the microservice; and
in response to determining the data type of the data is real-time communication data, routing the real-time communication data via a data routing service directly to the microservice or another microservice for processing without using the distributed queue management service.

10. The one or more non-transitory computer-readable media of claim 9 , wherein the acts further comprise:
in response to determining the data type is real-time communication data, routing the real-time communication data via a data broker by the data routing service to a web service.

11. The one or more non-transitory computer-readable media of claim 9 , wherein the acts further comprise:
in response to determining the data type is real-time communication data, routing the real-time communication data concurrently by the data routing service to a web service.

12. The one or more non-transitory computer-readable media of claim 9 , wherein the real-time communication data comprises a real-time geolocation;
wherein the acts further comprise:
rendering the real-time geolocation on a digital map accessible to a web browser.

13. The one or more non-transitory computer-readable media of claim 9 , wherein the real-time communication data comprises a real-time notification indicating an ongoing event at a corresponding geolocation.

14. The one or more non-transitory computer-readable media of claim 9 , wherein the real-time communication data corresponds to an ongoing law enforcement activity or event.

15. A computer-implemented method, comprising:
receiving data provided by a data source at a microservices platform;
determining a data type of the data;
in response to determining the data type is non-real-time communication data, routing the non-real-time communication data via a distributed queue management service to a data distribution inbox of a microservice for processing by the microservice; and
in response to determining the data type is real-time communication data, routing the real-time communication data via a data routing service directly to the microservice or another microservice for processing without using the distributed queue management service.

16. The method of claim 15 , further comprising:
in response to determining the data type is real-time communication data, routing the real-time communication data via a data broker by the data routing service to a web service.

17. The method of claim 15 , further comprising:
in response to determining the data type is real-time communication data, routing the real-time communication data concurrently by the data routing service to a web service.

18. The method of claim 15 , wherein the real-time communication data comprises a real-time geolocation;
wherein the method further comprises:
rendering the real-time geolocation on a digital map accessible to a web browser.

19. The method of claim 15 , wherein the real-time communication data comprises a real-time notification indicating an ongoing event at a corresponding geolocation.

20. The method of claim 15 , wherein the real-time communication data corresponds to an ongoing law enforcement activity or event.

Assignees

• Getac Technology Corp
• Whp Workflow Solutions Inc

Inventors

• Adeel Muhammad
• Guzik Thomas

Classifications

• G06F2209/548

  Queue · CPC title

• G06F9/546

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

• H04L45/02

  Topology update or discovery · CPC title

• H04L43/067

  using time frame reporting · CPC title

• H04L45/22 Primary

  Alternate routing · CPC title