Yay İşlemi Ek Açıklamaları - Başarı ile Çalıştırın

Question

Belirli olayların meydana geldiği durumlarda daha geniş bir sistemi bilgilendirmek için hizmet uygulamamdaki Yay uygulama olaylarını kullanıyorum. Sahip olduğum sorun, olayların bir işlem bağlamında işlenmesidir (Spring'in @Transactional ek açıklamasını kullanıyorum). Tehlike, bir olayı tetiklemem ve daha sonra işlemin başarısızlığa uğramasıdır (örneğin, Hazırda Bekletme kullanılırken meydana gelebilir). Bu senaryoda, olay dinleyicileri, idam edildikten sonra geri alınacak bazı durumları üstlenecekler. Buradaki tehlike, örneğin, kullanıcı hesabının gerçekte oluşturulmadığı bir web sitesinde kullanıcı kaydını onaylamak için bir e-posta gönderdiğim.

Ek açıklamaların kullanımını koruyan bir yol var mı? İşlemin yapılmasının ardından bir olayın tetikleneceği bir yere işaret mi edilmeli? Java Swing'de GUI programlama yaparken SwingUtilities.invokeLater(Runnable runnable)'u kullanmaya benziyor. Mevcut işlem başarıyla tamamlandığında, bu kodu biraz sonra yürütmek istiyorum.

Herhangi bir fikrin var mı?

sayesinde

Andrew

Answer 1

onay e-postalar ile sorunu çözmek için uygun yolu onlara katılan JMS kaynakla bir dağıtılmış işlemler kullanmak üzere muhtemelen.

Ancak, kirli hızlı ve-çözüm olarak, size taahhüt başarılı sonra biraz ThreadLocal depolama kayıtlı Runnable s çalıştırır bir PlatformTransactionManager etrafında sarıcı oluşturmaya çalışabilir (ve geri alma sonra ThreadLocal çıkarın). Aslında, AbstractPlatformTransactionManager, TransactionSynchronization s ile tam olarak bu tür bir mantığa sahiptir, ancak uygulama ayrıntılarının çok derinlerine gömülüdür.

Answer 2

PlatformTransactionManager'ı kesmeye gerek kalmadan TransactionSynchronizationManager'ı kullanabilirsiniz.

Not: TransactionAware, bir ApplicationListener işlem başarılı bir şekilde işlendikten sonra bir Event almak istediğini belirten bir işaretçi arabirimidir.

public class TransactionAwareApplicationEventMulticaster extends SimpleApplicationEventMulticaster { 

    @Override 
    public void multicastEvent(ApplicationEvent event) { 
     for (ApplicationListener listener : getApplicationListeners(event)) { 
      if ((listener instanceof TransactionAware) && TransactionSynchronizationManager.isSynchronizationActive()) { 
       TransactionSynchronizationManager.registerSynchronization(
        new EventTransactionSynchronization(listener, event)); 
      } 
      else { 
       notifyEvent(listener, event); 
      } 
     } 
    } 

    void notifyEvent(final ApplicationListener listener, final ApplicationEvent event) { 
      Executor executor = getTaskExecutor(); 
      if (executor != null) { 
       executor.execute(new Runnable() { 
        public void run() { 
         listener.onApplicationEvent(event); 
        } 
       }); 
      } 
      else { 
       listener.onApplicationEvent(event); 
      } 
    } 

    class EventTransactionSynchronization extends TransactionSynchronizationAdapter { 
     private final ApplicationListener listener; 
     private final ApplicationEvent event; 

     EventTransactionSynchronization(ApplicationListener listener, ApplicationEvent event) { 
      this.listener = listener; 
      this.event = event; 
     } 

     @Override 
     public void afterCompletion(int status) { 
      if ((phase == TransactionPhase.AFTER_SUCCESS) 
        && (status == TransactionSynchronization.STATUS_COMMITTED)) { 
       notifyEvent(listener, event); 
      } 
     } 
    } 
} 

Answer 3

Bu benim için çalışıyor:

TransactionSynchronizationManager.registerSynchronization(
    new TransactionSynchronizationAdapter() { 
     @Override 
     public void afterCommit() { 
      // things to do when commited 
     } 
     // other methods to override are available too 
    });