tự động đăng ký người nghe giao dịch với mùa xuân?

Question

Tôi có một ứng dụng springframework trong đó tôi muốn thêm một người nghe giao dịch vào một giao dịch hiện đang được tiến hành. Động lực là kích hoạt một hành động cam kết đăng bài thông báo cho các hệ thống hạ lưu. Tôi đang sử dụng @Transactional để gói giao dịch xung quanh một số phương thức dịch vụ - đó là nơi tôi muốn tạo/đăng ký trình xử lý giao dịch bài đăng. Tôi muốn làm một cái gì đó "như" sau đây.

public class MyService { 
@Transaction 
public void doIt() { 
    modifyObjects(); 

    // something like this 
    getTransactionManager().registerPostCommitAction(new 
    TransactionSynchronizationAdapter() { 
    public void afterCommit() { 
     notifyDownstream(); 
    } 
    }); 
} 
} 

Mùa xuân có giao diện TransactionSynchronization và lớp bộ điều hợp có vẻ chính xác những gì tôi muốn; tuy nhiên, không rõ ngay cách đăng ký một cách động với giao dịch hiện tại hoặc người quản lý giao dịch. Tôi không muốn phân lớp JtaTransactionManager nếu tôi có thể tránh nó.

Q: Có ai đã làm điều này trước đây.

Q: cách đơn giản nhất để đăng ký bộ điều hợp của tôi là gì?

Answer 1

bạn có thể sử dụng một khía cạnh aspect to match phương pháp giao dịch trong dịch vụ của bạn để thực hiện điều này:

@Aspect 
public class AfterReturningExample { 

    @AfterReturning("execution(* com.mypackage.MyService.*(..))") 
    public void afterReturning() { 
    // ... 
    } 

} 

Answer 2

Trên thực tế nó là không khó như tôi nghĩ; mùa xuân có một lớp trợ giúp tĩnh đặt các công cụ 'đúng' vào ngữ cảnh luồng.

TransactionSynchronizationManager.registerSynchronization(
    new TransactionSynchronizationAdapter() { 
     @Override 
     public void afterCommit() { 
      s_logger.info("TRANSACTION COMPLETE!!!"); 
     } 
    } 
); 

Answer 3

Dưới đây là giải pháp hoàn chỉnh hơn mà tôi đã thực hiện cho một vấn đề tương tự với việc gửi thư của tôi sau khi giao dịch được thực hiện (tôi có thể đã sử dụng RabbitMQ TX nhưng chúng khá chậm).

public class MessageBusUtils { 
    public static Optional<MessageBusResourceHolder> getTransactionalResourceHolder(TxMessageBus messageBus) { 

     if (! TransactionSynchronizationManager.isActualTransactionActive()) { 
      return Optional.absent(); 
     } 

     MessageBusResourceHolder o = (MessageBusResourceHolder) TransactionSynchronizationManager.getResource(messageBus); 
     if (o != null) return Optional.of(o); 

     o = new MessageBusResourceHolder(); 
     TransactionSynchronizationManager.bindResource(messageBus, o); 
     o.setSynchronizedWithTransaction(true); 
     if (TransactionSynchronizationManager.isSynchronizationActive()) { 
      TransactionSynchronizationManager.registerSynchronization(new MessageBusResourceSynchronization(o, messageBus)); 
     } 
     return Optional.of(o); 

    } 

    private static class MessageBusResourceSynchronization extends ResourceHolderSynchronization<MessageBusResourceHolder, TxMessageBus> { 
     private final TxMessageBus messageBus; 
     private final MessageBusResourceHolder holder; 

     public MessageBusResourceSynchronization(MessageBusResourceHolder resourceHolder, TxMessageBus resourceKey) { 
      super(resourceHolder, resourceKey); 
      this.messageBus = resourceKey; 
      this.holder = resourceHolder; 
     } 


     @Override 
     protected void cleanupResource(MessageBusResourceHolder resourceHolder, TxMessageBus resourceKey, 
       boolean committed) { 
      resourceHolder.getPendingMessages().clear(); 
     } 

     @Override 
     public void afterCompletion(int status) { 
      if (status == TransactionSynchronization.STATUS_COMMITTED) { 
       for (Object o : holder.getPendingMessages()) { 
        messageBus.post(o, false); 
       } 
      } 
      else { 
       holder.getPendingMessages().clear(); 
      } 
      super.afterCompletion(status); 
     } 


    } 
} 

public class MessageBusResourceHolder extends ResourceHolderSupport { 

    private List<Object> pendingMessages = Lists.newArrayList(); 

    public void addMessage(Object message) { 
     pendingMessages.add(message); 
    } 


    protected List<Object> getPendingMessages() { 
     return pendingMessages; 
    } 

} 

Bây giờ trong lớp học của bạn, nơi bạn có thực sự gửi tin nhắn bạn sẽ làm

@Override 
public void postAfterCommit(Object o) { 
    Optional<MessageBusResourceHolder> holder = MessageBusTxUtils.getTransactionalResourceHolder(this); 
    if (holder.isPresent()) { 
     holder.get().addMessage(o); 
    } 
    else { 
     post(o, false); 
    } 
} 

Xin lỗi cho các mẫu mã hơi dài nhưng hy vọng rằng sẽ hiển thị một người nào đó làm thế nào để làm điều gì đó sau một cam kết.

Answer 4

Có ý nghĩa khi ghi đè trình quản lý giao dịch lên các phương thức cam kết và khôi phục, gọi số super.commit() ngay lúc đầu.