com.hyd.ssdb

类 AbstractClient

java.lang.Object

com.hyd.ssdb.AbstractClient

直接已知子类:

SsdbClient

public abstract class AbstractClient
extends Object

实现 SsdbClient 的一些底层方法

作者:

Yiding

字段概要

字段

限定符和类型	字段和说明
static Charset	DEFAULT_CHARSET

构造器概要

构造器

构造器和说明
AbstractClient(Sharding sharding)

方法概要

限定符和类型	方法和说明
void	close() 关闭 SSDB 客户端
protected List<String>	combineBlocks(List<Response> responseList)
protected List<KeyValue>	combineKeyValues(List<Response> responseList)
Charset	getCharset()
Sharding	getSharding() 获取负载均衡策略（可用于在运行时变更配置）
protected String[]	prependCommand(String token, List<String> parameterList) 将 token 插入到 parameters 的第一位，生成一个新的数组
protected String[]	prependCommand(String token, String[] parameters) 将 token 插入到 parameters 的第一位，生成一个新的数组
protected String[]	prependCommand(String token1, String token2, List<String> parameters)
protected String[]	prependCommand(String token1, String token2, String[] parameters) 将两个 token 插入到 parameters 的第一位，生成一个新的数组
protected String[]	prependCommandIdScore(String token1, String token2, List<IdScore> idScores)
protected String[]	prependCommandKeyValue(String token1, String token2, List<KeyValue> keyValues)
Response	sendRequest(Object... tokens) 发送命令，每个参数为命令的一部分，例如 "set", "key1", "value1"
Response	sendRequest(Request request) 发送一个命令
Response	sendRequest(Server server, String command)
Response	sendRequest(String command) 发送一整条命令，例如 "set key1 value1"
protected List<Response>	sendRequestToAll(Object... tokens)
protected List<Response>	sendRequestToAll(Request request)
Response	sendWriteRequest(Object... tokens) 发送包含写入操作的命令，每个参数为命令的一部分，例如 "set", "key1", "value1"
void	setCharset(Charset charset)
protected List<String[]>	splitKeys(List<String> keys)
protected List<String[]>	splitKeys(String[] keys) 根据 Sharding 对 key 列表进行分组
protected List<List<KeyValue>>	splitKeyValues(List<KeyValue> keyValues)
protected List<String[]>	splitKeyValues(String[] keyValues)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

DEFAULT_CHARSET

public static final Charset DEFAULT_CHARSET

构造器详细资料

AbstractClient

public AbstractClient(Sharding sharding)

方法详细资料

setCharset

public void setCharset(Charset charset)

getCharset

public Charset getCharset()

getSharding

public Sharding getSharding()

获取负载均衡策略（可用于在运行时变更配置）

返回:

负载均衡策略对象

sendRequest

public Response sendRequest(String command)

发送一整条命令，例如 "set key1 value1"

参数:

command - 一整条命令

返回:

执行结果

sendRequest

public Response sendRequest(Server server,
                            String command)

sendWriteRequest

public Response sendWriteRequest(Object... tokens)

发送包含写入操作的命令，每个参数为命令的一部分，例如 "set", "key1", "value1"

参数:

tokens - 命令中的各个部分

返回:

执行结果

sendRequest

public Response sendRequest(Object... tokens)

发送命令，每个参数为命令的一部分，例如 "set", "key1", "value1"

参数:

tokens - 命令中的各个部分

返回:

执行结果

sendRequest

public Response sendRequest(Request request)

发送一个命令

参数:

request - 命令对象

返回:

执行结果

sendRequestToAll

protected List<Response> sendRequestToAll(Object... tokens)

sendRequestToAll

protected List<Response> sendRequestToAll(Request request)

prependCommand

protected String[] prependCommand(String token,
                                  List<String> parameterList)

将 token 插入到 parameters 的第一位，生成一个新的数组

参数:

token - 要插入的内容

parameterList - 参数

返回:

新生成的数组

prependCommand

protected String[] prependCommand(String token,
                                  String[] parameters)

将 token 插入到 parameters 的第一位，生成一个新的数组

参数:

token - 要插入的内容

parameters - 参数

返回:

新生成的数组

prependCommand

protected String[] prependCommand(String token1,
                                  String token2,
                                  String[] parameters)

将两个 token 插入到 parameters 的第一位，生成一个新的数组

参数:

token1 - 要插入的内容

token2 - 要插入的内容

parameters - 参数

返回:

新生成的数组

prependCommand

protected String[] prependCommand(String token1,
                                  String token2,
                                  List<String> parameters)

prependCommandKeyValue

protected String[] prependCommandKeyValue(String token1,
                                          String token2,
                                          List<KeyValue> keyValues)

prependCommandIdScore

protected String[] prependCommandIdScore(String token1,
                                         String token2,
                                         List<IdScore> idScores)

close

public void close()

关闭 SSDB 客户端

splitKeys

protected List<String[]> splitKeys(String[] keys)

根据 Sharding 对 key 列表进行分组

参数:

keys - 要进行分组的 key 列表

返回:

分组结果

splitKeys

protected List<String[]> splitKeys(List<String> keys)

splitKeyValues

protected List<String[]> splitKeyValues(String[] keyValues)

splitKeyValues

protected List<List<KeyValue>> splitKeyValues(List<KeyValue> keyValues)

combineBlocks

protected List<String> combineBlocks(List<Response> responseList)

combineKeyValues

protected List<KeyValue> combineKeyValues(List<Response> responseList)