java中Memcached的使用实例(包括与Spring整合)

第java中Memcached的使用实例(包括与Spring整合)一、什么是Memcached？

Memcached是开发的分布式内存对象缓存系统，所谓分布式，意味着它不是本地的，而是基于网络连接完成服务。Memcached把一些数据通过key=value数据存储到内存中，这样访问更加方便快捷。

但是随之而来的问题是如果Memcached关闭或者Memcached的服务器关闭那么所保存的内容也就没有了。

二、安装Memcached服务端

我是在Win下做的实验。

首先下载Win下的Memcached，解压到指定目录。

memcached.exe-dinstall安装memcached服务

然后通过Memcachedstartmemcached就启动了。

常用命令：

-p监听的端口

-l连接的IP地址,默认是本机

-dstart启动memcached服务

-drestart重起memcached服务

-dstop|shutdown关闭正在运行的memcached服务

-dinstall安装memcached服务

-duninstall卸载memcached服务

-u以的身份运行(仅在以root运行的时候有效)

-m最大内存使用，单位MB。默认64MB

-M内存耗尽时返回错误，而不是删除项

-c最大同时连接数，默认是1024

-f块大小增长因子，默认是1.25

-n最小分配空间，key+value+flags默认是48

-h显示帮助

三、java下使用Memcached（java客户端程序）

目前常用客户端有三种，我使用的是java_memcached-release_2.6.6，该系列是最早推出也应用最为广泛的客户端。

所需全部的jar：

commons-pool-1.5.6.jar

java_memcached-release_2.6.6.jar

slf4j-api-1.6.1.jar

slf4j-simple-1.6.1.jar

1、基本使用：

@Test

publicvoidshow(){

MemCachedClientclient=newMemCachedClient();

//使用的服务器，由于是在本地测试，只有一个服务器地址。默认端口是11211

//格式为服务器IP:端口号

String[]addr={":11211"};

*设置权重，与设定的服务器一一对应

Integer[]weight={3};

//建立通信的连接池

SockIOPoolpool=SockIOPool.getInstance();

//设置连接池可用cache服务器列表，服务器构成形式：ip地址+端口号

pool.setServers(addr);

//设置连接池可用cache服务器的权重，和server数组的位置一一对应

pool.setWeights(weight);

//设置初始连接数

pool.setInitConn(5);

//设置最小连接数

pool.setMinConn(5);

//设置最大连接数

pool.setMaxConn(200);

//设置可用连接的最长等待时间

pool.setMaxIdle(1000*30*30);

//设置连接池维护线程的睡眠时间，设置为0，维护线程不启动

pool.setMaintSleep(30);

//设置Nagle算法，设置为false，因为通讯数据量比较大要求相应及时

pool.setNagle(false);

//设置socket读取等待超时时间

pool.setSocketTO(30);

//设置连接等待超时值

pool.setSocketConnectTO(0);

//设置完参数后，启动pool

pool.initialize();

client.set("value","Ok");

Stringvalue=(String)client.get("value");

//设置定时时间2s后消失

client.set("value1","OK2",newDate(2000));

Stringvalue2=(String)client.get("value1");

System.out.println(value);

System.out.println(value2);

2、spring整合memcached

bean

propertyname="locations"

list

valueclasspath:property/perties/value

/list

/property

/bean

!--spring整合memched--

beanid="memcachedPool"factory-method="getInstance"

init-method="initialize"destroy-method="shutDown"

propertyname="servers"

list

value${memcached.server}/value

/list

/property

propertyname="maxConn"value="${memcached.maxConn}"/property

propertyname="maintSleep"value="${memcached.maniSleep}"/property

propertyname="nagle"value="${memcached.nagle}"/property

propertyname="socketTO"value="${memcached.socketTO}"/property

/bean

properties配置文件：

#服务器地址

memcached.server=:11211

#初始连接数目

memcached.initConn=20

#每个服务器建立最大连接数

memcached.maxConn=50

#自查线程周期工作，其每次休眠时间

memcached.maniSleep=3000

#是否使用nagle算法（Socket参数，如果是true，写数据不缓冲，直接发送）

memcached.nagle=false

#Socket阻塞读取数据的超时时间

memcached.socketTO=3000

测试：

@RunWith(SpringJUnit4ClassRunner.class)//表示整合JUnit进行测试

@ContextConfiguration(locations={"classpath:applicationContext.xml"})

publicclassSpringTest{

@Test

publicvoidtest1(){

MemCachedClientmemCachedClient=newMemCachedClient();

memCachedClient.set("username","luck");

Stringvalue=(String)memCachedClient.get("username");

System.out.println(value);

四、个人学习中遇到的问题：

我们通过客户端添加与获得数据，那么这个客户端如何与pool联系的，通过别人的博客找到答案。

客户端是通过pool的name关联到某个pool上的。

客户端与Pool都没有指定名称的时候，默认是创建名称为“default”的pool，客户端与它关联。

如果pool设置了名字，那么客户也要指定名称。

Memcached结合java基本操作

//创建MemcachedClient连接memcached服务器端

MemcachedClientmClient=newMemcachedClient(newInetSocketAddress("",11211));

System.out.println("连接memcached成功..........");

//存储数据,key-ruo,value-888,时间是1000秒

Futurefuture=mClient.set("ruo",1000,"888");

System.out.println("查看ruo的存储状态："+future.get()+",存储的值："+mClient.get("ruo"));

//添加数据,如果key已经存储，则不会更新之前的value，返回NOT_STORED

Futuref1=mClient.add("ruo",1000,"999");

System.out.println("查看添加ruo的存储状态："+f1.get()+",添加后key：ruo的值是"+mClient.get("ruo"));

//替换replace

Futuref2=mClient.replace("ruo",1000,"999");

System.out.println("查看替换ruo的存储状态："+f2.get()+",替换后key：ruo的值是"+mClient.get("ruo"));

//追加数据append，用来向已存在的key，追加数据

Futuref3=mClient.append("ruo","666");

System.out.println("查看替换ruo的存储状态："+f3.get()+",替换后key：ruo的值是"+mClient.get("ruo"));

//prepend，用来向已存在的key对应的value前，追加数据

Futuref4=mClient.prepend("ruo","555");

System.out.println("查看替换ruo的存储状态："+f4.get()+",替换后key：ruo的值是"+mClient.get("ruo"));

//清空数据库

mClient.flush();

//关闭连接

mClient.shutdown();

运行结果

2025-10-3011:23:07.350INFOnet.spy.memcached.MemcachedConnection:Connectionstatechangedforsun.nio.ch.SelectionKeyImpl@38a22ea7

查看ruo的存储状态：true,存储的值：888

查看添加ruo的存储状态：false,添加后key：ruo的值是888

查