\u672c\u6587\u4e3b\u8981\u7814\u7a76\u4e00\u4e0bspring\u7684TransactionSynchronizationAdapter<\/p>\n
public void insert(TechBook techBook){\n bookMapper.insert(techBook);\n \/\/ send after tx commit but is async\n TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {\n @Override\n public void afterCommit() {\n System.out.println("send email after transaction commit...");\n }\n }\n );\n System.out.println("service end");\n }<\/code><\/pre>\n\u4f7f\u7528TransactionSynchronizationManager.registerSynchronization\u6ce8\u518c\u4e86\u4e00\u4e2aTransactionSynchronizationAdapter\uff0c\u5728\u5176afterCommit\u65b9\u6cd5\u4e5f\u5c31\u662f\u4e8b\u52a1\u63d0\u4ea4\u6210\u529f\u4e4b\u540e\u6267\u884c\u4e00\u4e9b\u989d\u5916\u903b\u8f91<\/p><\/blockquote>\n
TransactionSynchronizationAdapter<\/h2>\n
org\/springframework\/transaction\/support\/TransactionSynchronizationAdapter.java<\/p>\n
public abstract class TransactionSynchronizationAdapter implements TransactionSynchronization, Ordered {\n\n @Override\n public int getOrder() {\n return Ordered.LOWEST_PRECEDENCE;\n }\n\n @Override\n public void suspend() {\n }\n\n @Override\n public void resume() {\n }\n\n @Override\n public void flush() {\n }\n\n @Override\n public void beforeCommit(boolean readOnly) {\n }\n\n @Override\n public void beforeCompletion() {\n }\n\n @Override\n public void afterCommit() {\n }\n\n @Override\n public void afterCompletion(int status) {\n }\n\n}<\/code><\/pre>\nTransactionSynchronizationAdapter\u662f\u4e2a\u62bd\u8c61\u7c7b\uff0c\u58f0\u660e\u5b9e\u73b0TransactionSynchronization\u53caOrdered\u63a5\u53e3<\/p><\/blockquote>\n
TransactionSynchronization<\/h2>\n
org\/springframework\/transaction\/support\/TransactionSynchronization.java<\/p>\n
\/**\n * Invoked after transaction commit. Can perform further operations right\n * <i>after<\/i> the main transaction has <i>successfully<\/i> committed.\n * <p>Can e.g. commit further operations that are supposed to follow on a successful\n * commit of the main transaction, like confirmation messages or emails.\n * <p><b>NOTE:<\/b> The transaction will have been committed already, but the\n * transactional resources might still be active and accessible. As a consequence,\n * any data access code triggered at this point will still "participate" in the\n * original transaction, allowing to perform some cleanup (with no commit following\n * anymore!), unless it explicitly declares that it needs to run in a separate\n * transaction. Hence: <b>Use {@code PROPAGATION_REQUIRES_NEW} for any\n * transactional operation that is called from here.<\/b>\n * @throws RuntimeException in case of errors; will be <b>propagated to the caller<\/b>\n * (note: do not throw TransactionException subclasses here!)\n *\/\n default void afterCommit() {\n }<\/code><\/pre>\n\u6ce8\u610f\u8fd9\u91cc\u6ce8\u91ca\u8bf4\u660e\u4e86\u5f02\u5e38\u4e0d\u4f1a\u88ab\u6355\u83b7\uff0c\u800c\u4e14\u5efa\u8bae\u4e0d\u5728\u8fd9\u91cc\u629b\u51faTransactionException\u7684\u5b50\u7c7b\uff1b\u53e6\u5916\u5bf9\u4e8eafterCommit\u6709\u6570\u636e\u5e93\u76f8\u5173\u64cd\u4f5c\u7684\u5efa\u8bae\u4f7f\u7528PROPAGATION_REQUIRES_NEW\u8fd9\u4e2a\u4e8b\u52a1\u4f20\u64ad\u7ea7\u522b\uff0c\u4e0d\u7136afterCommit\u7684\u64cd\u4f5c\u53ef\u80fd\u4e0d\u4f1a\u751f\u6548<\/p><\/blockquote>\n
registerSynchronization<\/h2>\n
org\/springframework\/transaction\/support\/TransactionSynchronizationManager.java<\/p>\n
\n private static final ThreadLocal<Set<TransactionSynchronization>> synchronizations =\n new NamedThreadLocal<>("Transaction synchronizations");\n\n \/**\n * Register a new transaction synchronization for the current thread.\n * Typically called by resource management code.\n * <p>Note that synchronizations can implement the\n * {@link org.springframework.core.Ordered} interface.\n * They will be executed in an order according to their order value (if any).\n * @param synchronization the synchronization object to register\n * @throws IllegalStateException if transaction synchronization is not active\n * @see org.springframework.core.Ordered\n *\/\n public static void registerSynchronization(TransactionSynchronization synchronization)\n throws IllegalStateException {\n\n Assert.notNull(synchronization, "TransactionSynchronization must not be null");\n Set<TransactionSynchronization> synchs = synchronizations.get();\n if (synchs == null) {\n throw new IllegalStateException("Transaction synchronization is not active");\n }\n synchs.add(synchronization);\n }<\/code><\/pre>\nTransactionSynchronizationManager\u7684registerSynchronization\u65b9\u6cd5\u4f1a\u628aTransactionSynchronization\u6ce8\u518c\u5230\u5f53\u524d\u7ebf\u7a0b\u7684synchronizations<\/p><\/blockquote>\n
processCommit<\/h2>\n
org\/springframework\/transaction\/support\/AbstractPlatformTransactionManager.java<\/p>\n
private void processCommit(DefaultTransactionStatus status) throws TransactionException {\n try {\n boolean beforeCompletionInvoked = false;\n\n try {\n boolean unexpectedRollback = false;\n prepareForCommit(status);\n triggerBeforeCommit(status);\n triggerBeforeCompletion(status);\n beforeCompletionInvoked = true;\n\n if (status.hasSavepoint()) {\n if (status.isDebug()) {\n logger.debug("Releasing transaction savepoint");\n }\n unexpectedRollback = status.isGlobalRollbackOnly();\n status.releaseHeldSavepoint();\n }\n else if (status.isNewTransaction()) {\n if (status.isDebug()) {\n logger.debug("Initiating transaction commit");\n }\n unexpectedRollback = status.isGlobalRollbackOnly();\n doCommit(status);\n }\n else if (isFailEarlyOnGlobalRollbackOnly()) {\n unexpectedRollback = status.isGlobalRollbackOnly();\n }\n\n \/\/ Throw UnexpectedRollbackException if we have a global rollback-only\n \/\/ marker but still didn't get a corresponding exception from commit.\n if (unexpectedRollback) {\n throw new UnexpectedRollbackException(\n "Transaction silently rolled back because it has been marked as rollback-only");\n }\n }\n catch (UnexpectedRollbackException ex) {\n \/\/ can only be caused by doCommit\n triggerAfterCompletion(status, TransactionSynchronization.STATUS_ROLLED_BACK);\n throw ex;\n }\n catch (TransactionException ex) {\n \/\/ can only be caused by doCommit\n if (isRollbackOnCommitFailure()) {\n doRollbackOnCommitException(status, ex);\n }\n else {\n triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN);\n }\n throw ex;\n }\n catch (RuntimeException | Error ex) {\n if (!beforeCompletionInvoked) {\n triggerBeforeCompletion(status);\n }\n doRollbackOnCommitException(status, ex);\n throw ex;\n }\n\n \/\/ Trigger afterCommit callbacks, with an exception thrown there\n \/\/ propagated to callers but the transaction still considered as committed.\n try {\n triggerAfterCommit(status);\n }\n finally {\n triggerAfterCompletion(status, TransactionSynchronization.STATUS_COMMITTED);\n }\n\n }\n finally {\n cleanupAfterCompletion(status);\n }\n }\n\n private void triggerAfterCommit(DefaultTransactionStatus status) {\n if (status.isNewSynchronization()) {\n if (status.isDebug()) {\n logger.trace("Triggering afterCommit synchronization");\n }\n TransactionSynchronizationUtils.triggerAfterCommit();\n }\n }<\/code><\/pre>\nAbstractPlatformTransactionManager\u7684processCommit\u65b9\u6cd5\uff0c\u5728\u63d0\u4ea4\u6210\u529f\u4e4b\u540e\u89e6\u53d1triggerAfterCommit\uff0c\u8fd9\u91cc\u8c03\u7528\u4e86TransactionSynchronizationUtils.triggerAfterCommit()\uff0c\u6ce8\u610f\u8fd9\u91cc\u6ca1\u6709try catch\uff0c\u8bf4\u660etriggerAfterCommit\u7684\u5f02\u5e38\u6700\u7ec8\u4f1a\u629b\u7ed9\u8c03\u7528\u65b9<\/p><\/blockquote>\n
triggerAfterCommit<\/h2>\n
org\/springframework\/transaction\/support\/TransactionSynchronizationUtils.java<\/p>\n
public static void triggerAfterCommit() {\n invokeAfterCommit(TransactionSynchronizationManager.getSynchronizations());\n }\n\n public static void invokeAfterCommit(@Nullable List<TransactionSynchronization> synchronizations) {\n if (synchronizations != null) {\n for (TransactionSynchronization synchronization : synchronizations) {\n synchronization.afterCommit();\n }\n }\n }<\/code><\/pre>\n\u8fd9\u91cc\u904d\u5386synchronizations\u6267\u884cafterCommit\u65b9\u6cd5\uff0c\u5982\u679c\u5176\u4e2d\u6709\u4e00\u4e2a\u6709\u5f02\u5e38\u629b\u51fa\u5219\u4e2d\u65ad<\/p><\/blockquote>\n
\u5c0f\u7ed3<\/h2>\n
\u4f7f\u7528TransactionSynchronizationManager.registerSynchronization\u53ef\u4ee5\u5728\u5f53\u524d\u7ebf\u7a0b\u7684\u4e8b\u52a1\u6ce8\u518c\u4e00\u4e2aTransactionSynchronizationAdapter\uff0c\u53ef\u4ee5\u5728afterCommit\u65b9\u6cd5\u4e5f\u5c31\u662f\u4e8b\u52a1\u63d0\u4ea4\u6210\u529f\u4e4b\u540e\u6267\u884c\u4e00\u4e9b\u989d\u5916\u903b\u8f91\uff1b\u6ce8\u610f\u8fd9\u91cc\u629b\u51fa\u7684\u5f02\u5e38\u4e0d\u5f71\u54cd\u4e8b\u52a1\u63d0\u4ea4\uff0c\u4f46\u662f\u5f02\u5e38\u4e0d\u4f1a\u88abcatch\u9700\u8981\u7531\u8c03\u7528\u65b9\u5904\u7406\uff0c\u5bf9\u4e8eafterCommit\u6709\u6570\u636e\u5e93\u76f8\u5173\u64cd\u4f5c\u7684\u5efa\u8bae\u4f7f\u7528PROPAGATION_REQUIRES_NEW\u8fd9\u4e2a\u4e8b\u52a1\u4f20\u64ad\u7ea7\u522b\uff0c\u4e0d\u7136afterCommit\u7684db\u64cd\u4f5c\u53ef\u80fd\u4e0d\u4f1a\u751f\u6548\u3002<\/p>\n
\u5728\u4e8b\u52a1\u63d0\u4ea4\u4e4b\u540e\u505a\u4e00\u4e9b\u4e8b\u60c5\u53ef\u80fd\u4e0d\u9700\u8981TransactionSynchronizationManager.registerSynchronization\u8fd9\u79cd\u65b9\u5f0f\u4e5f\u80fd\u5b9e\u73b0\uff0c\u4e5f\u5c31\u662f\u9700\u8981\u989d\u5916\u4e00\u5c42\u6765\u8c03\u7528\u4e8b\u52a1\u64cd\u4f5c\uff0c\u6709\u5f02\u5e38\u4f1a\u629b\u51fa\uff0c\u6ca1\u6709\u5f02\u5e38\u5219\u6267\u884c\u4e8b\u52a1\u63d0\u4ea4\u4e4b\u540e\u7684\u4e8b\u60c5\uff0c\u524d\u63d0\u5c31\u662f\u4e8b\u52a1\u56de\u6eda\u5f02\u5e38\u4e0d\u80fd\u88ab\u541e\u6389\uff0c\u4e0d\u7136\u5916\u5c42\u8c03\u7528\u53ef\u80fd\u4ee5\u4e3a\u4e8b\u52a1\u6210\u529f\u4e86
\u8fd8\u6709\u4e00\u79cd\u65b9\u5f0f\u5c31\u662f\u4f7f\u7528TransactionalEventListener\uff0c\u8fd9\u79cd\u65b9\u5f0f\u6bd4TransactionSynchronizationManager.registerSynchronization\u66f4\u4e3a\u4f18\u96c5\u4e00\u4e9b<\/p><\/blockquote>\n
doc<\/h2>\n