java中Memcached的使用实例(包括与Spring整合)

@test

     public   void show(){

         memcachedclient client= new memcachedclient();

         //使用的服务器，由于是在本地测试，只有一个服务器地址。默认端口是11211

         //格式为 服务器ip:端口号

         string [] addr={ "127.0.0.1:11211" };

         /**

          * 设置权重，与设定的服务器一一对应

          */

         integer[] weight={ 3 };

         //建立通信的连接池

         sockiopool pool=sockiopool.getinstance();

         //设置连接池可用cache服务器列表，服务器构成形式：ip地址+端口号

         pool.setservers(addr);

         //设置连接池可用cache服务器的权重，和server数组的位置一一对应

         pool.setweights(weight);

         //设置初始连接数

         pool.setinitconn( 5 );

         //设置最小连接数

         pool.setminconn( 5 );

         //设置最大连接数

         pool.setmaxconn( 200 );

         //设置可用连接的最长等待时间

         pool.setmaxidle( 1000 * 30 * 30 );

         //设置连接池维护线程的睡眠时间，设置为0，维护线程不启动

         pool.setmaintsleep( 30 );

         //设置nagle算法，设置为false，因为通讯数据量比较大要求相应及时

         pool.setnagle( false );

         //设置socket读取等待超时时间

         pool.setsocketto( 30 );

         //设置连接等待超时值

         pool.setsocketconnectto( 0 );

         //设置完参数后，启动pool

         pool.initialize();

         client.set( "value" , "ok" );

         string value= (string) client.get( "value" );

          //设置定时时间2s后消失

         client.set( "value1" , "ok2" , new date( 2000 ));

         string value2= (string) client.get( "value1" );

         system.out.println(value);

         system.out.println(value2);

     }

<bean class = "org.springframework.beans.factory.config.propertyplaceholderconfigurer" >

         <property name= "locations" >

             <list>

                 <value>classpath:property/memcached.properties</value>

             </list>

         </property>

     </bean>

     <!--spring整合memched-->

     <bean id= "memcachedpool" class = "com.danga.memcached.sockiopool" factory-method= "getinstance"

           init-method= "initialize"    destroy-method= "shutdown" >

         <property name= "servers" >

             <list>

                 <value>${memcached.server}</value>

             </list>

         </property>

         <property name= "maxconn" value= "${memcached.maxconn}" ></property>

         <property name= "maintsleep" value= "${memcached.manisleep}" ></property>

         <property name= "nagle" value= "${memcached.nagle}" ></property>

         <property name= "socketto" value= "${memcached.socketto}" ></property>

     </bean>

#服务器地址

memcached.server= 127.0 . 0.1 : 11211

#初始连接数目

memcached.initconn= 20

#每个服务器建立最大连接数

memcached.maxconn= 50

#自查线程周期工作，其每次休眠时间

memcached.manisleep= 3000

#是否使用nagle算法（socket参数，如果是 true ，写数据不缓冲，直接发送）

memcached.nagle= false

#socket阻塞读取数据的超时时间

memcached.socketto= 3000

@runwith (springjunit4classrunner. class ) //表示整合junit进行测试

@contextconfiguration (locations ={ "classpath:applicationcontext.xml" })

public class springtest {

     @test

     public void test1(){

         memcachedclient memcachedclient= new memcachedclient();

         memcachedclient.set( "username" , "luck" );

         string value= (string) memcachedclient.get( "username" );

         system.out.println(value);

     }

}

//创建memcachedclient    连接memcached服务器端

         memcachedclient mclient = new memcachedclient( new inetsocketaddress( "127.0.0.1" , 11211 ));

         system.out.println( "连接memcached成功.........." );

         //存储数据,key-ruo,value-888,时间是1000秒

         future future = mclient.set( "ruo" , 1000 , "888" );

         system.out.println( "查看ruo的存储状态：" +future.get()+ ",存储的值：" +mclient.get( "ruo" ));

         //添加数据,如果key已经存储，则不会更新之前的value，返回not_stored

         future f1 = mclient.add( "ruo" , 1000 , "999" );

         system.out.println( "查看添加ruo的存储状态：" +f1.get()+ ",添加后key：ruo的值是" +mclient.get( "ruo" ));

         //替换replace

         future f2 = mclient.replace( "ruo" , 1000 , "999" );

         system.out.println( "查看替换ruo的存储状态：" +f2.get()+ ",替换后key：ruo的值是" +mclient.get( "ruo" ));

         //追加数据append，用来向已存在的key，追加数据

         future f3 = mclient.append( "ruo" , "666" );

         system.out.println( "查看替换ruo的存储状态：" +f3.get()+ ",替换后key：ruo的值是" +mclient.get( "ruo" ));

         //prepend，用来向已存在的key对应的value前，追加数据

         future f4 = mclient.prepend( "ruo" , "555" );

         system.out.println( "查看替换ruo的存储状态：" +f4.get()+ ",替换后key：ruo的值是" +mclient.get( "ruo" ));

         //清空数据库

         mclient.flush();

         //关闭连接

         mclient.shutdown();