{"id":1925,"date":"2019-09-10T08:11:27","date_gmt":"2019-09-10T00:11:27","guid":{"rendered":"https:\/\/coderbee.net\/?p=1925"},"modified":"2019-09-09T22:12:16","modified_gmt":"2019-09-09T14:12:16","slug":"spring-%e4%ba%8b%e5%8a%a1%e9%92%a9%e5%ad%90","status":"publish","type":"post","link":"https:\/\/coderbee.net\/index.php\/framework\/20190910\/1925","title":{"rendered":"Spring \u4e8b\u52a1\u94a9\u5b50"},"content":{"rendered":"<h1>1. \u5e94\u7528\u573a\u666f\u8bf4\u660e<\/h1>\n<p>\u6709\u591a\u4e2a\u4e8b\u52a1\u53d1\u8d77\u7684\u70b9 E0\u3001E1\uff0c\u90fd\u8c03\u7528\u5230\u9700\u8981\u5728\u4e8b\u52a1\u91cc\u6267\u884c\u7684\u65b9\u6cd5 M0\u3001M1\uff0cM0\u3001M1 \u91cc\u90fd\u53ef\u80fd\u4ea7\u751f\u4e00\u4e9b\u903b\u8f91\uff1a\u4e00\u4e9b\u4f5c\u4e3a\u4e8b\u52a1\u7684\u4e00\u90e8\u5206\u6267\u884c\u3001\u4e00\u4e9b\u5728\u4e8b\u52a1\u63d0\u4ea4\u5931\u8d25\u65f6\u6267\u884c\u3001\u4e00\u4e9b\u5728\u4e8b\u52a1\u6210\u529f\u63d0\u4ea4\u540e\u6267\u884c\u3002<\/p>\n<h1>2. \u81ea\u884c\u5b9e\u73b0\u7684\u4e00\u4e2a\u7b80\u964b\u5b9e\u73b0<\/h1>\n<p>\u5e94\u7528\u547d\u4ee4\u6a21\u5f0f\u628a\u8981\u6839\u636e\u4e8b\u52a1\u662f\u5426\u63d0\u4ea4\u6210\u529f\u6765\u51b3\u5b9a\u6267\u884c\u7684\u903b\u8f91\u5c01\u88c5\u6210\u4e00\u4e2a\u547d\u4ee4\uff0c\u5728\u4e8b\u52a1\u4e4b\u5916\u6765\u6267\u884c\u3002<\/p>\n<p>\u5b9a\u4e49\u4e86\u4e0b\u9762\u8fd9\u6837\u4e00\u4e2a\u7c7b\uff0c\u5206\u522b\u7528\u4e8e\u6536\u96c6\u5728\u4e8b\u52a1\u63d0\u4ea4\u6210\u529f\u548c\u5931\u8d25\u540e\u6267\u884c\u7684\u903b\u8f91\uff1a<\/p>\n<pre><code class=\"java\">public class Actions {\n    private List&lt;Runnable&gt; transactionCommitSuccessActions = new ArrayList&lt;Runnable&gt;();\n    private List&lt;Runnable&gt; transactionCommitFailedActions = new ArrayList&lt;Runnable&gt;();\n}\n<\/code><\/pre>\n<p>\u5728\u5f00\u542f\u4e8b\u52a1\u524d\u521d\u59cb\u5316\u4e00\u4e2a Actions \u5bf9\u8c61\uff0c\u7136\u540e\u4e8b\u52a1\u65b9\u6cd5\u8c03\u7528\u5230\u7684\u65b9\u6cd5\u90fd\u5f97\u4f20\u9012\u8fd9\u4e2a\u5bf9\u8c61\uff0c\u5728\u4e8b\u52a1\u65b9\u6cd5\u7ed3\u675f\u540e\u5c31\u53ef\u4ee5\u6839\u636e\u4e8b\u52a1\u662f\u5426\u6210\u529f\u6765\u6267\u884c\u4e0d\u540c\u7684\u961f\u5217\u91cc\u7684\u903b\u8f91\u3002<\/p>\n<p><!--more--><\/p>\n<h1>3. Spring \u5185\u7f6e\u7684\u4e8b\u52a1\u94a9\u5b50<\/h1>\n<p>\u524d\u6bb5\u65f6\u95f4\u770b\u5230\u8fd9\u7bc7\u6587\u7ae0 <a href=\"https:\/\/www.infoq.cn\/article\/uMQb2CFDgRFcDUz9OFD1\">\u5927\u641c\u8f66\u5f02\u6b65\u4efb\u52a1\u961f\u5217\u4e2d\u95f4\u4ef6\u7684\u5efa\u8bbe\u5b9e\u8df5<\/a> \u624d\u53d1\u73b0 Spring \u4e00\u76f4\u5c31\u81ea\u5e26\u6709\u4e8b\u52a1\u94a9\u5b50 <code>TransactionSynchronizationManager<\/code>\uff0c\u8981\u6267\u884c\u7684\u903b\u8f91\u5c01\u88c5\u6210 <code>TransactionSynchronization<\/code> \u5bf9\u8c61\u3002<\/p>\n<p>\u94a9\u5b50\u5b9a\u4e49\uff1a<\/p>\n<pre><code class=\"java\">public interface TransactionSynchronization extends Flushable {\n    \/\/ \u4e8b\u52a1\u6b63\u5e38\u63d0\u4ea4\u7ed3\u675f\n    int STATUS_COMMITTED = 0;\n\n    \/\/ \u4e8b\u52a1\u4ee5\u56de\u6eda\u7ed3\u675f\n    int STATUS_ROLLED_BACK = 1;\n\n    \/** Completion status in case of heuristic mixed completion or system errors. *\/\n    \/\/ \u4ee5\u542f\u53d1\u5f0f\u6df7\u5408\u7ed3\u675f\u6216\u7cfb\u7edf\u9519\u8bef\uff0c\uff0c\uff0c\n    int STATUS_UNKNOWN = 2;\n\n    default void suspend() {\n    }\n\n    default void resume() {\n    }\n\n    @Override\n    default void flush() {\n    }\n\n    default void beforeCommit(boolean readOnly) {\n    }\n\n    default void beforeCompletion() {\n    }\n\n    default void afterCommit() {\n    }\n\n    default void afterCompletion(int status) {\n    }\n}\n<\/code><\/pre>\n<p>\u4e8b\u52a1\u63d0\u4ea4\u524d\u3001\u540e\u6267\u884c\u7684\u94a9\u5b50\u4e3a <code>beforeCommit\/afterCommit<\/code>\uff0c\u4e8b\u52a1\u7ed3\u675f\u7684\u94a9\u5b50\u4e3a <code>beforeCompletion\/afterCompletion<\/code>\uff0c\u4e8b\u52a1\u7ed3\u675f\u7684\u539f\u56e0\u53ef\u80fd\u662f\u6b63\u5e38\u63d0\u4ea4\u3001\u56de\u6eda\uff0c\u4e5f\u53ef\u80fd\u662f\u4e0d\u786e\u5b9a\u7684\uff08\u6bd4\u5982\u53d1\u8d77\u4e86\u63d0\u4ea4\u3001\u4f46\u8bfb\u54cd\u5e94\u5931\u8d25\uff09\u6216\u7cfb\u7edf\u9519\u8bef\u3002<\/p>\n<p>\u6211\u4eec\u77e5\u9053 Spring \u7684\u4e8b\u52a1\u662f\u8ddf\u7ebf\u7a0b\u76f8\u5173\u7684\uff0c\u56e0\u6b64\u53ef\u4ee5\u5229\u7528 <code>ThreadLocal<\/code> \u6765\u5b58\u50a8\u8ddf\u672c\u7ebf\u7a0b\u76f8\u5173\u7684\u4e8b\u52a1\u7684\u94a9\u5b50\uff0c\u8fd9\u6837\u4e5f\u907f\u514d\u4e86\u4e0d\u65ad\u4f20\u9012 <code>Actions<\/code> \u5b9e\u4f8b\u7684\u53c2\u6570\u7684\u95ee\u9898\u3002<\/p>\n<p><code>TransactionSynchronizationManager<\/code> \u63d0\u4f9b\u4e86\u7ba1\u7406\u3001\u6267\u884c\u94a9\u5b50\u7684\u80fd\u529b\uff1a<\/p>\n<pre><code class=\"java\">private static final ThreadLocal&lt;Set&lt;TransactionSynchronization&gt;&gt; synchronizations = new NamedThreadLocal&lt;&gt;(\"Transaction synchronizations\");\n\n\/\/ \u5224\u65ad\u5f53\u524d\u7ebf\u7a0b\u76f8\u5173\u7684\u4e8b\u52a1\u662f\u5426\u5904\u4e8e\u6d3b\u8dc3\u72b6\u6001\npublic static boolean isActualTransactionActive() {\n    return (actualTransactionActive.get() != null);\n}\n\n\/\/ \npublic static boolean isSynchronizationActive() {\n    return (synchronizations.get() != null);\n}\n\npublic static void initSynchronization() throws IllegalStateException {\n    if (isSynchronizationActive()) {\n        throw new IllegalStateException(\"Cannot activate transaction synchronization - already active\");\n    }\n    logger.trace(\"Initializing transaction synchronization\");\n    synchronizations.set(new LinkedHashSet&lt;&gt;());\n}\n\npublic static void registerSynchronization(TransactionSynchronization synchronization)\n        throws IllegalStateException {\n\n    Assert.notNull(synchronization, \"TransactionSynchronization must not be null\");\n    Set&lt;TransactionSynchronization&gt; synchs = synchronizations.get();\n    if (synchs == null) {\n        throw new IllegalStateException(\"Transaction synchronization is not active\");\n    }\n    synchs.add(synchronization);\n}\n<\/code><\/pre>\n<p><code>AbstractPlatformTransactionManager<\/code> \u8d1f\u8d23\u5728\u6070\u5f53\u7684\u56de\u8c03\u70b9\u8c03\u7528 <code>TransactionSynchronizationManager<\/code> \u7ba1\u7406\u7684\u94a9\u5b50\u3002<\/p>\n<pre><code class=\"java\">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            } else if (status.isNewTransaction()) {\n                if (status.isDebug()) {\n                    logger.debug(\"Initiating transaction commit\");\n                }\n                unexpectedRollback = status.isGlobalRollbackOnly();\n                doCommit(status);\n            } else if (isFailEarlyOnGlobalRollbackOnly()) {\n                unexpectedRollback = status.isGlobalRollbackOnly();\n            }\n\n            if (unexpectedRollback) {\n                throw new UnexpectedRollbackException(\n                        \"Transaction silently rolled back because it has been marked as rollback-only\");\n            }\n        } catch (UnexpectedRollbackException ex) {\n            \/\/ can only be caused by doCommit\n            triggerAfterCompletion(status, TransactionSynchronization.STATUS_ROLLED_BACK);\n            throw ex;\n        } catch (TransactionException ex) {\n            \/\/ can only be caused by doCommit\n            if (isRollbackOnCommitFailure()) {\n                doRollbackOnCommitException(status, ex);\n            } else {\n                triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN);\n            }\n            throw ex;\n        } catch (RuntimeException | Error ex) {\n            if (!beforeCompletionInvoked) {\n                triggerBeforeCompletion(status);\n            }\n            doRollbackOnCommitException(status, ex);\n            throw ex;\n        }\n\n        try {\n            triggerAfterCommit(status);\n        } finally {\n            triggerAfterCompletion(status, TransactionSynchronization.STATUS_COMMITTED);\n        }\n    } finally {\n        cleanupAfterCompletion(status);\n    }\n}\n<\/code><\/pre>\n<hr \/>\n<p>\u6b22\u8fce\u5173\u6ce8\u6211\u7684\u5fae\u4fe1\u516c\u4f17\u53f7: <strong>coderbee\u7b14\u8bb0<\/strong>\uff0c\u53ef\u4ee5\u66f4\u53ca\u65f6\u56de\u590d\u4f60\u7684\u8ba8\u8bba\u3002<br \/>\n<img loading=\"lazy\" decoding=\"async\" width=\"258\" height=\"258\" src=\"https:\/\/coderbee.net\/wp-content\/uploads\/2019\/01\/coderbee-note.jpg\" class=\"alignnone size-full wp-image-1707\" \/><\/p>\n","protected":false},"excerpt":{"rendered":"<p>1. \u5e94\u7528\u573a\u666f\u8bf4\u660e \u6709\u591a\u4e2a\u4e8b\u52a1\u53d1\u8d77\u7684\u70b9 E0\u3001E1\uff0c\u90fd\u8c03\u7528\u5230\u9700\u8981\u5728\u4e8b\u52a1\u91cc\u6267\u884c\u7684\u65b9 &hellip; <a href=\"https:\/\/coderbee.net\/index.php\/framework\/20190910\/1925\">\u7ee7\u7eed\u9605\u8bfb <span class=\"meta-nav\">&rarr;<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[255],"tags":[172,208],"_links":{"self":[{"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/posts\/1925"}],"collection":[{"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/comments?post=1925"}],"version-history":[{"count":2,"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/posts\/1925\/revisions"}],"predecessor-version":[{"id":1927,"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/posts\/1925\/revisions\/1927"}],"wp:attachment":[{"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/media?parent=1925"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/categories?post=1925"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/coderbee.net\/index.php\/wp-json\/wp\/v2\/tags?post=1925"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}