软件包 com.taobao.metamorphosis.network
的使用

使用 com.taobao.metamorphosis.network 的软件包
com.taobao.metamorphosis.client.extension.producer   
com.taobao.metamorphosis.client.producer   
com.taobao.metamorphosis.gregor.master   
com.taobao.metamorphosis.gregor.slave   
com.taobao.metamorphosis.network   
com.taobao.metamorphosis.server   
com.taobao.metamorphosis.server.assembly   
com.taobao.metamorphosis.server.network   
com.taobao.metamorphosis.server.store   
com.taobao.metamorphosis.server.transaction   
com.taobao.metamorphosis.server.transaction.store   
com.taobao.metamorphosis.utils   
 

com.taobao.metamorphosis.client.extension.producer 使用的 com.taobao.metamorphosis.network 中的类
BooleanCommand
          应答命令,协议格式如下:
result code length opaque\r\n message
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 

com.taobao.metamorphosis.client.producer 使用的 com.taobao.metamorphosis.network 中的类
BooleanCommand
          应答命令,协议格式如下:
result code length opaque\r\n message
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 

com.taobao.metamorphosis.gregor.master 使用的 com.taobao.metamorphosis.network 中的类
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 

com.taobao.metamorphosis.gregor.slave 使用的 com.taobao.metamorphosis.network 中的类
SyncCommand
          同步复制,master/slave复制消息的协议,协议格式如下:
sync topic partition value-length flag msgId checksum opaque\r\ndata
 

com.taobao.metamorphosis.network 使用的 com.taobao.metamorphosis.network 中的类
AbstractRequestCommand
          请求命令基类
AbstractResponseCommand
          应答命令基类
MetaEncodeCommand
          协议编码接口和常量
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 

com.taobao.metamorphosis.server 使用的 com.taobao.metamorphosis.network 中的类
GetCommand
          获取消息协议,协议格式如下: get topic group partition offset maxSize opaque\r\n
OffsetCommand
          查询最近有效的offset 格式: offset topic group partition offset opaque\r\n
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
QuitCommand
          退出命令,客户端发送此命令后,服务器将主动关闭连接
StatsCommand
          统计信息查询 格式:
stats item opaque\r\n
VersionCommand
          查询服务器版本,也用于心跳检测,协议:version opaque\r\n
 

com.taobao.metamorphosis.server.assembly 使用的 com.taobao.metamorphosis.network 中的类
GetCommand
          获取消息协议,协议格式如下: get topic group partition offset maxSize opaque\r\n
OffsetCommand
          查询最近有效的offset 格式: offset topic group partition offset opaque\r\n
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
QuitCommand
          退出命令,客户端发送此命令后,服务器将主动关闭连接
StatsCommand
          统计信息查询 格式:
stats item opaque\r\n
VersionCommand
          查询服务器版本,也用于心跳检测,协议:version opaque\r\n
 

com.taobao.metamorphosis.server.network 使用的 com.taobao.metamorphosis.network 中的类
GetCommand
          获取消息协议,协议格式如下: get topic group partition offset maxSize opaque\r\n
OffsetCommand
          查询最近有效的offset 格式: offset topic group partition offset opaque\r\n
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
QuitCommand
          退出命令,客户端发送此命令后,服务器将主动关闭连接
StatsCommand
          统计信息查询 格式:
stats item opaque\r\n
TransactionCommand
          事务命令,协议格式如下:
transaction transactionKey sessionId type [timeout] [uniqueQualifier] opaque\r\n
 

com.taobao.metamorphosis.server.store 使用的 com.taobao.metamorphosis.network 中的类
GetCommand
          获取消息协议,协议格式如下: get topic group partition offset maxSize opaque\r\n
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 

com.taobao.metamorphosis.server.transaction 使用的 com.taobao.metamorphosis.network 中的类
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 

com.taobao.metamorphosis.server.transaction.store 使用的 com.taobao.metamorphosis.network 中的类
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 

com.taobao.metamorphosis.utils 使用的 com.taobao.metamorphosis.network 中的类
PutCommand
          发送消息命令,协议格式:

put topic partition value-length flag checksum [transactionkey] opaque\r\n data

data的结构如下:

attribute(0个或者1个,固定长度字符串,取决于flag字段) + binary data
 



Copyright © 2010–2013. All rights reserved.