MemCache对象缓存应用
参考：http://my.oschina.net/u/273598/blog/100733?fromerr=QG2sQjeH主要是参考别人的内容，把需要用到的资源给整合以下，方便自己或需要的同学使用....
一、需要引入jar包（附件中有）：
commons-pool-1.6.jar,
java_memcached-release_2.6.6.jar,
slf4j-api-1.7.5.jar,
slf4j-simple-1.7.13.jar
Memcached-Java-Client官网jar包的下载地址：
https://github.com/gwhalin/Memcached-Java-Client/downloads
当然也可以maven pom.xml配置引入，看个人项目需求了
java_memcached-release_2.6.6.jar，这个jar包在maven中央库中未收录，所以如果使用的话需要先安装到maven库中，执行命令 mvn install:install-file -Dfile=D:\java_memcached-release_2.6.6.jar -DgroupId=com.danga -DartifactId=memcached -Dversion=2.6.6 -Dpackaging=jar -DgeneratePom=true 。这个时候应该在本地maven库中有看到相应的jar包，在项目中就可以直接使用了
<dependency>
<groupId>com.danga</groupId>
<artifactId>memcached</artifactId>
<version>2.6.6</version>
</dependency>
如果直接把jar包放到项目中也可以，以下配置
<dependency>
<groupId>com.danga</groupId>
<artifactId>memcached</artifactId>
<version>2.6.6</version>
<scope>system</scope>
<systemPath>${project.basedir}/src/main/webapp/WEB-INF/lib/java_memcached-release_2.6.6.jar</systemPath>
</dependency>
其他jar包maven库中有收录就不用这么麻烦了，直接配置
<dependency>
<groupId>commons-pool</groupId>
<artifactId>commons-pool</artifactId>
<version>1.6</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.13</version>
</dependency>
关于这个写法，可以到maven库去查询：http://search.maven.org/
二、以下是例子，需要先启动memcached.exe（附件中有）
查看是否启动成功telnet 127.0.0.1 11211（根据自己的服务器来）
stats items 列出所有key
stats cachedump itemid 0 根据itemid列出对应key，第二个参数是长度，0表示所有
get id 通过key获取缓存内容
package org.andy.shop.service;
import java.util.Date;
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
public class MemCachedManager {
// 创建全局的唯一实例
protected static MemCachedClient mcc = new MemCachedClient();
protected static MemCachedManager memCached = new MemCachedManager();
// 设置与缓存服务器的连接池
static {
// 服务器列表和其权重
String[] servers = { "127.0.0.1:11211" };
Integer[] weights = { 3 };
// 获取socke连接池的实例对象
SockIOPool pool = 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();
}
/**
* 保护型构造方法，不允许实例化！
*
*/
protected MemCachedManager()
{
}
/**
* 获取唯一实例.
* @return
*/
public static MemCachedManager getInstance()
{
return memCached;
}
/**
* 添加一个指定的值到缓存中.
* @param key
* @param value
* @return
*/
public boolean add(String key, Object value)
{
return mcc.add(key, value);
}
public boolean add(String key, Object value, Date expiry)
{
return mcc.add(key, value, expiry);
}
public boolean replace(String key, Object value)
{
return mcc.replace(key, value);
}
public boolean replace(String key, Object value, Date expiry)
{
return mcc.replace(key, value, expiry);
}
/**
* 根据指定的关键字获取对象.
* @param key
* @return
*/
public Object get(String key)
{
return mcc.get(key);
}
public static void main(String[] args)
{
MemCachedManager cache = MemCachedManager.getInstance();
long startDate=System.currentTimeMillis();
for (int i = 0; i < 3; i++) {
cache.add("test"+i , "中国");
}
long endDate=System.currentTimeMillis();
long nowDate=(endDate-startDate)/1000;
System.out.println(nowDate);
System.out.print( " get value : " + cache.get( "test0" ));
}
}
页:
[1]