一、什么是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