memcached java client 3.0.2详解
memcached-java-client-3.0.2详解
一：MemCachedClient的创建
创建该客户端对象的构造方法有以下几个：
1,
/**
* Creates a new instance of MemCachedClient.
*/
public MemCachedClient() {
this(null, true, false);
} 2,
/**
* Creates a new instance of MemCachedClient accepting a passed in pool
* name.
*
* @param poolName
* name of SockIOPool
*/
public MemCachedClient(String poolName) {
this(poolName, true, false);
} 3,
/**
* Create memcached client.
*
* @param poolName
* name of SockIOPool
* @param isTCP
* use tcp protocol
* @param binaryProtocal
* use binary protocol.
*/
public MemCachedClient(String poolName, boolean isTcp, boolean binaryProtocal) {
if (binaryProtocal)
client = new BinaryClient(poolName);
else
client = isTcp ? new AscIIClient(poolName) : new AscIIUDPClient(poolName);
} 我们常用的构造方法是1,2两种，从代码可知，我们真正创建的客户端对象大多是AscIIClient.
其客户端的继承关系如下：
http://s3.运维网.com/wyfs02/M01/59/F6/wKioL1TxcwHD5cmHAACK4rBh6r8387.jpg
而在每一个子类里面的构造方法中都会调用内部的void init()方法来初始化状态。
AscIIClient的init方法实现如下：
/**
* Initializes client object to defaults.
*
* This enables compression and sets compression threshhold to 15 KB.
*/
private void init() {
this.sanitizeKeys = true;//key值是否被编码URLEncoder.encode
this.primitiveAsString = false;
this.compressEnable = false;
this.compressThreshold = COMPRESS_THRESH;
this.defaultEncoding = "UTF-8";
this.poolName = (this.poolName == null) ? "default" : this.poolName;
// get a pool instance to work with for the life of this instance
this.pool = SchoonerSockIOPool.getInstance(poolName);
}
AscIIUDPClient的init方法实现如下：
/**
* Initializes client object to defaults.
*
* This enables compression and sets compression threshhold to 15 KB.
*/
private void init() {
this.sanitizeKeys = true;
this.primitiveAsString = false;
this.compressEnable = true;
this.compressThreshold = COMPRESS_THRESH;
this.defaultEncoding = "UTF-8";
this.poolName = (this.poolName == null) ? "default" : this.poolName;
// get a pool instance to work with for the life of this instance
this.pool = SchoonerSockIOPool.getInstance(poolName);
}
BinaryClient的init方法实现如下：
/**
* Initializes client object to defaults.
*
* This enables compression and sets compression threshhold to 15 KB.
*/
private void init() {
this.poolName = (this.poolName == null) ? "default" : this.poolName;
// get a pool instance to work with for the life of this instance
this.pool = SchoonerSockIOPool.getInstance(poolName);
}
二：常用方法解析（以AscIIClient实现为例）
首先我们来认识一个方法，定义如下：
/**
* Stores data to cache.
*
* If data does not already exist for this key on the server, or if the key
* is being
* deleted, the specified value will not be stored.
* The server will automatically delete the value when the expiration time
* has been reached.
*
* If compression is enabled, and the data is longer than the compression
* threshold
* the data will be stored in compressed form.
*
* As of the current release, all objects stored will use java
* serialization.
*
* @param cmdname
* action to take (set, add, replace, append,prepend, cas)
* @param key
* key to store cache under
* @param value
* object to cache
* @param expiry
* expiration
* @param hashCode
* if not null, then the int hashcode to use
* @return true/false indicating success
*/
private boolean set(String cmdname, String key, Object value, Date expiry, Integer hashCode, Long casUnique,boolean asString)
该方法的作用就是向服务器端发送指令，从而实现各种功能，截取组装指令的代码段：
// construct the command
String cmd = new StringBuffer().append(cmdname).append(" ").append(key).append(" ").append(flags).append(" ").append(expiry.getTime() / 1000).append(" ").toString();
由此可见，要明白客户端这些方法在服务器段起到的效果，需要明白服务器段各个指令所达到的效果，这个后面介绍。
方法举例
public boolean add(String key, Object value) {
return set("add", key, value, null, null, 0L, primitiveAsString);
} 该方法缓存的数据不过期
public boolean add(String key, Object value, Date expiry) {
return set("add", key, value, expiry, null, 0L, primitiveAsString);
} 该方法指定了数据缓存过期时间（过期时间到将会被自动删除）
其他方式类似，例如set, replace, append,prepend, cas
注意：key、value都不能为null.
页:
[1]