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

网友投稿 275 2022-10-12


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

一、什么是Memcached?

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

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

二、安装Memcached服务端

我是在Win下做的实验。

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

memcached.exe -d install 安装memcached服务

然后通过Memcached start memcached就启动了。

常用命令:

-p 监听的端口

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

-d start 启动memcached服务

-d restart 重起memcached服务

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

-d install 安装memcached服务

-d uninstall 卸载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

public void show(){

MemCachedClient client=new MemCachedClient();

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

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

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

/**

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

*/

Integer[] weight={3};

//建立通信的连接池

SockIOPool pool=SockIOPool.getInstance();

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

pool.setServers(addr);

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

pool.setWeights(weight);

//设置初始连接数

pool.setInitConn(5);

//设置最小连接数

pool.setMinConn(5);

//设置最大连接数

http:// pool.setMaxConn(200);

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

pool.setMaxIdle(1000*30*30);

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

pool.setMaintSleep(30);

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

pool.setNagle(false);

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

pool.setSocketTO(30);

//设置连接等待超时值

pool.setSocketConnectTO(0);

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

pool.initialize();

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

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

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

client.set("value1","OK2",new Date(2000));

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

System.out.println(value);

System.out.println(value2);

}

2、spring整合memcached

classpath:property/memcached.properties

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

${memcached.server}

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

${memcached.server}

${memcached.server}

properties配置文件:

#服务器地址

memcached.server=127.0.0.1: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"})

public class SpringTest {

@Test

public void test1(){

MemCachedClient memCachedClient=new MemCachedClient();

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

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

System.out.println(value);

}

}

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

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

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

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

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

Memcached结合java基本操作

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

MemcachedClient mClient = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));

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

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

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

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

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

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

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

//替换replace

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

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

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

Future f3 = mClient.append("ruo","666");

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

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

Future f4 = mClient.prepend("ruo", "555");

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

//清空数据库

mClient.flush();

//关闭连接

mClient.shutdown();

运行结果

2018-10-30 11:23:07.350 INFO net.spy.memcached.MemcachedConnection: Connection state changed for sun.nio.ch.SelectionKeyImpl@38a22ea7

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

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

查看替换ruo的存储状态:true,替换后key:ruo的值是999

查看替换ruo的存储状态:true,替换后key:ruo的值是999666

查看替换ruo的存储状态:true,替换后key:ruo的值是555999666

2018-10-30 11:23:07.368 INFO net.spy.memcached.MemcachedConnection: Shut down memcached client


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:什么是可靠数据传输服务?什么是可靠数据传输协议?(什么协议提供可靠的数据传输服务)
下一篇:网络协议TCP和UDP的基本原理(udp协议和tcp协议作用)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~