×

Remote data object publishing/subscribing system having a multicast key-value protocol

  • US 10,002,153 B2
  • Filed: 05/14/2016
  • Issued: 06/19/2018
  • Est. Priority Date: 05/14/2015
  • Status: Active Grant
First Claim
Patent Images

1. A system comprising:

  • a data source computing device including a first nontransitory memory containing instructions for a publishing process using a key-value protocol;

    a first electronic communications channel including a first communications protocol, wherein the first channel is a broadcast channel;

    a second electronic communications channel including a second communications protocol, wherein the second channel is a host-to-host retransmit request channel; and

    a query computing device coupled to the data source computing device via the first electronic communications channel and the second electronic communications channel, the query computing device including a second nontransitory memory containing instructions for a subscriber process using the key-value protocol,wherein the instructions for the publishing process stored in the first nontransitory memory include instructions that, when executed by the data source computing device, cause the data source computing device to perform publishing operations including;

    receiving, at the data source computing device, an indication of new data available, wherein the new data includes at least one key-value pair;

    updating, at the data source computing device, a sequence identifier value to generate an updated sequence identifier value for the at least one key-value pair;

    packaging, at the data source computing device, at least a portion of the new data into a publisher message including the at least one key-value pair and the updated sequence identifier value;

    broadcasting, from the data source computing device, the publisher message via the first electronic communication channel;

    receiving, at the data source computing device, a retransmit request from the query computing device via the second electronic communications channel;

    selecting a retransmit electronic communications channel from a plurality of available channels, the retransmit electronic communications channel being different than the second electronic communications channel; and

    transmitting, from the data source computing device, requested retransmit data to the query computing device via the selected retransmit electronic communication channel,wherein the instructions for the subscriber process stored in the second nontransitory memory include instructions that, when executed by the query computing device, cause the query computing device to perform subscriber operations including;

    receiving, at the query computing device, a request for a first group of keys from a first remote query processor;

    transmitting, from the query computing device via the second electronic communications channel, a request for current key-value data for the first group of keys from the data source computing device;

    adding, at the query computing device, the current key-value data to a key-value map;

    receiving, at the query computing device, a received key-value protocol broadcast message;

    for each respective key of one or more keys in the received key-value protocol broadcast message that are in the key-value map;

    evaluating, at the query computing device, a sequence identifier (ID) in the received key-value protocol broadcast message to determine a most recent data for the respective key, andupdating the value for that the respective key in the key-value map with the most recent data;

    generating an updated data object based on current key-value data and/or the key-value protocol broadcast message;

    propagating changes, using the subscriber process, based on the updated data object to one or more dependent objects according to an update propagation graph of data object dependencies to update an in-memory table of a subscriber system associated with the subscriber process;

    transmitting, from the query computing device via the second electronic communications channel, a request for retransmit data from the data source computing device; and

    receiving, at the query computing device, the requested retransmit data from the data source computing device via the retransmit electronic communication channel selected by the data source computing device,wherein the first electronic communication channel and the second electronic communications channel are different channels.

View all claims
  • 3 Assignments
Timeline View
Assignment View
    ×
    ×