ストームトポロジの全スレッドで変数を同期させよう

Question

カフカキューからカサンドラDBにデータを書き込むためのストームトポロジがあります。プログラムはマルチスレッドのものです。カサンドラのデシベルの挿入を容易にするために、私は私のDBUtilsとしてこれを持っている：

public DBUtils() { 
    if(session == null) { 
     session = CassandraUtil.getInstance().getSession(); 
     LOG.info("Started a new session for dbUtils-Monitoring....."); 
    } 
    synchronized(session) { 
     testMapper = new MappingManager(session).mapper(TestVO.class); 
    } 
} 

はので、私はすべての実行中のスレッド全体で単一dbUtilsインスタンスを作成するために、同期に使用しています。しかし、ログを確認すると、セッションが複数回初期化されているように見えます。ストームトポロジのdbUtilsは準備メソッドでのみ初期化され、準備/実行/クリーンアップメソッド全体で使用されています。したがって、すべてのスレッドで使用したい変数が複数の場所で使用されている場合は、synchronizedブロックを使用する方法がわかりません。 私の質問は、セッション/ dbUtils変数の初期化を全スレッドを通して一度だけ行う方法です。

Answer 1

ストームはシステムで配布されているため、並列実行中のすべてのボルトに1つの共有変数を設定することはできません。 1つのワーカーJVM内でエグゼキュータ上で変数を共有することしかできませんでした。

これを行うには、static変数を作成し、共有/静的オブジェクトインスタンスを使用してその初期化を同期させる必要があります。