Memcached初次体验
最近初学了一下Memcached,网上有很多的前辈文章详细介绍过Memcached 的安装使用啊,我写着个的目的不是介绍Memcached,只是想把自己初次体验的过程记下来,以备那天真的需要了可以来此复习一下。
1.下载Memcached 地址:http://code.google.com/p/memcached/downloads/list 以及libevent地址:http://www.monkey.org/~provos/libevent/
?
2.安装(我用的linux)
? 1)先安装libevent。需要指定一个安装路径,即./configure –prefix=/usr;然后make;然后make install;
?2)再安装memcached,需要指定libevent的安装路径即./configure –with-libevent=/usr;然后make;然后make install;
? 3)测试安装是否成功:ls -al /usr/local/bin/mem*
?4)启动memcahced:/usr/local/bin/memcached -d -m 10 -u root -l 192.168.1.158 -p 12111 -c 256 -P /tmp/memcached.pid
?
3.下载Memcached的java客户端,客户端很多中,各种的差异网上有很多,我试了其中的三种:
? 1.gwhalin-Memcached-Java-Client
???? 下载地址:https://github.com/gwhalin/Memcached-Java-Client
? 2.是有前辈在gwhatlin上改进的一个java客户端
???? 地址:http://code.google.com/p/memcache-client-forjava/
??? 使用这个的时候的在可以在classlpath下用以个xml文件配置客户端信息。
?? memcached.xml:
<?xml version="1.0" encoding="UTF-8"?><memcached> <client name="mclient0" compressEnable="true" defaultEncoding="UTF-8" socketpool="pool0"> <errorHandler>com.alisoft.xplatform.asf.cache.memcached.MemcachedErrorHandler</errorHandler> </client> <socketpool name="pool0" failover="true" initConn="5" minConn="5" maxConn="250" maintSleep="0" nagle="false" socketTO="3000" aliveCheck="true"> <servers>192.168.1.158:12111</servers> </socketpool> </memcached>?
?3.是xmemcached
??? 地址:http://code.google.com/p/xmemcached/downloads/list
?
4.便写测试代码:
package com.strong;import java.io.IOException;import java.util.concurrent.TimeoutException;import net.rubyeye.xmemcached.MemcachedClient;import net.rubyeye.xmemcached.MemcachedClientBuilder;import net.rubyeye.xmemcached.XMemcachedClientBuilder;import net.rubyeye.xmemcached.exception.MemcachedException;import net.rubyeye.xmemcached.utils.AddrUtil;import org.junit.AfterClass;import static org.junit.Assert.*;import org.junit.BeforeClass;import org.junit.Test;import com.alisoft.xplatform.asf.cache.ICacheManager;import com.alisoft.xplatform.asf.cache.IMemcachedCache;import com.alisoft.xplatform.asf.cache.memcached.CacheUtil;import com.alisoft.xplatform.asf.cache.memcached.MemcachedCacheManager;import com.danga.MemCached.MemCachedClient;import com.danga.MemCached.SockIOPool;public class MemcacheTest{ static ICacheManager<IMemcachedCache> manager; static SockIOPool pool ; static MemcachedClient cache; @BeforeClass public static void setUpBeforeClass() throws Exception { manager = CacheUtil.getCacheManager(IMemcachedCache.class, MemcachedCacheManager.class.getName()); manager.setConfigFile("memcached.xml"); manager.setResponseStatInterval(5*1000); manager.start(); pool = SockIOPool.getInstance(); String[] server = { "192.168.1.158:12111" }; pool.setServers(server); 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(); MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil.getAddresses("192.168.1.158:12111")); cache = builder.build(); } /** * @throws java.lang.Exception */ @AfterClass public static void tearDownAfterClass() throws Exception { pool.shutDown(); manager.stop(); cache.shutdown(); } @Test public void testXmemcached(){ try { cache.set("key1", 0, "232323"); assertEquals("232323", cache.get("key1")); } catch (TimeoutException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } catch (MemcachedException e) { e.printStackTrace(); } } @Test public void testQwhatLinMemcached(){ MemCachedClient memCachedClient = new MemCachedClient(); for(int i=0;i<10;i++){ memCachedClient.set("test"+i, i+"testing"); } for(int i=0;i<10;i++){ String result = (String) memCachedClient.get("test"+i); assertEquals(i+"testing", result); } } @Test public void testWenChuMemcached(){ IMemcachedCache cache = manager.getCache("mclient0"); cache.remove("key1"); cache.remove("key2"); cache.remove("key3"); cache.put("key1", "1"); cache.put("key2", "222");//替换在添加 cache.replace("key1", "333"); cache.add("key3", "444");//只做添加 cache.put("key2", "555"); assertEquals("333", cache.get("key1")); assertEquals("555", cache.get("key2")); assertEquals("444", cache.get("key3")); }}
?5.与spring的集成。网上有介绍和spring集成的实例,xmemcache在用户手册中专门介绍了与spring集成。详细的可以看它的官网:http://code.google.com/p/xmemcached/wiki/User_Guide_zh