memcache入门实例

最近一直在做一个项目的前期设计工作,考虑到后期系统的扩展和性能问题也找了很多解决方法,有一个就是用到了数据库的缓存工具memcached(当然该工具并不仅仅局限于数据库的缓存)。先简单的介绍下什么是memcached。

Memcached是高性能的,分布式的内存对象缓存系统,用于在动态应用中减少数据库负载,提升访问速度。Memcached由DangaInteractive开发,用于提升LiveJournal.com访问速度的。LJ每秒动态页面访问量几千次,用户700万。Memcached将数据库负载大幅度降低,更好的分配资源,更快速访问。

上网baidu了很多东西,几乎都差不多,而且基于java的说的很少,所有只有在研究了各个其他语言类的应用后再来尝试在java上进行简单的操作应用。先从memcached上进行说明,memcached的最新版是采用c语言进行开发和设计的,据说旧版的是采用perl语言开发的,而且它是一个应用软件来的,是作为缓存服务器的服务器端运行在服务器上的,需要使用特定的语言编写客户端与其进行通信来进行数据的缓存和获取。通常我们是把memcached安装运行在web服务器上,然后通过对需要的数据进行缓存,据我目前所知,所有数据的缓存设置和存取操作,以及数据的更新后替换操作全部需要程序来进行,而不是自动进行的(自动不知道能不能成功,呵呵)。下面从一个实际的例子来应用memcached。

首先到http://danga.com/memcached/下载memcached的windows版本和java客户端jar包,目前最新版本是memcached-1.2.1-win32.zip和java_memcached-release_1.6.zip,分别解压后即可!首先是安装运行memcached服务器,我们将memcached-1.2.1-win32.zip解压后,进入其目录,然后运行如下命令:

c:>memcached.exe-dinstall

c:>memcached.exe-127.0.0.1-m32-dstart

第一行是安装memcached成为服务,这样才能正常运行,否则运行失败!第一行是启动memcached的,作为测试我们就简单的只分配32M内存了,然后监听本机端口和以守护进行运行。执行完毕后,我们就可以在任务管理器中见到memcached.exe这个进程了。好了,我们的服务器已经正常运行了,下面我们就来写java的客户端连接程序。

我们将java_memcached-release_1.6.zip解压后的目录中的java_memcached-release_1.6.jar文件复制到java项目的lib目录下,然后我们来编写代码,比如我提供的一个应用类如下:

Java代码收藏代码

packageutils.cache;

importjava.util.Date;

importcom.danga.MemCached.MemCachedClient;

importcom.danga.MemCached.SockIOPool;

