一、什么是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、基本使用：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
@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); //设置最大连接数 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"); 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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
<bean class="org.springframework.beans.factory.config.propertyplaceholderconfigurer"> <property name="locations"> <list> <value>classpath:property/memcached.properties</value> </list> </property> </bean> <!--spring整合memched--> <bean id="memcachedpool" class="com.danga.memcached.sockiopool" factory-method="getinstance" init-method="initialize" destroy-method="shutdown"> <property name="servers"> <list> <value>${memcached.server}</value> </list> </property> <property name="maxconn" value="${memcached.maxconn}"></property> <property name="maintsleep" value="${memcached.manisleep}"></property> <property name="nagle" value="${memcached.nagle}"></property> <property name="socketto" value="${memcached.socketto}"></property> </bean> |
properties配置文件：
|
1
2
3
4
5
6
7
8
9
10
11
12
|
#服务器地址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 |
测试：
|
1
2
3
4
5
6
7
8
9
10
11
|
@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基本操作
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
//创建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
以上为个人经验，希望能给大家一个参考，也希望大家多多支持服务器之家。
原文链接：https://www.cnblogs.com/GregZQ/p/8365276.html
