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);//设置最大连接数pool.setMaxConn(200);//设置可用连接的最长等待时间pool.setMaxIdle(1000*30*30);//设置连接池维护线程的睡眠时间，设置为0，维护线程不启动pool.setMaintSleep(30);//设置Nagle算法，设置为false，因为通讯数据量比较大要求相应及时pool.setNagle(false);//设置socket读取等待超时时间pool.setSocketTO(30);//设置连接等待超时值pool.setSocketConnectTO(0);//设置完参数后，启动poolpool.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

<bean class='org.springframework.beans.factory.config.PropertyPlaceholderConfigurer'><property name='locations'> <list><value>classpath:property/memcached.properties</value> </list></property> </bean> <!--spring整合memched--> <bean 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配置文件：

#服务器地址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_STOREDFuture f1 = mClient.add('ruo', 1000, '999');System.out.println('查看添加ruo的存储状态：'+f1.get()+',添加后key：ruo的值是'+mClient.get('ruo'));//替换replaceFuture 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的值是5559996662018-10-30 11:23:07.368 INFO net.spy.memcached.MemcachedConnection: Shut down memcached client

以上为个人经验，希望能给大家一个参考，也希望大家多多支持好吧啦网。