Granted Patent B2

US 12,603,946 · App. 18/644,483 · Granted Apr 14, 2026

Inventors: Anand Singh (Apex, NC); Erich Nahum (New York, NY); Dylan J Brisco (Cary, NC); Douglas Alan Larson (Raleigh, NC); Vijay Kestur (Cary, NC)

Assignee: International Business Machines Corporation

H04L67/60

Abstract

Claims (73)

1 . A computer-implemented method comprising:

generating a topic chain for a service request that spans a set of service nodes in a distributed services environment, wherein the topic chain indicates a sequence of topics to publish the service request so as to provide the service request to the set of service nodes by way of the sequence of topics; and

publishing the service request and the topic chain in a message to a first topic indicated by the topic chain to provide the service request and the topic chain to a first service node in the set of service nodes, and to allow the first service node to subsequently publish the message to a second topic indicated by the topic chain, so as to provide the service request and topic chain to a second service node in the set of service nodes.

2 . The computer-implemented method of claim 1 , wherein generating the topic chain for the service request further comprises:

identifying a rule list that corresponds to the service request, wherein the rule list defines the sequence of topics for publishing the service request to allow the set of service nodes to accomplish the service request; and

generating the topic chain to indicate the sequence of topics defined by the rule list.

3 . The computer-implemented method of claim 1 , wherein generating the topic chain for the service request further comprises:

obtaining status information for service nodes in the distributed services environment;

selecting individual service nodes to handle aspects of the service request based on the status information;

identifying topics to which the individual service nodes subscribe; and

generating the topic chain to indicate the topics.

4 . The computer-implemented method of claim 1 , wherein generating the topic chain for the service request further comprises:

generating the topic chain at a classifier node implemented in the distributed services environment to generate topic chains for service requests, wherein the service requests are provided to the classifier node by way of a topic to which the classifier node subscribes.

5 . The computer-implemented method of claim 1 , wherein generating the topic chain for the service request further comprises:

generating the topic chain at a service node included in the set of service nodes, wherein the service node is configured to act as both a service node to provide a microservice and a classifier to generate topic chains for service requests.

6 . The computer-implemented method of claim 1 , wherein publishing the service request and the topic chain further comprises:

incorporating the topic chain in metadata of the message for publishing the service request to the set of service nodes.

7 . The computer-implemented method of claim 1 , wherein publishing the service request and the topic chain further comprises:

incorporating the topic chain in a payload field of the message of the service request as key-value pairs.

8 . The computer-implemented method of claim 1 , further comprising:

receiving, at a service node in the set of service nodes, the message containing the service request and the topic chain;

performing an aspect of the service request that corresponds to the service node;

identifying a next topic in the topic chain; and

publishing the message containing the service request and the topic chain to the next topic.

9 . The computer-implemented method of claim 8 , wherein identifying the next topic in the topic chain further comprises:

modifying, by the service node, the topic chain to indicate remaining topics in the topic chain to which the message has yet to be published.

10 . The computer-implemented method of claim 8 , further comprising:

inserting, by the service node, tracing information into the message, where the tracing information tracks and records activities of the service node related to performing the service request.

11 . The computer-implemented method of claim 10 , further comprising:

extracting, at an extractor node, the tracing information for the service request from the message after at least a portion of the service request has been completed; and

logging the service request using the tracing information extracted from the message.

12 . A system comprising:

one or more computer readable storage media storing program instructions and one or more processors which, in response to executing the program instructions, are configured to:

generate a topic chain for a service request that spans a set of service nodes in a distributed services environment, wherein the topic chain indicates a sequence of topics to publish the service request so as to provide the service request to the set of service nodes by way of the sequence of topics; and

publish the service request and the topic chain in a message to a first topic indicated by the topic chain to provide the service request and the topic chain to a first service node in the set of service nodes, and to allow the first service node to subsequently publish the message to a second topic indicated by the topic chain, so as to provide the service request and topic chain to a second service node in the set of service nodes.

13 . The system of claim 12 , wherein the program instructions configured to cause the one or more processors to generate the topic chain for the service request are further configured to cause the one or more processors to:

obtain status information for service nodes in the distributed services environment;

select individual service nodes to handle aspects of the service request based on the status information;

identify topics to which the individual service nodes subscribe; and

generate the topic chain to indicate the topics.

14 . The system of claim 12 , wherein the program instructions are further configured to cause the one or more processors to:

receive, at a service node in the set of service nodes, the message containing the service request and the topic chain;

perform an aspect of the service request that corresponds to the service node;

modify the topic chain to indicate remaining topics in the topic chain to which the message has yet to be published; and

publish the message containing the service request and the topic chain to a next topic in the topic chain.

15 . The system of claim 12 , wherein the program instructions are further configured to cause the one or more processors to:

receive, at a service node in the set of service nodes, the message containing the service request and the topic chain;

perform an aspect of the service request that corresponds to the service node;

insert, by the service node, tracing information into the message, where the tracing information tracks and records activities of the service node related to performing the service request; and

publish the message containing the tracing information to a next topic in the topic chain.

16 . The system of claim 15 , wherein the program instructions are further configured to cause the one or more processors to:

receive the message containing the tracing information at an extractor node after at least a portion of the service request has been completed;

extract the tracing information for the service request from the message; and

log the service request using the tracing information extracted from the message.

17 . A computer program product comprising:

one or more computer readable storage media, and program instructions collectively stored on the one or more computer readable storage media, the program instructions configured to cause one or more processors to:

generate a topic chain for a service request that spans a set of service nodes in a distributed services environment, wherein the topic chain indicates a sequence of topics to publish the service request so as to provide the service request to the set of service nodes by way of the sequence of topics; and

publish the service request and the topic chain in a message to a first topic indicated by the topic chain to provide the service request and the topic chain to a first service node in the set of service nodes, and to allow the first service node to subsequently publish the message to a second topic indicated by the topic chain, so as to provide the service request and topic chain to a second service node in the set of service nodes.

18 . The computer program product of claim 17 , wherein the program instructions configured to cause the one or more processors to generate the topic chain for the service request are further configured to cause the one or more processors to:

obtain status information for service nodes in the distributed services environment;

select individual service nodes to handle aspects of the service request based on the status information;

identify topics to which the individual service nodes subscribe; and

generate the topic chain to indicate the topics.

19 . The computer program product of claim 17 , wherein the program instructions are further configured to cause the one or more processors to:

receive, at a service node in the set of service nodes, the message containing the service request and the topic chain;

perform an aspect of the service request that corresponds to the service node;

modify the topic chain to indicate remaining topics in the topic chain to which the message has yet to be published; and

publish the message containing the service request and the topic chain to a next topic in the topic chain.

20 . The computer program product of claim 17 , wherein the program instructions are further configured to cause the one or more processors to:

receive, at a service node in the set of service nodes, the message containing the service request and the topic chain;

perform an aspect of the service request that corresponds to the service node;

insert, by the service node, tracing information into the message, where the tracing information tracks and records activities of the service node related to performing the service request to allow an extractor node to extract the tracing information for the service request from the message and log the service request using the tracing information; and

publish the message containing the tracing information to a next topic in the topic chain.

Assignments (1)

Continuity (1)

References Cited (16)