|
||||||||||
上一个软件包 下一个软件包 | 框架 无框架 |
接口摘要 | |
---|---|
MetaEncodeCommand | 协议编码接口和常量 |
类摘要 | |
---|---|
AbstractRequestCommand | 请求命令基类 |
AbstractResponseCommand | 应答命令基类 |
BooleanCommand | 应答命令,协议格式如下: result code length opaque\r\n message |
ByteUtils | Utilities for byte process |
DataCommand | 应答命令,协议格式如下: value total-length opaque\r\n data,其中data的结构如下: 4个字节的消息数据长度(可能包括属性) 4个字节的check sum 8个字节的消息id 4个字节的flag 消息数据,如果有属性,则为: 4个字节的属性长度+ 消息属性 + payload 否则为: payload |
GetCommand | 获取消息协议,协议格式如下: get topic group partition offset maxSize opaque\r\n |
HttpStatus | 响应状态码,遵循http语义 |
MetamorphosisWireFormatType | Metamorphosis wire format type |
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 | 退出命令,客户端发送此命令后,服务器将主动关闭连接 |
RemotingUtils | |
StatsCommand | 统计信息查询 格式: stats item opaque\r\n |
SyncCommand | 同步复制,master/slave复制消息的协议,协议格式如下: sync topic partition value-length flag msgId checksum opaque\r\ndata |
TransactionCommand | 事务命令,协议格式如下: transaction transactionKey sessionId type [timeout] [uniqueQualifier] opaque\r\n |
VersionCommand | 查询服务器版本,也用于心跳检测,协议:version opaque\r\n |
|
||||||||||
上一个软件包 下一个软件包 | 框架 无框架 |