infinispan Cache-Objekt Update in Transaktion Roll-Back-Ausgabe

Question

wir hoffen, Infinispan als eine In-Memory-Datenbank im Auftragsmanagement-System zu verwenden. Dort müssen wir folgende Art von Operation durchführen. Hier enthält der Cash-Account-Cache einen Kunden-Cache-Account, der von der DB geladen wurde. Sagen wir, dass der Anfangssaldo des Cash-Kontos1 1000 ist und CashAccount2 2000 ist. Wir aktualisieren beide Cash-Konten in einer Transaktion in einem jboss 7.1-Anwendungsserver. Was wir als Ergebnis erwarten, ist, dass die Salden der beiden Cash-Konten unverändert bleiben, da diese Operation innerhalb der Transaktion stattfand. Aber leider können wir auch nach dem Rollback der Transaktion das Update-Objekt im Cache sehen. ut was wir untersuchen, ist, wenn wir ein Objekt in den Cache in einer Transaktion hinzufügen, wenn das Rollback der Transaktion aus dem Cache entfernt wird. Aber die Modifikation des bestehenden Objekts bleibt so wie es ist.

Dies ist nur ein Beispiel, was wir tun möchten. In Wirklichkeit müssen mehrere Objekte in einer einzigen Transaktion aktualisiert werden.

Könnten Sie uns bitte wissen lassen, dass es möglich ist, Infinispan für diese Art von Betrieb zu verwenden.

cashAccountCache= provider.getCacheContainer().getCache(CACHE_NAME); 
     try { 
      utx.begin(); 
      CashAccount cashAccount1 = cashAccountCache.get("cashAccNumber1"); 
      CashAccount cashAccount2 = cashAccountCache.get("cashAccNumber2"); 
      cashAccount1.setBalance(cashAccount1 .getBalance() + 100); 
      cashAccount2.setBalance(cashAccount2 .getBalance() + 200); 
      if(true) throw new RuntimeException(); 
      utx.commit(); 
     } catch (Exception e) { 
      if (utx != null) { 
       try { 
        utx.rollback(); 
       } catch (Exception e1) { 
       } 
      } 
     } 

Answer 1

Der richtige Weg, dies in infinispan zu tun, ist zu CacheAccount Objekt unveränderlich zu machen. Andernfalls ändern Sie die Eigenschaft eines Objekts, und Infinispan hat keine Kontrolle darüber.

//CashAccount Class 
public class CashAccount{ 

    public CashAccount setBalance(int balance){ 
     CacheAccount account = new CacheAccount(this); //deep copy 
     account.setBalance(balance); 
     return account; 
    } 

} 



cashAccountCache= provider.getCacheContainer().getCache(CACHE_NAME); 
try { 
    utx.begin(); 
    CashAccount cashAccount1 = cashAccountCache.get("cashAccNumber1"); 
    CashAccount cashAccount2 = cashAccountCache.get("cashAccNumber2"); 
    cashAccount1 = cashAccount1.setBalance(cashAccount1 .getBalance() + 100); 
    cashAccount2 = cashAccount2.setBalance(cashAccount2 .getBalance() + 200); 
    cacheAccountCache.put("cashAccNumber1", cashAccount1); 
    cacheAccountCache.put("cashAccNumber2",cacheAccount2); 
    if(true) throw new RuntimeException(); 
    utx.commit(); 
} catch (Exception e) { 
    if (utx != null) { 
     try { 
      utx.rollback(); 
     } catch (Exception e1) { 
     } 
    } 
}