windows下java连接memcached出现NullPointerException

0 0

windows下java连接memcached出现NullPointerException15

windows：XP

memcached版本：memcached-1.2.1-win32
java client版本：java_memcached-release_1.6

public class testMemCached
{
    // 创建全局的唯一实例
    protected static MemCachedClient mcc = new MemCachedClient();
      protected static testMemCached memCached = new testMemCached();
    
    // 设置与缓存服务器的连接池
    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 testMemCached()
    {}

    public static testMemCached getInstance()
    {
        return memCached;
    }
    
    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);
    }
    
    public Object get(String key)
    {
        return mcc.get(key);
    }
    
    public boolean flushAll()
    {
        return mcc.flushAll();
    }
    
    public static void main(String[] args)
    {
        testMemCached cache = testMemCached.getInstance();
        cache.flushAll();
        
        for(int i=0; i<50000;i++){
          cache.add(i+"", "test");
        }

        String s = cache.get("0").toString();
        System.out.println(s);
    }
}

输出：com.danga.MemCached.MemCachedClient Sun Jan 08 14:42:19 CST 2012 - ++++ data successfully stored for key: 49998
com.danga.MemCached.MemCachedClient Sun Jan 08 14:42:19 CST 2012 - Storing with native handler...
com.danga.MemCached.MemCachedClient Sun Jan 08 14:42:19 CST 2012 - ++++ memcache cmd (result code): add 49999 0 0 5
 (STORED)
com.danga.MemCached.MemCachedClient Sun Jan 08 14:42:19 CST 2012 - ++++ data successfully stored for key: 49999
Exception in thread "main" java.lang.NullPointerException
 at utils.cache.testMemCached.main(testMemCached.java:90)

memcached启动语句：memcached.exe -l 127.0.0.1 -m 128 -d start

如果我只写入500条记录再读，是没有问题的，但是超过5000条记录就会出现空指针异常了。

请问是哪里出问题了？

问题补充：<div class="quote_title">renpeng301 写道</div><div class="quote_div"><pre name="code" class="java">

for(int i=0; i<50001;i++){
cache.add(i+"", "test");
}
看看cache中的数量。。
</pre></div> <br />请问在哪里设置cache的数量？

问题补充：<div class="quote_title">renpeng301 写道</div><div class="quote_div"><pre name="code" class="java">
通过cache使用计数器

    使用storeCounter方法初始化一个计数器
    使用incr方法对计数器增量操作
    使用decr对计数器减量操作

然后你试试是不是刚好循环到50000时抛出 NullPointerException

</pre> <br /></div> <br />改了下： <br />        cache.storeCount("count"); <br />        for(int i=0; i<50000;i++){ <br />          cache.add(i+"", "test"); <br />          System.out.println(cache.inrCount("count")); <br />        } <br />count从23106后就是-1了 <br />23106 <br />-1 <br />-1 <br />-1 <br />-1 <br /> <br />但是我把for中的i改成20000也是会出现空指针异常。 <br />应该怎么才可以实现保存50000个记录对的需求呢？

问题补充：<div class="quote_title">renpeng301 写道</div><div class="quote_div"><pre name="code" class="java">
int count=0
for(int i=0; i<50001;i++){
try{
         cache.add(i+"", "test");
count++;
}catch(Exp....){
      System.out.print("error........");
}
       }

</pre></div> <br />这个不会有异常的啊，因为记录已经显示第49999条记录已经写入成功。而且我发现是因为前面的记录被覆盖掉了！ <br />所以需要把memcached支持的记录数加大才对吧？

2012年1月08日 14:55

benson76
15
0 0 0

java_memcached-release_1.6.zip (245.3 KB)
下载次数: 9

memcached-1.2.1-win32.zip (89 KB)
下载次数: 12

4个答案按时间排序按投票排序

0 0

但是我把for中的i改成20000也是会出现空指针异常。
应该怎么才可以实现保存50000个记录对的需求呢？
============================================
是不是有个地方可以设置缓存数的。。

忘记了。。


[color=red]所以需要把memcached支持的记录数加大才对吧？ [/color]
对的

2012年1月08日 16:25

renpeng301
912
0 0 7

添加评论

0 0

 int count=0
for(int i=0; i<50001;i++){    
try{
         cache.add(i+"", "test"); 
  count++;
}catch(Exp....){
      System.out.print("error........");
}   
       }

2012年1月08日 15:40

renpeng301
912
0 0 7

添加评论

0 0

通过cache使用计数器

    使用storeCounter方法初始化一个计数器
    使用incr方法对计数器增量操作
    使用decr对计数器减量操作 

然后你试试 是不是刚好循环到50000时 抛出 NullPointerException

2012年1月08日 15:34

renpeng301
912
0 0 7

添加评论

0 0


 for(int i=0; i<50001;i++){  
          cache.add(i+"", "test");  
        } 
看看cache中的数量。。

2012年1月08日 15:21

renpeng301
912
0 0 7

添加评论

已解决问题

未解决问题

排行榜

查看全部排名>>