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启动完成后会回调其run()方法。而在ServerRunner的run()方法中调用了Server.start()方法。

文章插图
在Server#start()方法中，初始化了包括id生成器在内的很多组件，我们先不管这些，重点关注以下几行代码：
NettyRemotingServer nettyRemotingServer = new NettyRemotingServer(workingThreads);DefaultCoordinator coordinator = DefaultCoordinator.getInstance(nettyRemotingServer);coordinator.init();nettyRemotingServer.setHandler(coordinator);DefaultCoordinator是一个单例Bean ，在整个应用中只有一个DefaultCoordinator实例

文章插图

文章插图
DefaultCoordinator 实现了 TransactionMessageHandler
NettyRemotingServer#setHandler()设置的正是TransactionMessageHandler

文章插图
DefaultCoordinator#onRequest()

文章插图
重点是这三行：
AbstractTransactionRequestToTC transactionRequest = (AbstractTransactionRequestToTC) request;transactionRequest.setTCInboundHandler(this);transactionRequest.handle(context);DefaultCoordinator实现了TCInboundHandler接口，所以它不仅是一个TransactionMessageHandler，还是一个TCInboundHandler
这里transactionRequest.setTCInboundHandler(this)，就是指定AbstractTransactionRequestToTC中的TCInboundHandler设置为DefaultCoordinator