Efficient state synchronization in a clustered environment using compacted key/tuple representations and snapshot-based state restoration

A computer program product comprising computer-readable program code capable of being executed by one or more processors when retrieved from a non-transitory computer-readable medium, the program code comprising computer-readable instructions configurable to cause:

• detecting, by a target device accessing a message bus, an indicator of a first event message transmitted by a source device via the message bus, the first event message pertaining to an update to data in a database, the update being processed by the source device;
• responsive to detecting the indicator, skipping, by the target device, the first event message on the message bus;
• listening, by the target device, within the message bus for a subsequent event message containing a snapshot link;
• identifying, by the target device, the snapshot link in a second event message subsequent to the first event message on the message bus, the snapshot link pointing to a position in the message bus, the indicator indicating that the source device is unaware of the snapshot link;
• resubscribing, by the target device, at the position in the message bus;
• accessing, by the target device, a snapshot event identified by the snapshot link, the snapshot event including a complete snapshot of data from which subsequent event messages can be processed;
• storing, by the target device, data of the snapshot event in an in-memory data structure;
• processing, by the target device, one or more event messages subsequent to the snapshot event;
• and
• updating the in-memory data structure according to the one or more event messages.

A computing system, comprising:

• a processor;
• and
• a memory, the computing system configurable to cause:
• detecting, by a target device accessing a message bus, an indicator of a first event message transmitted by a source device via the message bus, the first event message pertaining to an update to data in a database, the update being processed by the source device;
• responsive to detecting the indicator, skipping, by the target device, the first event message on the message bus;
• listening, by the target device, within the message bus for a subsequent event message containing a snapshot link;
• identifying, by the target device, the snapshot link in a second event message subsequent to the first event message on the message bus, the snapshot link pointing to a position in the message bus, the indicator indicating that the source device is unaware of the snapshot link;
• resubscribing, by the target device, at the position in the message bus;
• accessing, by the target device, a snapshot event identified by the snapshot link, the snapshot event including a complete snapshot of data from which subsequent event messages can be processed;
• storing, by the target device, data of the snapshot event in an in-memory data structure;
• processing, by the target device, one or more event messages subsequent to the snapshot event;
• and
• updating the in-memory data structure according to the one or more event messages.