Springのトランザクション中にElasticsearchインデックスに変更されたJPAエンティティを一括検索する

Question

私は、ElasticsearchドキュメントでもあるJPAエンティティクラスを持っています。この環境は、Spring Data JpaとSpring Data Elasticsearchを使用したSpring Bootアプリケーションです。

@Entity 
@Document(indexname...etc) 
@EntityListeners(MyJpaEntityListener.class) 
public class MyEntity { 
    //ID, constructor and stuff following here 
} 

このエンティティのインスタンスが作成、更新、または削除されると、Elasticsearchに再インデックスされます。これは現在、PostPersist、PostUpdate、およびPostRemoveイベントに反応するJPA EntityListenerで実現されています。

public class MyJpaEntityListener { 

    @PostPersist 
    @PostUpdate 
    public void postPersistOrUpdate(MyEntity entity) { 
     //Elasticsearch indexing code gets here 
    } 

    @PostRemove 
    public void postPersistOrUpdate(MyEntity entity) { 
     //Elasticsearch indexing code gets here 
    } 
} 

That's単一または少数のエンティティが単一のトランザクション中に変更されます現時点では、すべての作業罰金。各変更により、別々の索引操作がトリガーされます。しかし、多くのエンティティがトランザクション内で変更された場合、トランザクションは遅くなります。

トランザクションの終了時（またはコミット後）に変更されたすべてのエンティティをbulkindexしたいとします。私はTransactionalEventListeners、AOP、TransactionSynchronizationManagerを見ていましたが、これまでのところ良い設定を思いついたわけではありませんでした。

どのようにして、すべての変更されたエンティティをトランザクションごとにエレガントに収集することができますか？

また、トランザクションの最後に、このトランザクションの収集されたエンティティを使用してバルクインデックスをトリガーできます。

あなたの時間と助けてくれてありがとう！

Answer 1

あなたのサービスとエンティティをelasticsearch関連のコードと混在させないように、私の意見ではエレガントなアプローチは、サービスレイヤのトランザクションメソッドで@AfterReturningを使用することです。

pointcut expressionは、必要なすべてのサービス方法をキャッチするように調整できます。

@Order（1）は、このコードがトランザクションコミット後に実行されることを保証します。

以下のコードはサンプルに過ぎません。プロジェクトで使用するには、このサンプルを使用する必要があります。

@Aspect 
@Component() 
@Order(1) 
public class StoreDataToElasticAspect { 

    @Autowired 
    private SampleElasticsearhRepository elasticsearchRepository; 


    @AfterReturning(pointcut = "execution(* com.example.DatabaseService.bulkInsert(..))") 
    public void synonymsInserted(JoinPoint joinPoint) { 
     Object[] args = joinPoint.getArgs(); 
     //create elasticsearch documents from method params. 
     //can also inject database services if more information is needed for the documents. 
     List<String> ids = (List) args[0]; 
     //create batch from ids 
     elasticsearchRepository.save(batch); 
    } 
} 

ここでは、ログの態様を持つexampleがあります。