后浪云Memcached教程：Java 连接 Memcached 服务
Java 连接 Memcached 服务
使用 Java 程序连接 Memcached，需要在你的 classpath 中添加 Memcached jar 包。
本站 jar 包下载地址：spymemcached-2.10.3.jar。
Google Code jar 包下载地址：spymemcached-2.10.3.jar（需要科学上网）。
以下程序假定 Memcached 服务的主机为 127.0.0.1，端口为 11211。
连接实例
Java 连接 Memcached
MemcachedJava.java 文件：
import
net
.
spy
.
memcached
.
MemcachedClient
;
import
java
.
net
.*;
public
class
MemcachedJava
{
public
static
void
main
(
String
[
]
args
)
{
try
{
//
本地连接 Memcached 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
该程序中我们使用 InetSocketAddress 连接 IP 为 127.0.0.1 端口 为 11211 的 memcached 服务。
执行以上代码，如果连接成功会输出以下信息：
Connection to server successful.
set 操作实例
以下使用 java.util.concurrent.Future 来存储数据
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
存储数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Free Education
"
)
;
//
查看存储状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
输出值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
执行程序，输出结果为：
Connection to server successful. set status:true runoob value in cache - Free Education
add 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Free Education
"
)
;
//
打印状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
输出
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
添加
fo
=
mcc
.
add
(
"
runoob
"
,
900
,
"
memcached
"
)
;
//
打印状态
System
.
out
.
println
(
"
add status:
"
+
fo
.
get
(
)
)
;
//
添加新key
fo
=
mcc
.
add
(
"
runoob
"
,
900
,
"
All Free Compilers
"
)
;
//
打印状态
System
.
out
.
println
(
"
add status:
"
+
fo
.
get
(
)
)
;
//
输出
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
replace 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加第一个 key=》value 对
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Free Education
"
)
;
//
输出执行 add 方法后的状态
System
.
out
.
println
(
"
add status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
添加新的 key
fo
=
mcc
.
replace
(
"
runoob
"
,
900
,
"
Largest Tutorials' Library
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
replace status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
append 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Free Education
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
对存在的key进行数据添加操作
fo
=
mcc
.
append
(
"
runoob
"
,
900
,
"
for All
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
append status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
; ]
}
}
prepend 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Education for All
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
对存在的key进行数据添加操作
fo
=
mcc
.
prepend
(
"
runoob
"
,
900
,
"
Free
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
prepend status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
CAS 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Free Education
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
使用 get 方法获取数据
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方法来更新数据
CASResponse
casresp
=
mcc
.
cas
(
"
runoob
"
,
casValue
.
getCas
(
)
,
900
,
"
Largest Tutorials-Library
"
)
;
//
输出 CAS 响应信息
System
.
out
.
println
(
"
CAS Response -
"
+
casresp
)
;
//
输出值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
get 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Free Education
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
使用 get 方法获取数据
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
gets 操作实例、CAS
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
Free Education
"
)
;
//
输出执行 set 方法后的状态
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
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
delete 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数据
Future
fo
=
mcc
.
set
(
"
runoob
"
,
900
,
"
World's largest online tutorials library
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
对存在的key进行数据添加操作
fo
=
mcc
.
delete
(
"
runoob
"
)
;
//
输出执行 delete 方法后的状态
System
.
out
.
println
(
"
delete status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
System
.
out
.
println
(
"
runoob value in cache -
"
+
mcc
.
get
(
"
runoob
"
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}
Incr/Decr 操作实例
MemcachedJava.java 文件：
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 服务
MemcachedClient
mcc
=
new
MemcachedClient
(
new
InetSocketAddress
(
"
127.0.0.1
"
,
11211
)
)
;
System
.
out
.
println
(
"
Connection to server successful.
"
)
;
//
添加数字值
Future
fo
=
mcc
.
set
(
"
number
"
,
900
,
"
1000
"
)
;
//
输出执行 set 方法后的状态
System
.
out
.
println
(
"
set status:
"
+
fo
.
get
(
)
)
;
//
获取键对应的值
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
)
)
;
//
关闭连接
mcc
.
shutdown
(
)
;
}
catch
(
Exception
ex
)
{
System
.
out
.
println
(
ex
.
getMessage
(
)
)
;
}
}
}