Seata RMClient(三)

public static void init(String applicationId, String transactionServiceGroup) {
	// 构建:RmNettyRemotingClient(这里和TmNettyRemotingClient都差不多,我就不分析了)
	RmNettyRemotingClient rmNettyRemotingClient = RmNettyRemotingClient.getInstance(applicationId, transactionServiceGroup);
	
	// ***********************************************************
	// 创建了ResourceManager的实现类(DefaultResourceManager)
	// 从ResourceManager接口签名就知道:它主要负责创建分支事务/汇报/锁undolog...
	// ***********************************************************
	rmNettyRemotingClient.setResourceManager(DefaultResourceManager.get());
	
	// ***********************************************************
	// 创建了AbstractRMHandler的实现类(DefaultRMHandler)
	// 从AbstractRMHandler接口签名就知道:它主要负责处理Netty的请求.
	// ***********************************************************
	rmNettyRemotingClient.setTransactionMessageHandler(DefaultRMHandler.get());
	rmNettyRemotingClient.init();

// RmNettyRemotingClient注册的:RemotingProcessor明显要比:TmNettyRemotingClient要多很多.
private void registerProcessor() {
	
	// 分支事务的commit处理
	// 1.registry rm client handle branch commit processor
	RmBranchCommitProcessor rmBranchCommitProcessor = new RmBranchCommitProcessor(getTransactionMessageHandler(), this);
	super.registerProcessor(MessageType.TYPE_BRANCH_COMMIT, rmBranchCommitProcessor, messageExecutor);
	
	// 分支事务的rollback处理
	// 2.registry rm client handle branch commit processor
	RmBranchRollbackProcessor rmBranchRollbackProcessor = new RmBranchRollbackProcessor(getTransactionMessageHandler(), this);
	super.registerProcessor(MessageType.TYPE_BRANCH_ROLLBACK, rmBranchRollbackProcessor, messageExecutor);
	
	// undo log处理
	// 3.registry rm handler undo log processor
	RmUndoLogProcessor rmUndoLogProcessor = new RmUndoLogProcessor(getTransactionMessageHandler());
	super.registerProcessor(MessageType.TYPE_RM_DELETE_UNDOLOG, rmUndoLogProcessor, messageExecutor);
	
	// 向tc进行汇报处理
	// 4.registry TC response processor
	ClientOnResponseProcessor onResponseProcessor =
		new ClientOnResponseProcessor(mergeMsgMap, super.getFutures(), getTransactionMessageHandler());
	
	super.registerProcessor(MessageType.TYPE_SEATA_MERGE_RESULT, onResponseProcessor, null);
	super.registerProcessor(MessageType.TYPE_BRANCH_REGISTER_RESULT, onResponseProcessor, null);
	super.registerProcessor(MessageType.TYPE_BRANCH_STATUS_REPORT_RESULT, onResponseProcessor, null);
	super.registerProcessor(MessageType.TYPE_GLOBAL_LOCK_QUERY_RESULT, onResponseProcessor, null);
	super.registerProcessor(MessageType.TYPE_REG_RM_RESULT, onResponseProcessor, null);
	
	// 心跳
	// 5.registry heartbeat message processor
	ClientHeartbeatProcessor clientHeartbeatProcessor = new ClientHeartbeatProcessor();
	super.registerProcessor(MessageType.TYPE_HEARTBEAT_MSG, clientHeartbeatProcessor, null);
}