|
||||||||||
上一个 下一个 | 框架 无框架 |
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 |
|
||||||||||
上一个 下一个 | 框架 无框架 |