| Package | Description |
|---|---|
| com.tencent.tcaplus.client |
TCaplus Service API 接口
|
| com.tencent.tcaplus.client.impl |
TCaplus Service API 接口实现
|
| com.tencent.tcaplus.net |
包装Proxy,Dir协议通信功能
|
| com.tencent.tcaplus.net.impl |
| Modifier and Type | Method and Description |
|---|---|
void |
Request.AddElementIndex(int index)
添加LIST记录的元素索引值。该函数只对于TCAPLUS_API_LIST_DELETE_BATCH_REQ有效
|
void |
Request.addFieldName(String fieldName)
增加一个需要查询或更新的value字段名称列表,即部分value字段查询和更新。
可用于get、batchget、partkeyget、listget、listgetall、listreplace、replace、update、tabletraverse操作。
|
Record |
Request.addRecord()
向请求中添加一条记录,设置默认index为-1
|
Record |
Request.addRecord(int index)
向请求中添加一条记录
|
static Client |
ClientFactory.createClient(int appId,
int zoneId,
String signature,
List<String> addresses)
创建Client实例对象
|
static Client |
ClientFactory.createClient(int appId,
int zoneId,
String signature,
List<String> addresses,
int callbackPoolSize)
创建Client实例对象
|
static Client |
ClientFactory.createClient(int appId,
int zoneId,
String signature,
List<String> addresses,
int callbackPoolSize,
int timeout)
创建Client实例对象
|
static void |
ClientFactory.destroyClient(Client client)
销毁Client实例对象,释放资源
|
byte[] |
Record.getKeyBlob(String fieldName) |
byte |
Record.getKeyByte(String fieldName) |
double |
Record.getKeyDouble(String fieldName) |
float |
Record.getKeyFloat(String fieldName) |
int |
Record.getKeyInt(String fieldName) |
long |
Record.getKeyLong(String fieldName) |
short |
Record.getKeyShort(String fieldName) |
String |
Record.getKeyString(String fieldName) |
byte[] |
Record.getValueBlob(String fieldName) |
byte |
Record.getValueByte(String fieldName) |
double |
Record.getValueDouble(String fieldName) |
float |
Record.getValueFloat(String fieldName) |
int |
Record.getValueInt(String fieldName) |
long |
Record.getValueLong(String fieldName) |
short |
Record.getValueShort(String fieldName) |
String |
Record.getValueString(String fieldName) |
Response |
Client.poll(Request req)
同步访问方法
|
void |
Client.post(Request req,
Future future)
异步访问方法
|
void |
Request.setAddableIncreaseFlag(int increaseFlag)
设置空记录自增允许标志。用于Generic表的increase操作。
|
void |
Request.SetCheckDataVersionPolicy(int type)
设置记录版本的检查类型,版本号version通过使用SetVersion()函数设置
|
void |
Request.setCmd(int cmd)
设置请求命令字
|
void |
Request.setExpireTime(int expireTime)
当设置了
TcaplusProtocolCsConstants.TCAPLUS_FLAG_FETCH_ONLY_IF_EXPIRED 标志位时,用于指定记录过期时间,目前仅batchget
操作支持指定记录过期时间。 |
void |
Request.setFieldName(List<String> fieldNames)
批量设置需要查询或更新的Value字段名称列表
|
void |
Request.setFlags(int flag)
设置请求的通用标志位,可以通过"按位或"操作同时设定多个值
|
void |
Record.setKeyBlob(String fieldName,
byte[] value) |
void |
Record.setKeyByte(String fieldName,
byte value) |
void |
Record.setKeyDouble(String fieldName,
double value) |
void |
Record.setKeyFloat(String fieldName,
float value) |
void |
Record.setKeyInt(String fieldName,
int value) |
void |
Record.setKeyLong(String fieldName,
long value) |
void |
Record.setKeyShort(String fieldName,
short value) |
void |
Record.setKeyString(String fieldName,
String value) |
void |
Request.setListShiftFlag(int flag)
设置LIST满时,插入元素时,删除旧元素的模式
|
void |
Request.setMultiResponseFlag(int multiFlag)
设置是否允许一个请求包可以自动响应多个应答包,仅对listgetall、batchget、partkeyget协议有效。
|
void |
Request.setPartkeyGetParam(int offset,
int num)
Deprecated.
|
void |
Request.setResultFlag(int resultFlag)
设置响应标志。主要用于Generic表的insert、increase、replace、update、
delete操作和list表的单个delete、replace操作。
|
void |
Request.setResultFlagForFail(int resultFlag)
设置响应标志。主要是本次请求执行失败后返回给前端的数据
|
void |
Request.setResultFlagForSuccess(int resultFlag)
设置响应标志。主要是本次请求成功执行后返回给前端的数据
|
void |
Request.setResultLimit(int limit,
int offset)
如果此请求会返回多条记录,通过此接口对返回的记录做一些限制,仅对listgetall、partkeyget协议有效
|
void |
Request.setTableName(String tableName)
设置请求表名
|
void |
Request.setUserData(byte[] data)
设置用户附加数据,该数据可以在响应消息中通过getUserData方法获再次获得。
|
void |
Record.setValueBlob(String fieldName,
byte[] value) |
void |
Record.setValueByte(String fieldName,
byte value) |
void |
Record.setValueDouble(String fieldName,
double value) |
void |
Record.setValueFloat(String fieldName,
float value) |
void |
Record.setValueInt(String fieldName,
int value) |
void |
Record.setValueLong(String fieldName,
long value) |
void |
Record.setValueShort(String fieldName,
short value) |
void |
Record.setValueString(String fieldName,
String value) |
void |
Record.setVersion(int version)
设置记录版本号
|
Iterator<Record> |
GenericTableTraverser.start()
以同步方式开始遍历
|
Iterator<List<Record>> |
ListTableTraverser.start()
以同步方式开始遍历
|
void |
Traverser.startAsync(Future future)
执行异步遍历,按response进行回调,发生错误时不再获取数据,请自行处理response中的错误信息
|
| Modifier and Type | Method and Description |
|---|---|
void |
RequestLite.AddElementIndex(int index) |
void |
RequestLite.addFieldName(String fieldName) |
Record |
RequestLite.addRecord() |
Record |
RequestLite.addRecord(int index) |
void |
ResponseLite.disassembly(TCaplusPkg pkg) |
byte[] |
RecordLite.getKeyBlob(String fieldName) |
byte |
RecordLite.getKeyByte(String fieldName) |
double |
RecordLite.getKeyDouble(String fieldName) |
float |
RecordLite.getKeyFloat(String fieldName) |
int |
RecordLite.getKeyInt(String fieldName) |
long |
RecordLite.getKeyLong(String fieldName) |
short |
RecordLite.getKeyShort(String fieldName) |
String |
RecordLite.getKeyString(String fieldName) |
List<Record> |
ResponseLite.getRecordList() |
byte[] |
RecordLite.getValueBlob(String fieldName) |
byte |
RecordLite.getValueByte(String fieldName) |
double |
RecordLite.getValueDouble(String fieldName) |
float |
RecordLite.getValueFloat(String fieldName) |
int |
RecordLite.getValueInt(String fieldName) |
long |
RecordLite.getValueLong(String fieldName) |
short |
RecordLite.getValueShort(String fieldName) |
String |
RecordLite.getValueString(String fieldName) |
void |
ClientImpl.init(int appId,
int zoneId,
String signature,
List<String> addresses,
int callbackPoolSize,
int timeout)
初始化函数
|
Response |
ClientImpl.poll(Request req) |
void |
ClientImpl.post(Request req,
Future future) |
void |
RequestLite.setAddableIncreaseFlag(int increaseFlag) |
void |
RequestLite.SetCheckDataVersionPolicy(int type) |
void |
RequestLite.setCmd(int cmd) |
void |
RequestLite.setExpireTime(int expireTime) |
void |
RequestLite.setFieldName(List<String> fieldNames) |
void |
RequestLite.setFlags(int flag) |
void |
RecordLite.setKeyBlob(String fieldName,
byte[] value) |
void |
RecordLite.setKeyByte(String fieldName,
byte value) |
void |
RecordLite.setKeyDouble(String fieldName,
double value) |
void |
RecordLite.setKeyFloat(String fieldName,
float value) |
void |
RecordLite.setKeyInt(String fieldName,
int value) |
void |
RecordLite.setKeyLong(String fieldName,
long value) |
void |
RecordLite.setKeyShort(String fieldName,
short value) |
void |
RecordLite.setKeyString(String fieldName,
String value) |
void |
RequestLite.setListShiftFlag(int flag) |
void |
RequestLite.setMultiResponseFlag(int multiFlag) |
void |
RequestLite.setPartkeyGetParam(int offset,
int num)
Deprecated.
|
void |
RequestLite.setResultFlag(int resultFlag) |
void |
RequestLite.setResultFlagForFail(int resultFlag) |
void |
RequestLite.setResultFlagForSuccess(int resultFlag) |
void |
RequestLite.setResultLimit(int limit,
int offset) |
void |
RequestLite.setTableName(String tableName) |
void |
RequestLite.setUserData(byte[] data) |
void |
RecordLite.setValueBlob(String fieldName,
byte[] value) |
void |
RecordLite.setValueByte(String fieldName,
byte value) |
void |
RecordLite.setValueDouble(String fieldName,
double value) |
void |
RecordLite.setValueFloat(String fieldName,
float value) |
void |
RecordLite.setValueInt(String fieldName,
int value) |
void |
RecordLite.setValueLong(String fieldName,
long value) |
void |
RecordLite.setValueShort(String fieldName,
short value) |
void |
RecordLite.setValueString(String fieldName,
String value) |
void |
RecordLite.setVersion(int version) |
Iterator<Record> |
GenericTableTraverserImpl.start() |
Iterator<List<Record>> |
ListTableTraverserImpl.start() |
void |
GenericTableTraverserImpl.startAsync(Future future) |
void |
ListTableTraverserImpl.startAsync(Future future) |
| Modifier and Type | Method and Description |
|---|---|
void |
Connector.connect()
异步连接服务端
|
void |
Connector.onRead() |
int |
Router.sendMsg(Message msg) |
| Modifier and Type | Method and Description |
|---|---|
void |
DirRouter.connect(int timeout) |
Copyright © 2026. All rights reserved.