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