实例讲解分布式缓存软件Memcached的Java客户端使用

package com.danga.MemCached.test;

import com.danga.MemCached.MemCachedClient;

import com.danga.MemCached.SockIOPool;

import org.apache.log4j.*;

public class TestMemcached {

public static void main(String[] args) {

// memcached should be running on port 11211 but NOT on 11212

BasicConfigurator.configure();

//缓存服务器地址，多台服务器则以逗号隔开，11211为memcached使用的端口号

String[] servers = { “localhost:11211″ };

//得到一个链接池对象并进行一些初始化工作

SockIOPool pool = SockIOPool.getInstance();

pool.setServers( servers );

pool.setFailover( true );

pool.setInitConn( 10 );

pool.setMinConn( 5 );

pool.setMaxConn( 250 );

//pool.setMaintSleep( 30 );

pool.setNagle( false );

pool.setSocketTO( 3000 );

pool.setAliveCheck( true );

pool.initialize();

MemCachedClient mcc = new MemCachedClient();

// turn off most memcached client logging:

//Logger.getLogger( MemCachedClient.class.getName() ).setLevel( com.schooner.MemCached.Logger. );

//以下是数据写入和取出操作例子

for ( int i = 0; i <10; i++ ) {

boolean success = mcc.set( “” + i, “Hello!” );

String result = (String)mcc.get( “” + i );

System.out.println( String.format( “set( %d ): %s”, i, success ) );

System.out.println( String.format( “get( %d ): %s”, i, result ) );

}

System.out.println( “\n\t — sleeping –\n” );

try { Thread.sleep( 10000 ); } catch ( Exception ex ) { }

for ( int i = 0; i <10; i++ ) {

boolean success = mcc.set( “” + i, “Hello!” );

String result = (String)mcc.get( “” + i );

System.out.println( String.format( “set( %d ): %s”, i, success ) );

System.out.println( String.format( “get( %d ): %s”, i, result ) );

}

}

}

package com.danga.MemCached.test; 
 
import com.danga.MemCached.*; 
public class TestMemcached { 
 public static void main(String[] args) { 
  /*初始化SockIOPool，管理memcached的连接池*/ 
  String[] servers = { "192.168.105.217:11211" }; 
  SockIOPool pool = SockIOPool.getInstance(); 
  pool.setServers(servers); 
  pool.setFailover(true); 
  pool.setInitConn(10); 
  pool.setMinConn(5); 
  pool.setMaxConn(250); 
  pool.setMaintSleep(30); 
  pool.setNagle(false); 
  pool.setSocketTO(3000); 
  pool.setAliveCheck(true); 
  pool.initialize(); 
  /*建立MemcachedClient实例*/ 
  MemCachedClient memCachedClient = new MemCachedClient(); 
  for (int i = 0; i <10; i++) { 
   /*将对象加入到memcached缓存*/ 
   boolean success = memCachedClient.set("" + i, "Hello!"); 
   /*从memcached缓存中按key值取对象*/ 
   String result = (String) memCachedClient.get("" + i); 
   System.out.println(String.format("set( %d ): %s", i, success)); 
   System.out.println(String.format("get( %d ): %s", i, result)); 
  } 
 } 
}