Database offload with node-to-node communication

Patent metadata

Field	Value
Publication number	US-12563115-B2
Application number	US-202418749340-A
Country	US
Kind code	B2
Filing date	Jun 20, 2024
Priority date	Jun 20, 2024
Publication date	Feb 24, 2026
Grant date	Feb 24, 2026

Abstract

An example embodiment may involve conducting, by an application node, an operation with a database node, wherein the application node and the database node are both within a computational instance of nodes; transmitting, by the application node and to each of a plurality of destination application nodes, a message relating to the operation, wherein the plurality of destination application nodes are also within the computational instance of nodes; and updating, by each of the plurality of destination application nodes, respective local storage of data relating to the operation.

First claim

What is claimed is:

1 . A method comprising:
conducting, by an application node, a write operation of data to a database of a database node, wherein the application node, a plurality of destination application nodes, and the database node are all within a computational instance of nodes; transmitting, by the application node and to each of the plurality of destination application nodes, respective messages indicating the write operation and the data; and updating, by each of the plurality of destination application nodes, respective local storages with the data, wherein reception of the respective messages indicating the write operation and the data causes the plurality of destination application nodes to use the respective local storages of the data for a period of time rather than read the data from the database node.

2 . The method of claim 1 , wherein the application node is in communication with each of the plurality of destination application nodes by way of respective WebSockets connections.

3 . The method of claim 1 , wherein transmitting the respective messages indicating the write operation and the data comprises:
transmitting, by the application node and to a load balancer, respective copies of the respective messages for each of the plurality of destination application nodes; and transmitting, by the load balancer and to each of the plurality of destination application nodes, the respective copies of the respective messages.

4 . The method of claim 1 , wherein the application node comprises:
one or more applications; a messaging interface through which the one or more applications can communicate with the plurality of destination application nodes; a transport module including channels between the application node and each of the plurality of destination application nodes; and an outbound message processing module including outbound worker threads that route messages from the messaging interface to the plurality of destination application nodes.

5 . The method of claim 4 , wherein the application node also comprises:
an inbound message processing module including inbound worker threads that route messages from the plurality of destination application nodes to the one or more applications.

6 . The method of claim 1 , wherein the application node and the plurality of destination application nodes also communicate with one another by way of a cache stored in the database node that maintains information that is synchronized between the application node and the plurality of destination application nodes.

7 . The method claim 1 , further comprising:
conducting, by the application node, a further write operation of further data to the database; transmitting, by the application node and to each of the plurality of destination application nodes, respective further messages indicating a cache flush operation relating to the further data; and updating, by each of the plurality of destination application nodes, the respective local storages to remove copies of the further data.

8 . A non-transitory computer-readable medium, having stored thereon program instructions that, upon execution by a computing system, cause the computing system to perform steps comprising:
conducting, by an application node, a write operation of data to a database of a database node, wherein the application node, a plurality of destination application nodes, and the database node are all within a computational instance of nodes; transmitting, by the application node and to each of the plurality of destination application nodes, respective messages indicating the write operation and the data; and updating, by each of the plurality of destination application nodes, respective local storages with the data, wherein reception of the respective messages indicating the write operation and the data causes the plurality of destination application nodes to use the respective local storages of the data for a period of time rather than read the data from the database node.

9 . The non-transitory computer-readable medium of claim 8 , wherein transmitting the respective messages indicating the write operation and the data comprises:
transmitting, by the application node and to a load balancer, respective copies of the respective messages for each of the plurality of destination application nodes; and transmitting, by the load balancer and to each of the plurality of destination application nodes, the respective copies of the respective messages.

10 . The non-transitory computer-readable medium of claim 8 , wherein the application node comprises:
one or more applications; a messaging interface through which the one or more applications can communicate with the plurality of destination application nodes; a transport module including channels between the application node and each of the plurality of destination application nodes; and an outbound message processing module including outbound worker threads that route messages from the messaging interface to the plurality of destination application nodes.

11 . The non-transitory computer-readable medium of claim 10 , wherein the application node also comprises:
an inbound message processing module including inbound worker threads that route messages from the plurality of destination application nodes to the one or more applications.

12 . The non-transitory computer-readable medium of claim 8 , wherein the application node and the plurality of destination application nodes also communicate with one another by way of a cache stored in the database node that maintains information that is synchronized between the application node and the plurality of destination application nodes.

13 . The non-transitory computer-readable medium of claim 8 , wherein the steps further comprise:
conducting, by the application node, a further write operation of further data to the database; transmitting, by the application node and to each of the plurality of destination application nodes, respective further messages indicating a cache flush operation relating to the further data; and updating, by each of the plurality of destination application nodes, the respective local storages to remove copies of the further data.

14 . The non-transitory computer-readable medium of claim 8 , wherein the application node is in communication with each of the plurality of destination application nodes by way of respective WebSockets connections.

15 . The non-transitory computer-readable medium of claim 9 , wherein the respective copies of the respective messages comprise a sticky cookie.

16 . A method comprising:
conducting, by an application node, a read operation of data from a database of a database node, wherein the application node, a plurality of destination application nodes, and the database node are all within a computational instance of nodes; transmitting, by the application node and to each of the plurality of destination application nodes, respective messages indicating the read operation and the data; and updating, by each of the plurality of destination application nodes, respective local storages with the data, wherein reception of the respective messages indicating the read operation and the data causes the plurality of destination application nodes to use the respective local storages of the data for a period of time rather than read the data from the database node.

17 . The method of claim 16 , wherein the application node is in communication with each of the plurality of destination application nodes by way of respectiv

Assignees

• Servicenow Inc

Inventors

• Barron-Kraus Kyle
• Fiorelli Benedetto
• Misra Vinamra
• Maturi Shasank
• Jain Kavish
• Milton André Michel

Classifications

• G06F16/27 Primary

  Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor · CPC title

• H04L67/568

  Storing data temporarily at an intermediate stage, e.g. caching · CPC title

• H04L67/1097 Primary

  for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS] · CPC title