Memcached 基礎(chǔ)教程
Memcached 安裝
Memcached 連接
Memcached 查找命令
Memcached get 命令
Memcached gets 命令
Memcached delete 命令
Memcached incr 與 decr 命令
Memcached 存儲命令
Memcached set 命令
Memcached add 命令
Memcached replace 命令
Memcached append 命令
Memcached prepend 命令
Memcached CAS 命令
Memcached 統(tǒng)計(jì)命令
Memcached stats 命令
Memcached stats items 命令
Memcached stats slabs 命令
Memcached stats sizes 命令
Memcached flush all 命令
Memcached 實(shí)例
Java 連接 Memcached 服務(wù)
PHP 連接 Memcached 服務(wù)
?
This document uses PHP Chinese website manual Release
characters
Java 連接 Memcached 服務(wù)
使用 Java 程序連接 Memcached，需要在你的 classpath 中添加 Memcached jar 包。
本站 jar 包下載地址：spymemcached-2.10.3.jar（地下有下載地址）
以下程序假定 Memcached 服務(wù)的主機(jī)為 127.0.0.1，端口為 11211。
連接實(shí)例
Java 連接 Memcached
import?net.spy.memcached.MemcachedClient;
import?java.net.*;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
??????try{
?????????//?本地連接?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex){
?????????System.out.println(?ex.getMessage()?);
??????}
???}
}
該程序中我們使用 InetSocketAddress 連接 IP 為 127.0.0.1 端口 為 11211 的 memcached 服務(wù)。
執(zhí)行以上代碼，如果連接成功會輸出以下信息：
Connection?to?server?successful.
set 操作實(shí)例
以下使用 java.util.concurrent.Future 來存儲數(shù)據(jù)
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
??????
?????????//?存儲數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"Free?Education");
??????
?????????//?查看存儲狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
?????????
?????????//?輸出值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex){
?????????System.out.println(?ex.getMessage()?);
??????}
???}
}
執(zhí)行程序，輸出結(jié)果為：
Connection?to?server?successful. set?status:true runoob?value?in?cache?-?Free?Education
add 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"Free?Education");
?????????//?打印狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
?????????//?輸出
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?添加
?????????Future?fo?=?mcc.add("runoob",?900,?"memcached");
?????????//?打印狀態(tài)
?????????System.out.println("add?status:"?+?fo.get());
?????????//?添加新key
?????????fo?=?mcc.add("codingground",?900,?"All?Free?Compilers");
?????????//?打印狀態(tài)
?????????System.out.println("add?status:"?+?fo.get());
?????????
?????????//?輸出
?????????System.out.println("codingground?value?in?cache?-?"?+?mcc.get("codingground"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex){
?????????System.out.println(ex.getMessage());
??????}
???}
}
replace 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try?{
?????????//連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加第一個(gè)?key=》value?對
?????????Future?fo?=?mcc.set("runoob",?900,?"Free?Education");
?????????//?輸出執(zhí)行?add?方法后的狀態(tài)
?????????System.out.println("add?status:"?+?fo.get());
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?添加新的?key
?????????fo?=?mcc.replace("runoob",?900,?"Largest?Tutorials'?Library");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("replace?status:"?+?fo.get());
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex){
?????????System.out.println(?ex.getMessage()?);
??????}
???}
}
append 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"Free?Education");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?對存在的key進(jìn)行數(shù)據(jù)添加操作
?????????Future?fo?=?mcc.append("runoob",?900,?"?for?All");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("append?status:"?+?fo.get());
?????????
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("codingground"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex)
?????????System.out.println(ex.getMessage());
???}
}
prepend 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"Education?for?All");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?對存在的key進(jìn)行數(shù)據(jù)添加操作
?????????Future?fo?=?mcc.prepend("runoob",?900,?"Free?");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("prepend?status:"?+?fo.get());
?????????
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("codingground"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex)
?????????System.out.println(ex.getMessage());
???}
}
CAS 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.CASValue;
import?net.spy.memcached.CASResponse;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"Free?Education");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
????????????
?????????//?使用?get?方法獲取數(shù)據(jù)
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?通過?gets?方法獲取?CAS?token（令牌）
?????????CASValue?casValue?=?mcc.gets("runoob");
?????????//?輸出?CAS?token（令牌）?值
?????????System.out.println("CAS?token?-?"?+?casValue);
?????????//?嘗試使用cas方法來更新數(shù)據(jù)
?????????CASResponse?casresp?=?mcc.cas("runoob",?casValue.getCas(),?900,?"Largest?Tutorials-Library");
?????????
?????????//?輸出?CAS?響應(yīng)信息
?????????System.out.println("CAS?Response?-?"?+?casresp);
?????????//?輸出值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex)
?????????System.out.println(ex.getMessage());
???}
}
get 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"Free?Education");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
?????????//?使用?get?方法獲取數(shù)據(jù)
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex)
?????????System.out.println(ex.getMessage());
???}
}
gets 操作實(shí)例、CAS
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.CASValue;
import?net.spy.memcached.CASResponse;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"Free?Education");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
????????????
?????????//?從緩存中獲取鍵為?runoob?的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?通過?gets?方法獲取?CAS?token（令牌）
?????????CASValue?casValue?=?mcc.gets("runoob");
?????????//?輸出?CAS?token（令牌）?值
?????????System.out.println("CAS?value?in?cache?-?"?+?casValue);
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex)
?????????System.out.println(ex.getMessage());
???}
}
delete 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)據(jù)
?????????Future?fo?=?mcc.set("runoob",?900,?"World's?largest?online?tutorials?library");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("runoob"));
?????????//?對存在的key進(jìn)行數(shù)據(jù)添加操作
?????????Future?fo?=?mcc.delete("runoob");
?????????//?輸出執(zhí)行?delete?方法后的狀態(tài)
?????????System.out.println("delete?status:"?+?fo.get());
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("runoob?value?in?cache?-?"?+?mcc.get("codingground"));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex)
?????????System.out.println(ex.getMessage());
???}
}
Incr/Decr 操作實(shí)例
import?java.net.InetSocketAddress;
import?java.util.concurrent.Future;
import?net.spy.memcached.MemcachedClient;
public?class?MemcachedJava?{
???public?static?void?main(String[]?args)?{
???
??????try{
???
?????????//?連接本地的?Memcached?服務(wù)
?????????MemcachedClient?mcc?=?new?MemcachedClient(new?InetSocketAddress("127.0.0.1",?11211));
?????????System.out.println("Connection?to?server?sucessful.");
?????????//?添加數(shù)字值
?????????Future?fo?=?mcc.set("number",?900,?"1000");
?????????//?輸出執(zhí)行?set?方法后的狀態(tài)
?????????System.out.println("set?status:"?+?fo.get());
?????????//?獲取鍵對應(yīng)的值
?????????System.out.println("value?in?cache?-?"?+?mcc.get("number"));
?????????//?自增并輸出
?????????System.out.println("value?in?cache?after?increment?-?"?+?mcc.incr("number",?111));
?????????//?自減并輸出
?????????System.out.println("value?in?cache?after?decrement?-?"?+?mcc.decr("number",?112));
?????????//?關(guān)閉連接
?????????mcc.shutdown();
?????????
??????}catch(Exception?ex)
?????????System.out.println(ex.getMessage());
???}
}
下載