\u672c\u6587\u4e3b\u8981\u7814\u7a76\u4e00\u4e0bTransactionSynchronization\u7684invokeAfterCompletion<\/p>\n
org\/springframework\/transaction\/support\/TransactionSynchronization.java<\/p>\n
public interface TransactionSynchronization extends Flushable {\n\n \/** Completion status in case of proper commit. *\/\n int STATUS_COMMITTED = 0;\n\n \/** Completion status in case of proper rollback. *\/\n int STATUS_ROLLED_BACK = 1;\n\n \/** Completion status in case of heuristic mixed completion or system errors. *\/\n int STATUS_UNKNOWN = 2;\n\n \/\/......\n\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 }\n\n \/**\n * Invoked after transaction commit\/rollback.\n * Can perform resource cleanup <i>after<\/i> transaction completion.\n * <p><b>NOTE:<\/b> The transaction will have been committed or rolled back already,\n * but the transactional resources might still be active and accessible. As a\n * consequence, any data access code triggered at this point will still "participate"\n * in the original transaction, allowing to perform some cleanup (with no commit\n * following anymore!), unless it explicitly declares that it needs to run in a\n * separate transaction. Hence: <b>Use {@code PROPAGATION_REQUIRES_NEW}\n * for any transactional operation that is called from here.<\/b>\n * @param status completion status according to the {@code STATUS_*} constants\n * @throws RuntimeException in case of errors; will be <b>logged but not propagated<\/b>\n * (note: do not throw TransactionException subclasses here!)\n * @see #STATUS_COMMITTED\n * @see #STATUS_ROLLED_BACK\n * @see #STATUS_UNKNOWN\n * @see #beforeCompletion\n *\/\n default void afterCompletion(int status) {\n }\n\n}<\/code><\/pre>\nafterCompletion\u65b9\u6cd5\u6709\u5165\u53c2status\uff0c\u8868\u793a\u4e8b\u52a1\u7ed3\u675f\u65f6\u5019\u7684\u72b6\u6001\uff0c0\u8868\u793a\u4e8b\u52a1\u5df2\u63d0\u4ea4\uff0c1\u8868\u793a\u4e8b\u52a1\u5df2\u56de\u6eda\uff0c2\u8868\u793a\u4e8b\u52a1\u672a\u77e5\uff1b\u4e0eafterCommit\u7684\u4e00\u4e2a\u6700\u91cd\u8981\u7684\u533a\u522b\u662fafterCompletion\u7684\u5f02\u5e38\u4f1a\u88ab\u6355\u83b7\uff0c\u4e0d\u50cfafterCommit\u4f1a\u629b\u7ed9\u8c03\u7528\u65b9<\/p><\/blockquote>\n
invokeAfterCompletion<\/h2>\n
org\/springframework\/transaction\/support\/TransactionSynchronizationUtils.java<\/p>\n
\/**\n * Actually invoke the {@code afterCompletion} methods of the\n * given Spring TransactionSynchronization objects.\n * @param synchronizations a List of TransactionSynchronization objects\n * @param completionStatus the completion status according to the\n * constants in the TransactionSynchronization interface\n * @see TransactionSynchronization#afterCompletion(int)\n * @see TransactionSynchronization#STATUS_COMMITTED\n * @see TransactionSynchronization#STATUS_ROLLED_BACK\n * @see TransactionSynchronization#STATUS_UNKNOWN\n *\/\n public static void invokeAfterCompletion(@Nullable List<TransactionSynchronization> synchronizations,\n int completionStatus) {\n\n if (synchronizations != null) {\n for (TransactionSynchronization synchronization : synchronizations) {\n try {\n synchronization.afterCompletion(completionStatus);\n }\n catch (Throwable tsex) {\n logger.error("TransactionSynchronization.afterCompletion threw exception", tsex);\n }\n }\n }\n }<\/code><\/pre>\n\u53ef\u4ee5\u770b\u5230TransactionSynchronizationUtils\u7684invokeAfterCompletion\u65b9\u6cd5\u4f1a\u904d\u5386synchronizations\uff0c\u6328\u4e2a\u6267\u884cafterCompletion\uff0c\u6ce8\u610f\u8fd9\u91cccatch\u4e86Throwable\u5f02\u5e38\uff0c\u8fdb\u884c\u4e86error\u7ea7\u522b\u7684log<\/p><\/blockquote>\n
AbstractPlatformTransactionManager<\/h2>\n
org\/springframework\/transaction\/support\/AbstractPlatformTransactionManager.java<\/p>\n
\/**\n * Actually invoke the {@code afterCompletion} methods of the\n * given Spring TransactionSynchronization objects.\n * <p>To be called by this abstract manager itself, or by special implementations\n * of the {@code registerAfterCompletionWithExistingTransaction} callback.\n * @param synchronizations a List of TransactionSynchronization objects\n * @param completionStatus the completion status according to the\n * constants in the TransactionSynchronization interface\n * @see #registerAfterCompletionWithExistingTransaction(Object, java.util.List)\n * @see TransactionSynchronization#STATUS_COMMITTED\n * @see TransactionSynchronization#STATUS_ROLLED_BACK\n * @see TransactionSynchronization#STATUS_UNKNOWN\n *\/\n protected final void invokeAfterCompletion(List<TransactionSynchronization> synchronizations, int completionStatus) {\n TransactionSynchronizationUtils.invokeAfterCompletion(synchronizations, completionStatus);\n }\n\n \/**\n * Trigger {@code afterCompletion} callbacks.\n * @param status object representing the transaction\n * @param completionStatus completion status according to TransactionSynchronization constants\n *\/\n private void triggerAfterCompletion(DefaultTransactionStatus status, int completionStatus) {\n if (status.isNewSynchronization()) {\n List<TransactionSynchronization> synchronizations = TransactionSynchronizationManager.getSynchronizations();\n TransactionSynchronizationManager.clearSynchronization();\n if (!status.hasTransaction() || status.isNewTransaction()) {\n if (status.isDebug()) {\n logger.trace("Triggering afterCompletion synchronization");\n }\n \/\/ No transaction or new transaction for the current scope ->\n \/\/ invoke the afterCompletion callbacks immediately\n invokeAfterCompletion(synchronizations, completionStatus);\n }\n else if (!synchronizations.isEmpty()) {\n \/\/ Existing transaction that we participate in, controlled outside\n \/\/ of the scope of this Spring transaction manager -> try to register\n \/\/ an afterCompletion callback with the existing (JTA) transaction.\n registerAfterCompletionWithExistingTransaction(status.getTransaction(), synchronizations);\n }\n }\n }<\/code><\/pre>\nAbstractPlatformTransactionManager\u7684invokeAfterCompletion\u59d4\u6258\u7ed9\u4e86TransactionSynchronizationUtils.invokeAfterCompletion\uff1btriggerAfterCompletion\u4e3b\u8981\u662f\u6839\u636e\u4e8b\u52a1\u72b6\u6001\u6267\u884c\u4e0d\u540c\u903b\u8f91\uff0c\u5206\u522b\u662finvokeAfterCompletion\u4e0eregisterAfterCompletionWithExistingTransaction\uff0c\u540e\u8005\u4e3b\u8981\u662fJTA\u4e4b\u7c7b\u7684\u573a\u666f\uff0c\u5b83\u56de\u4f20\u7684status\u662fSTATUS_UNKNOWN<\/p><\/blockquote>\n
\u5c0f\u7ed3<\/h2>\n
afterCompletion\u65b9\u6cd5\u6709\u5165\u53c2status\uff0c\u8868\u793a\u4e8b\u52a1\u7ed3\u675f\u65f6\u5019\u7684\u72b6\u6001\uff0c0\u8868\u793a\u4e8b\u52a1\u5df2\u63d0\u4ea4\uff0c1\u8868\u793a\u4e8b\u52a1\u5df2\u56de\u6eda\uff0c2\u8868\u793a\u4e8b\u52a1\u672a\u77e5(\u4e00\u822c\u662fJTA\u76f8\u5173<\/code>)\uff1b\u4e0eafterCommit\u7684\u4e00\u4e2a\u6700\u91cd\u8981\u7684\u533a\u522b\u662fafterCompletion\u7684\u5f02\u5e38(Throwable<\/code>)\u4f1a\u88ab\u6355\u83b7\uff0c\u4e0d\u50cfafterCommit\u4f1a\u629b\u7ed9\u8c03\u7528\u65b9<\/p>\ndoc<\/h2>\n