技术中心

这里象征着我们的态度和能力

>MemCached java 操作
作者:中国IT实验室    来源:中国IT实验室    发布时间:2012-03-12      浏览次数:6975
分享到:
欢迎进入Java社区论坛,与200万技术人员互动交流 >>进入
    package com.xmail.wm.common.memcache.test;
   
    import java.util.Date;
   
    import com.danga.MemCached.MemCachedClient;
   
    import com.danga.MemCached.SockIOPool;
   
    public class Test {
   
    // 创建全局的唯一实例
   
    protected static MemCachedClient mcc = new MemCachedClient();
   
    protected static Test memCached = new Test();
   
    // 设置与缓存服务器的连接池
   
    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();
   
    // 压缩设置,超过指定大小(单位为K)的数据都会被压缩
   
    mcc.setCompressEnable( true );
   
    mcc.setCompressThreshold( 64 * 1024 );
   
    }
   
    /**
   
    * 保护型构造方法,不允许实例化!
   
    *
   
    */
   
    protected Test()
   
    {
   
    }
   
    /**
   
    * 获取唯一实例。
   
    * @return
   
    */
   
    public static Test 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)
   
    {
   
    Test cache = Test.getInstance();
   
    cache.add("hello", 234);
   
    System.out.print("get value : " + cache.get("hello"));
   
    }
   
    }
   
    spymemcached
   
    import java.net.InetSocketAddress;
   
    import java.util.concurrent.Future;
   
    import net.spy.memcached.MemcachedClient;
   
    public class MClient {
   
    public static void main(String[] args){
   
    try{
   
    /*建立MemcachedClient 实例,并指定memcached服务的IP地址和端口号*/
   
    MemcachedClient mc = new MemcachedClient(new InetSocketAddress("192.168.1.20", 12111));
   
    Future<Boolean> b = null;
   
    /*将key值,过期时间(秒)和要缓存的对象set到memcached中*/
   
    b = mc.set("neea:testDaF:ksIdno", 900, "someObject");
   
    if(b.get()。booleanValue()==true){
   
    mc.shutdown();
   
    }
   
    }
   
    catch(Exception ex){
   
    ex.printStackTrace();
   
    }
   
    }
   
    }
4000-880-989
(24小时热线)
联系客服
微信公众号

官方公众号

小程序

©2008-2022 CORPORATION ALL Rights Reserved. 昆明奥远科技有限公司版权所有 滇ICP备09003328号-1 滇公网安备 53011102000818号 增值电信业务经营许可证号:滇B2-20110045
昆明那家网络公司好,新媒体运营,网站优化,网络推广,网站建设,网页设计,网站设计,网站推广,云南网站公司,昆明新媒体公司,云南网红主播,昆明SEO公司,昆明网站建设,昆明网络推广,昆明网站优化,昆明网站推广,红河网站建设,大理网络公司,曲靖网络公司,丽江网站设计,昭通网络公司,保山大数据服务,智慧高速建设,智慧校园服务,云南IDC服务商,网络安全测评,等保测评,网站关键词排名优化服务,服务客户尽超2000余家,一切尽在奥远科技,服务电话:13888956730