Seata Server 1.5.2 源碼學習 _生活百科

Seata 包括 Server端和Client端。Seata中有三種角色：TC、TM、RM，其中，Server端就是TC，TM和RM屬Client端。Client端的源碼學習上一篇已講過，詳見《Seata 1.5.2源碼學習》，今天來學習Server端的源碼。
源碼下載地址：https://github.com/seata/seata
啟動類 ServerApplication 沒什么好說的，重點是ServerRunner

文章插圖
ServerRunner 是一個 CommandLineRunner 實例，因此在Spring Boot啟動完成后會回調(diào)其run()方法。而在ServerRunner的run()方法中調(diào)用了Server.start()方法。

文章插圖
在Server#start()方法中，初始化了包括id生成器在內(nèi)的很多組件，我們先不管這些，重點關注以下幾行代碼：
NettyRemotingServer nettyRemotingServer = new NettyRemotingServer(workingThreads);DefaultCoordinator coordinator = DefaultCoordinator.getInstance(nettyRemotingServer);coordinator.init();nettyRemotingServer.setHandler(coordinator);DefaultCoordinator是一個單例Bean，在整個應用中只有一個DefaultCoordinator實例

文章插圖

文章插圖
DefaultCoordinator 實現(xiàn)了 TransactionMessageHandler
NettyRemotingServer#setHandler()設置的正是TransactionMessageHandler

文章插圖
DefaultCoordinator#onRequest()

文章插圖
重點是這三行：
AbstractTransactionRequestToTC transactionRequest = (AbstractTransactionRequestToTC) request;transactionRequest.setTCInboundHandler(this);transactionRequest.handle(context);DefaultCoordinator實現(xiàn)了TCInboundHandler接口，所以它不僅是一個TransactionMessageHandler，還是一個TCInboundHandler
這里transactionRequest.setTCInboundHandler(this)，就是指定AbstractTransactionRequestToTC中的TCInboundHandler設置為DefaultCoordinator