Getting_Started_zh
簡單介紹
依賴包
簡單例子
設(shè)置權(quán)重
使用二進制協(xié)議
使用Kestrel
動態(tài)增刪節(jié)點
Nio連接池
使用CAS原子更新
簡單介紹
Xmemcached支持memcached所有的二進制協(xié)議（從1.2.0開始）和文本協(xié)議，并且支持對Kestrel(一個scala寫的MQ)的兼容訪問。 更多信息請參考用戶指南
依賴包
Xmemcached 1.x 需要依賴common-logging和yanf4j-0.70http://code.google.com/p/yanf4j/downloads/list)
Xmemcached 1.2.0-stable開始及以后版本需要依賴slf4j(http://www.slf4j.org/)和yanf4j-1.0.1
memcached 1.2.0 and 1.2.1 依賴 yanf4j 1.0.1
memcached 1.2.2 依賴 yanf4j 1.1.0
memcached 1.2.3 and 1.2.4 依賴 yanf4j 1.1.1
Xmemcached 1.2.5 不再依賴yanf4j
如果您使用maven構(gòu)建，只需要添加依賴即可使用xmemcached:
com.googlecode.xmemcachedxmemcached1.2.5
簡單例子
MemcachedClient client=new XMemcachedClient("host",11211);
//同步存儲value到memcached
client.set("key",3600,someObject);
//從memcached獲取key對應(yīng)的value
Object someObject=client.get("key");
//從memcached獲取key對應(yīng)的value,操作超時2秒
someObject=client.get("key",2000);
//刪除value
client.delete("key");
設(shè)置權(quán)重
MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil.getAddresses("localhost:12000 localhost:12001"),new int[]{1,3});
MemcachedClient memcachedClient=builder.build();
上面的例子將"localhost:12000"節(jié)點的權(quán)重設(shè)置為1，而將"localhost:12001"節(jié)點的權(quán)重設(shè)置為3.當然，你也可以通過JMX調(diào)用MBean動態(tài)修改權(quán)重：
public interface XMemcachedClientMBean{
....
/**
* Set a memcached server's weight
*
* @param server
* @param weight
*/
public void setServerWeight(String server, int weight);
}
使用二進制協(xié)議
Xmemcached默認使用成熟的文本協(xié)議，memcached 1.4.0正式支持啟用二進制協(xié)議，如果你想使用二進制協(xié)議，你只要添加一行代碼，設(shè)置BinaryCommandFactory即可：
MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil.getAddresses("localhost:12000 localhost:12001"),new int[]{1,3});
builder.setCommandFactory(new BinaryCommandFactory());//use binary protocol
MemcachedClient memcachedClient=builder.build();
使用Kestrel
Kestrel是twitter開源的一個scala寫的簡單高效MQ，它支持memcached文本協(xié)議，但是并不完全兼容，例如它不支持flag，導(dǎo)致很多利用flag做序列化的客戶端無法正常運作。因此Xmemcached特意提供了KestrelCommandFactory用于支持Kestrel。使用KestrelCommandFactory即可擁有如下好處：
默認關(guān)閉get優(yōu)化，因為kestrel不支持bulk get；
支持kestrel的阻塞獲取和可靠獲取；
允許向kestrel存儲任意java序列化類型。設(shè)置KestrelCommandFactory:
MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil.getAddresses("localhost:12000 localhost:12001"),new int[]{1,3});
builder.setCommandFactory(new KestrelCommandFactory());
MemcachedClient memcachedClient=builder.build();
關(guān)于最后一點需要補充說明，由于kestrel不支持flag，因此xmemcached在存儲的數(shù)據(jù)之前加了4個字節(jié)的flag，如果你的全部應(yīng)用都使用xmemcached，那么沒有問題，如果使用其他clients，會有兼容性的問題，因此Xmemcached還允許關(guān)閉這個功能，通過
client.setPrimitiveAsString(true);
設(shè)置為true后，原生類型都將存儲為字符串，而序列化類型將無法存儲了。
動態(tài)增刪節(jié)點
你可以通過編程或者JMX來動態(tài)增加或者移除memcached節(jié)點：
MemcachedClient client=new XMemcachedClient(AddrUtil.getAddresses("server1:11211 server2:11211"));
//Add two new memcached nodes
client.addServer("server3:11211 server4:11211");
//Remove memcached servers
client.removeServer("server1:11211 server2:11211");
Nio連接池
Xmemcached是基于java nio的client實現(xiàn)，默認對一個memcached節(jié)點只有一個連接，這在通常情況下已經(jīng)有非常優(yōu)異的表現(xiàn)。但是在典型的高并發(fā)環(huán)境下,nio的單連接也會遇到性能瓶頸。因此XMemcached支持設(shè)置nio的連接池，允許建立多個連接到同一個memcached節(jié)點，但是請注意，這些連接之間是不同步的，因此你的應(yīng)用需要自己保證數(shù)據(jù)更新的同步，啟用連接池可以通過下面代碼：
MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil.getAddresses("localhost:12000"));
builder.setConnectionPoolSize(5);
使用CAS原子更新
典型的CAS操作需要先通過gets得到cas值，然后進行cas替換，用起來相當麻煩。XMemcached提供了CASOperation封裝了這兩個操作，提供給用戶統(tǒng)一的使用接口，并且允許設(shè)置最多重試次數(shù)。詳見下面的例子，啟動N個線程原子更新同一個key的value。
class CASThread extends Thread {
static final class IncrmentOperation implements CASOperation
{
/*
*Max repeat times.if repeat times is great than this value,
*xmemcached will throw a TimeoutException.
*/
@Override
public int getMaxTries() {
return Integer.MAX_VALUE;
}
//increase current value
@Override
public Integer getNewValue(long currentCAS, Integer currentValue) {
return currentValue + 1; // 當前值+1
}
}
private XMemcachedClient mc;
private CountDownLatch cd;
public CASThread(XMemcachedClient mc, CountDownLatch cdl) {
super();
this.mc = mc;
this.cd = cdl;
}
public void run() {
try {
//do the cas operation
if (mc.cas("a", 0, new IncrmentOperation()))
this.cd.countDown();
} catch (Exception e) {
e.printStackTrace();
}
}
}
public class CASTest {
public static void main(String[] args) throws Exception {
if (args.length < 2) {
System.err.println("Usage:java CASTest [threadNum] [server]");
System.exit(1);
}
//threads num
int NUM = Integer.parseInt(args[0]);
XMemcachedClient mc = new XMemcachedClient(AddrUtil.getAddresses(args[1]));
//initial value is 0
mc.set("a", 0, 0);
CountDownLatch cdl = new CountDownLatch(NUM);
long start = System.currentTimeMillis();
//start NUM threads to increment the value
for (int i = 0; i < NUM; i++)
new CASThread(mc, cdl).start();
cdl.await();
System.out.println("test cas,timed:"
+ (System.currentTimeMillis() - start));
System.out.println("result=" + mc.get("a"));
mc.shutdown();
}
}