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" ));

    }

 

}