Ignite Client-Knoten stellt keine Daten obwohl Serverknoten zu DB (mit Durchschreiben nur auf dem Server, ohne writeBehind)

Question

Könnten Sie mir bitte mit folgenden Fragen helfen:

Ich habe die folgende Konfiguration von partitionierten Cache-Cluster:

• Serverknoten mit aktiviertem writeThrough. Sie sind in der Lage Daten von cacheStoreFactory=HibernateCacheStoreFactory

• Client-Knoten ohne Durchschreiben Konfiguration DB zu schreiben, aber mit clientMode=true

I perform auf Client-Knoten setzen, dann sehe ich, dass diese Daten an den Serverknoten gesendet wird, Der Serverknoten führt jedoch put nur zum Zwischenspeichern aus, ruft aber cacheStoreFactory nicht auf (writeThrough-Verhalten). Daten werden also nur im Cluster zwischengespeichert, aber nicht in die DB geschrieben.

Wenn ich die writeThrough-Konfiguration den Client-Knoten hinzufüge, wird writeThrough natürlich aufgerufen, aber ich möchte Abhängigkeiten von Hibernate von den Client-Knoten entfernen.

Wenn ich die writeBehind-Konfiguration auf der Serverseite aktiviert, wird writeThrough-Funktionalität aufgerufen, und der Serverknoten schreibt Daten vom Clientknoten asynchron in die Datenbank. Aber es erfüllt meine Anforderungen nicht, weil ich Puts vom Client-Knoten in einer Transaktion ausführen möchte.

Ist es möglich, Puts vom Clientknoten zum Speichern von Daten nach Serverknoten mit writeThrough in der Transaktion ohne writeBehind auszuführen?

Answer 1

Der Transaktionscache schreibt in den Persistenzspeicher von dem Knoten, der die Transaktion initiiert hat (in Ihrem Fall handelt es sich um einen Clientknoten). Dies geschieht, weil eine Transaktion möglicherweise Einträge enthalten kann, die auf verschiedenen Knoten gespeichert sind, und wenn der Speicher auch von verschiedenen Knoten aktualisiert wird, wäre es unmöglich, die Transaktionskonsistenz zwischen dem Cache und der Datenbank aufrechtzuerhalten.

Wenn Sie nicht auf dem Client-Zugriff auf die Datenbank haben, können Sie einen Verschluss zu einem der Server senden und eine Transaktion dort beginnen, wie folgt aus:

Ignition.ignite().compute().run(new IgniteRunnable() { 
    @IgniteInstanceResource 
    private Ignite ignite; 

    @Override public void run() { 
     try (Transaction tx = ignite.transactions().txStart()) { 
      // Cache operations go here... 

      tx.commit(); 
     } 
    } 
});