publicclassMemCached{

//创建全局的唯一实例

protectedstaticMemCachedClientmcc=newMemCachedClient();

protectedstaticMemCachedmemCached=newMemCached();

//设置与缓存服务器的连接池

static{

//服务器列表和其权重

String[]servers={"127.0.0.1:11211"};

Integer[]weights={3};

//获取socke连接池的实例对象

SockIOPoolpool=SockIOPool.getInstance();

//设置服务器信息

pool.setServers(servers);

pool.setWeights(weights);

//设置初始连接数、最小和最大连接数以及最大处理时间

pool.setInitConn(5);

pool.setMinConn(5);

pool.setMaxConn(250);

pool.setMaxIdle(1000*60*60*6);

//设置主线程的睡眠时间

pool.setMaintSleep(30);

//设置TCP的参数,连接超时等

pool.setNagle(false);

pool.setSocketTO(3000);

pool.setSocketConnectTO(0);

//初始化连接池

pool.initialize();

//压缩设置,超过指定大小(单位为K)的数据都会被压缩

mcc.setCompressEnable(true);

mcc.setCompressThreshold(64*1024);

}

/**保护型构造方法,不允许实例化!

*@类名:MemCached.java

*@描述:TODO

*@

*/

protectedMemCached()

{

}

/**

*@方法功能说明:获取唯一实例

*@修改者名字:马铁利

*@修改时间:Feb10,20122:11:20PM

*@修改内容:

*@参数:@return

*@return:MemCached

*@throws

*/

publicstaticMemCachedgetInstance()

{

returnmemCached;

}

/**

*@方法功能说明:添加一个指定的值到缓存中.

*@修改者名字:马铁利

*@修改时间:Feb10,20122:07:17PM

*@修改内容:

*@参数:@paramkey

*@参数:@paramvalue

*@参数:@return

*@return:boolean

*@throws

*/

publicbooleanadd(Stringkey,Objectvalue)

{

returnmcc.add(key,value);

}

publicbooleanadd(Stringkey,Objectvalue,Dateexpiry)

{

returnmcc.add(key,value,expiry);

}

/**

*@方法功能说明:替换

*@修改者名字:马铁利

*@修改时间:Feb10,20122:06:51PM

*@修改内容:

*@参数:@paramkey

*@参数:@paramvalue

*@参数:@return

*@return:boolean

*@throws

*/

publicbooleanreplace(Stringkey,Objectvalue)

{

returnmcc.replace(key,value);

}

publicbooleanreplace(Stringkey,Objectvalue,Dateexpiry)

{

returnmcc.replace(key,value,expiry);

}

/**

*@方法功能说明:删除缓存中的值

*@修改者名字:马铁利

*@修改时间:Feb10,20122:09:07PM

*@修改内容:

*@参数:@paramkey

*@参数:@return

*@return:boolean

*@throws

*/

publicbooleandelete(Stringkey){

returnmcc.delete(key);

}

/**

*@方法功能说明:根据指定的关键字获取对象.

*@修改者名字:马铁利

*@修改时间:Feb10,20122:08:48PM

*@修改内容:

*@参数:@paramkey

*@参数:@return

*@return:Object

*@throws

*/

publicObjectget(Stringkey)

{

returnmcc.get(key);

}

}

在下载的jar中包含源码,可以自己关联下,然后读下相关源码。

测试类

Java代码收藏代码

packageutils.test;

importjava.util.ArrayList;

importjava.util.Date;

importjava.util.List;

importutils.cache.MemCached;

importutils.pojo.Student;

publicclassTest{

publicstaticvoidmain(String[]args){

MemCachedmc=MemCached.getInstance();

//测试缓存基本数据

mc.add("hello","马铁利的第一个memcached");

System.out.println(mc.get("hello"));

mc.delete("hello");

mc.add("hello","马铁利的第二个memcached");

System.out.println(mc.get("hello"));

mc.add("h","121212",newDate());//奇怪,为什么加上日期后放不到缓存中去呢?调试一下放进去了,结果注释掉本行的时候,获得不到缓存中的值?

System.out.println(mc.get("h"));

//测试缓存pojo(注:pojo类必须要序列化)

Students=newStudent();

s.setName("matieli");

s.setAge(25);

mc.add("matieli",s);

System.out.println("pojo存储!");

Students1=(Student)mc.get("matieli");

System.out.println("matieli对象的名字:"+s1.getName());

System.out.println("matieli对象的年龄:"+s1.getAge());

//测试缓存List<pojo>

mc.delete("list");//memcache的add方法不像listmap一样,要想修改值,使用replace或delete

Studenttom=newStudent();

tom.setName("Tom");

tom.setAge(56);

Studentjack=newStudent();

jack.setName("jack");

jack.setAge(54);

List<Student>list=newArrayList<Student>();

list.add(jack);

list.add(tom);

mc.add("list",list);

List<Student>list1=(List<Student>)mc.get("list");

for(Studentstu:list1){

System.out.println(stu.getName());

System.out.println(stu.getAge());

System.out.println("-------------");

}

}

}

pojo实体类

Java代码收藏代码

packageutils.pojo;

publicclassStudentimplementsjava.io.Serializable{

privateStringname;

privateintage;

publicStringgetName(){

returnname;

}

publicvoidsetName(Stringname){

this.name=name;

}

publicintgetAge(){

returnage;

}

publicvoidsetAge(intage){

this.age=age;

}

}

以上是我在windows下对memcached的一点小学习和实践,在以后的项目开发过程中将会更深入的学习和应用这一缓存工具,也希望和有兴趣的同行一起讨论学习该工具的使用~~

修改端口:

可以直接修改注册表HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\memcachedServer\下的ImagePath为

"x:\xxx\memcached.exe"-p端口-m内存-drunservice

相关推荐