US 11,455,470 B2 · Distributed reactive streaming microservices architecture with self-management and autonomous routing

Abstract

A method for building a distributed reactive streaming microservices architecture having a decentralized, self-managed, and autonomous data message routing mechanism. The method comprises processing of data message by multiple microservices and generating routing patterns in the form of a fingerprint in response to the message-processing by the microservices. As the message is input into the microservices architecture, a fingerprint of the message is generated, wherein the fingerprint may comprise a payload flag in which payload information is embedded. A first microservice is triggered by recognizing the payload flag. As the message is processed by the first microservice, the fingerprint is updated by appending a first flag to the payload flag. The message with the updated fingerprint is subsequently recognized by a second microservice. As such, the routing of the message is accomplished by the changing fingerprint being recognized by the desired microservices to be triggered.

Claims18

Dependent claims

A method for processing a message by a distributed reactive streaming microservices architecture, comprising:

generating payload information in response to an input message;
creating a payload flag in which the payload information is embedded, so as to generate a fingerprint of the message comprising the payload flag;
providing a first service by a first microservice, wherein the first microservice is triggered by recognizing the payload flag;
updating the fingerprint by appending to the fingerprint a first flag based on a result generated by the first service;
providing a second service by a second microservice, wherein the second microservice is triggered by recognizing the first flag;
updating the fingerprint by appending to the fingerprint a second flag based on a result generated by the second service;
and
outputting a response to the message by the processing server system after updating the fingerprint at least once.

5 more elements

An apparatus for processing a message by distributed reactive streaming microservices architecture, comprising:

a processing server system configured to generate payload information in response to an input message;
wherein the processing server system is further configured to generate a payload flag in which the payload information is embedded, so as to generate a fingerprint of the message comprising the payload flag;
wherein the processing server system is further configured to provide a first service by a first microservice, wherein the first microservice is triggered by recognizing the payload flag;
wherein the processing server system is further configured to update the fingerprint by appending to the fingerprint a first flag based on a result generated by the first service;
wherein the processing server system is further configured to provide a second service by a second microservice, wherein the second microservice is triggered by recognizing the first flag;
wherein the processing server system is further configured to update the fingerprint by appending to the fingerprint a second flag based on a result generated by the second service;
and
wherein the processing server system is further configured to output a response to the message after updating the fingerprint at least once.

5 more elements

Dependencies are inferred from the claim text.

Distributed reactive streaming microservices architecture with self-management and autonomous routing

Life of this patent

Distributed reactive streaming microservices architecture with self-management and autonomous routing

Life of this patent

Abstract

Claims18