接口 com.taobao.metamorphosis.server.CommandProcessor
的使用

使用 CommandProcessor 的软件包

com.taobao.metamorphosis.gregor.master
com.taobao.metamorphosis.gregor.slave
com.taobao.metamorphosis.server
com.taobao.metamorphosis.server.assembly
com.taobao.metamorphosis.server.network
com.taobao.metamorphosis.server.transaction

com.taobao.metamorphosis.gregor.master 中 CommandProcessor 的使用

实现 CommandProcessor 的 com.taobao.metamorphosis.gregor.master 中的类

class

SamsaCommandProcessor Master的broker command processor，暂不支持所有事务操作

com.taobao.metamorphosis.gregor.slave 中 CommandProcessor 的使用

实现 CommandProcessor 的 com.taobao.metamorphosis.gregor.slave 中的类

class

GregorCommandProcessor Slave的协议处理器

com.taobao.metamorphosis.server 中 CommandProcessor 的使用

实现 CommandProcessor 的 com.taobao.metamorphosis.server 中的类

class

CommandProcessorFilter Processor过滤器实现，可继承并自定义实现

返回 CommandProcessor 的 com.taobao.metamorphosis.server 中的方法

CommandProcessor

CommandProcessorFilter.getNext()

参数类型为 CommandProcessor 的 com.taobao.metamorphosis.server 中的构造方法

CommandProcessorFilter(CommandProcessor next)

com.taobao.metamorphosis.server.assembly 中 CommandProcessor 的使用

实现 CommandProcessor 的 com.taobao.metamorphosis.server.assembly 中的类

class	BrokerCommandProcessor meta服务端核心处理器
class	TransactionalCommandProcessor 事务命令处理器

返回 CommandProcessor 的 com.taobao.metamorphosis.server.assembly 中的方法

CommandProcessor

MetaMorphosisBroker.getBrokerProcessor()

参数类型为 CommandProcessor 的 com.taobao.metamorphosis.server.assembly 中的方法

void	MetaMorphosisBroker.setBrokerProcessor(CommandProcessor brokerProcessor)

参数类型为 CommandProcessor 的 com.taobao.metamorphosis.server.assembly 中的构造方法

TransactionalCommandProcessor(MetaConfig metaConfig, MessageStoreManager storeManager, IdWorker idWorker, CommandProcessor next, TransactionStore transactionStore, StatsManager stasManager)

com.taobao.metamorphosis.server.network 中 CommandProcessor 的使用

参数类型为 CommandProcessor 的 com.taobao.metamorphosis.server.network 中的构造方法

GetProcessor(CommandProcessor processor, ThreadPoolExecutor executor)

OffsetProcessor(CommandProcessor processor, ThreadPoolExecutor executor)

PutProcessor(CommandProcessor processor, ThreadPoolExecutor executor)

QuitProcessor(CommandProcessor processor)

StatsProcessor(CommandProcessor processor)

TransactionProcessor(CommandProcessor processor, ThreadPoolExecutor executor)

VersionProcessor(CommandProcessor processor)

com.taobao.metamorphosis.server.transaction 中 CommandProcessor 的使用

返回 CommandProcessor 的 com.taobao.metamorphosis.server.transaction 中的方法

CommandProcessor

XATransaction.getBrokerProcessor()

参数类型为 CommandProcessor 的 com.taobao.metamorphosis.server.transaction 中的方法

void	XATransaction.setBrokerProcessor(CommandProcessor brokerProcessor)

参数类型为 CommandProcessor 的 com.taobao.metamorphosis.server.transaction 中的构造方法

XATransaction(CommandProcessor brokerProcessor, TransactionStore transactionStore, XATransactionId xid)