2

Infinispanのドキュメントには、楽観的および悲観的なロック スキームについて多くのことが書かれていますが、トランザクションの使用方法については詳しく説明されていません。おそらくJavaのデフォルトAPIを使っているので知っていると思われますが、そうであればJTAの利用パターンについても調べていませんでした。

楽観的なトランザクションを使用する場合、データへの同時アクセスに応じて、コミットまたはロールバックされると想定しています。ロールバックされた場合、トランザクションをリプレイできるようになり、トランザクションが完了することを期待しています。他の同時アクセスの前に成功します。私は TransactionManager に begin()、commit()、rollback() メソッドを持っています。この情報を使用して、次のコードを作成しました。

public void transactionSum(Key key, Long delta) {
    boolean redo;
    do{
        redo = false;
        try {
            tm.begin();
            try {
                Long value = cache.get(key);
                // Some processing:
                value += delta;
                cache.put(key, value);
                tm.commit();
            } catch(CacheException e) {
                tm.rollback();
                throw new RollbackException();
            }
        } catch (RollbackException e) {
            redo = true;
            logger.debug("Cache transaction collision, replaying it.");
        } catch (Exception e) {
            logger.error(e.getMessage());
        }
    } while(redo);
}

このコードは正しいですか? おそらく一般的な操作を実行するには複雑すぎるように思われるため、何か間違ったことをしたのではないかと思いCacheExceptionますcache.put()... もしそうなら、私は明示的に呼び出す必要がありますtm.rollback()か? 句tm.commit()の中で呼び出したらどうなりますか? finallyいつスローしRollbackExceptionますか？

さらに重要なことは、トランザクションのリプレイを実行する慣用句/デフォルトの方法はありますか?

4

1 に答える 1

3

正しいパターンは次のとおりです。

Transaction tx = tm.begin();
try
{
// DO SOMETHING
}
catch (Exception e)
{
   tx.setRollbackOnly(); // Force a rollback for this error
   throw e;
}
finally
{
   if (tx.getStatus() == Status.STATUS_ACTIVE)
      tx.commit();
   else
      tx.rollback();
}

関数型言語がない場合、これを利用する最も簡単な方法は、呼び出し可能オブジェクトまたは同様のパターンを使用することです。つまり、https：//github.com/galderz/infinispan/blob/master/core/src/test/java/org/infinispan/test/TestingUtil .java＃L1307

更新：Infinispanでトランザクションを再試行する機能はありません

于 2012-05-17T12:49:11.567 に答える