| Package | Description |
|---|---|
| com.tencent.tcaplus.message | |
| com.tencent.tcaplus.message.impl |
包含各种请求、响应消息对象
|
| com.tencent.tcaplus.net |
包装Proxy,Dir协议通信功能
|
| com.tencent.tcaplus.net.impl |
| Modifier and Type | Method and Description |
|---|---|
MessageBuffer |
ProtocolSupport.getAuthorizedReq()
获得一个鉴权请求消息二进制包
|
MessageBuffer |
ProtocolSupport.getDirHeartbeatReq(String qosReport)
获得一个心跳通知请求消息二进制包
|
MessageBuffer |
ProtocolSupport.getDirServerListReq() |
MessageBuffer |
ProtocolSupport.getMetadataReq(String tableName) |
MessageBuffer |
ProtocolSupport.getProxyHeartBeatReq(int appId,
int zoneId,
String dirAlarmCodes)
获得一个心跳通知请求消息二进制包
|
MessageBuffer |
ProtocolSupport.getProxyStopRsp(MessageBuffer req)
获得Proxy停止响应消息二进制包
|
MessageBuffer |
Message.getRecvBuffer() |
MessageBuffer |
Message.getSendBuffer() |
MessageBuffer |
ProtocolSupport.getSignUpAppReq() |
MessageBuffer |
ProtocolSupport.getTableAndAccessReq()
获得Proxy路由拉取请求消息二进制包
|
MessageBuffer |
ProtocolSupport.packRequest(Request req) |
| Modifier and Type | Method and Description |
|---|---|
MessageBuffer |
ProtocolSupport.getProxyStopRsp(MessageBuffer req)
获得Proxy停止响应消息二进制包
|
void |
Message.setRecvBuffer(MessageBuffer msgBuf) |
void |
Message.setSendBuffer(MessageBuffer msgBuf) |
ResGetDirServerList |
ProtocolSupport.unpackGetDirServerListRes(MessageBuffer msg) |
ResGetTablesAndAccess |
ProtocolSupport.unpackGetTablesAndAccessRes(MessageBuffer msg) |
Response |
ProtocolSupport.unpackResponse(MessageBuffer msg) |
ResSignUpApp |
ProtocolSupport.unpackSignUpRes(MessageBuffer msg) |
| Modifier and Type | Class and Description |
|---|---|
class |
MessageBufferImpl |
| Modifier and Type | Method and Description |
|---|---|
MessageBuffer |
MessageBufferImpl.get(byte[] byteArray) |
MessageBuffer |
ProtocolSupportImpl.getAuthorizedReq() |
MessageBuffer |
ProtocolSupportImpl.getDirHeartbeatReq(String qosReport) |
MessageBuffer |
ProtocolSupportImpl.getDirServerListReq() |
MessageBuffer |
ProtocolSupportImpl.getMetadataReq(String tableName) |
MessageBuffer |
ProtocolSupportImpl.getProxyHeartBeatReq(int appId,
int zoneId,
String dirAlarmCodes) |
MessageBuffer |
ProtocolSupportImpl.getProxyStopRsp(MessageBuffer req) |
MessageBuffer |
MessageImpl.getRecvBuffer() |
MessageBuffer |
MessageImpl.getSendBuffer() |
MessageBuffer |
ProtocolSupportImpl.getSignUpAppReq() |
MessageBuffer |
ProtocolSupportImpl.getTableAndAccessReq() |
MessageBuffer |
MessageBufferPool.packMsgBuffer(TCapdirCSPkg pkg) |
MessageBuffer |
MessageBufferPool.packMsgBuffer(TCaplusPkg pkg) |
MessageBuffer |
ProtocolSupportImpl.packRequest(Request req) |
MessageBuffer |
MessageBufferImpl.put(byte[] src) |
MessageBuffer |
MessageBufferImpl.put(byte[] src,
int offset,
int length) |
| Modifier and Type | Method and Description |
|---|---|
MessageBuffer |
ProtocolSupportImpl.getProxyStopRsp(MessageBuffer req) |
boolean |
MessageBufferPool.offer(MessageBuffer messageBuffer) |
void |
MessageImpl.setRecvBuffer(MessageBuffer msgBuf) |
void |
MessageImpl.setSendBuffer(MessageBuffer msgBuf) |
ResGetDirServerList |
ProtocolSupportImpl.unpackGetDirServerListRes(MessageBuffer msg) |
ResGetTablesAndAccess |
ProtocolSupportImpl.unpackGetTablesAndAccessRes(MessageBuffer msg) |
Response |
ProtocolSupportImpl.unpackResponse(MessageBuffer msg) |
ResSignUpApp |
ProtocolSupportImpl.unpackSignUpRes(MessageBuffer msg) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
Connector.onRecvMessageBuffer(MessageBuffer msgBuf) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DirConnector.onRecvMessageBuffer(MessageBuffer messageBuffer) |
protected void |
ProxyConnector.onRecvMessageBuffer(MessageBuffer messageBuffer) |
Copyright © 2026. All rights reserved.