memcached集群开发

memcached是高性能的分布式内存缓存服务器。一般的使用目的
是，通过缓存数据库查询结果，减少数据库访问次数，以提高动态Web应用的速度、提高可扩展
性。
1 确保libevent 和memcacahed 安装成功，并且启动
2 配置文件memcached.properties---memcached Server 配置
memcached.servers=10.100.1.117:11211,10.100.120.185:11211
memcached.weights=3,2
memcached.initConn=100
memcached.minConn=20
memcached.maxConn=1024
memcached.socketTimeout=3000
memcached.maintSleep=5000
#memcached yes/no
memcached.isEnable=yes
memcached.commonCacheTime=600000000
#categories cached time: (30 daies)
memcached.categoriesCacheTime=2592000000
#downTicket cache time: (one day)
memcached.downTicketCacheTime=86400000
memcached 分布式开发就是在此配置文件中配置多了servers 和 weights。当然你也可以不用配置配置文件直接在程序中写


之后java代码解析我把我项目中用的拷个大家供大家参考

public class MCLoader {

	private static MCLoader loader = new MCLoader();
	private Properties p = new Properties();

	private MCLoader() {
		try {
			InputStream in = this.getClass().getClassLoader().getResourceAsStream("memcached.properties");
			p.load(in);
		} catch (IOException e1) {
			e1.printStackTrace();
		}
	}

	public final static MCLoader getInstance() {
		return loader;
	}

	public Object get(String key) {
		return p.get(key);
	}
}


public class MemCacheMgr {
	private static MemCacheMgr _instance = new MemCacheMgr();
	private MemCachedClient mc = null;

	public static MemCacheMgr getInstance() {
		return _instance;
	}

	public Date getTime(String key) {
		Calendar c = Calendar.getInstance();
		long cacheTime = System.currentTimeMillis()
				+ Long.parseLong((String) MCLoader.getInstance().get(key));
		Date ct = null;
		c.setTimeInMillis(cacheTime);
		ct = c.getTime();
		return ct;
	}

	public Date getTime() {
		Calendar c = Calendar.getInstance();
		long cacheTime = System.currentTimeMillis()
				+ Long.parseLong((String) MCLoader.getInstance().get(
						"memcached.cacheTime"));
		Date ct = null;
		c.setTimeInMillis(cacheTime);
		ct = c.getTime();
		return ct;
	}

	private MemCacheMgr() {
		String[] serverArray = null;
		Integer[] weights = null;
		String[] weightsArray = null;

		String serverList = (String) MCLoader.getInstance().get(
				"memcached.servers");
		String weightList = (String) MCLoader.getInstance().get(
				"memcached.weights");
		int initConn = Integer.parseInt((String) MCLoader.getInstance().get(
				"memcached.initConn"));
		int minConn = Integer.parseInt((String) MCLoader.getInstance().get(
				"memcached.minConn"));
		int maxConn = Integer.parseInt((String) MCLoader.getInstance().get(
				"memcached.maxConn"));
		int socketTimeOut = Integer.parseInt((String) MCLoader.getInstance().get(
				"memcached.socketTimeout"));
		int maintSleep = Integer.parseInt((String) MCLoader.getInstance().get(
				"memcached.maintSleep"));

		if (serverList.indexOf(",") > 0) {
			serverArray = serverList.split(",");
			System.out.println(serverArray);
		} else {
			serverArray = new String[] { serverList };
			System.out.println(serverArray);
		}
		if (weightList.indexOf(",") > 0) {
			weightsArray = weightList.split(",");
			Integer[] weightsI = new Integer[weightsArray.length];
			for (int i = 0; i < weightsArray.length; i++) {
				weightsI[i] = Integer.parseInt(weightsArray[i]);
			}
			weights = weightsI;
		} else {
			weights = new Integer[] { Integer.parseInt(weightList) };
		}
		// initialize the pool for memcache servers
		SockIOPool pool = SockIOPool.getInstance();
		pool.setServers(serverArray);
		pool.setWeights(weights);
		pool.setInitConn(initConn);
		pool.setMinConn(minConn);
		pool.setMaxConn(maxConn);
		pool.setMaintSleep(maintSleep);
		pool.setNagle(false);
		pool.setSocketTO(socketTimeOut);
		pool.setHashingAlg(SockIOPool.CONSISTENT_HASH);
		pool.initialize();
		mc = new MemCachedClient();
	}

	public MemCachedClient getCache() {
		return mc;
	}

	/**
	 * public void set(String key, String value) { set(key, value, null); }
	 */

	public void set(String key, String value, String timeStr) {
		MemCachedClient mc = MemCacheMgr.getInstance().getCache();
		Long cacheTime = null;
		String cacheTimeValue = "";

		if (StringUtil.isNotEmpty(timeStr)) {
			try {
				cacheTimeValue = (String) MCLoader.getInstance().get(timeStr);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

		if (StringUtil.isNotEmpty(cacheTimeValue)) {
			cacheTime = Long.parseLong(cacheTimeValue);
		} else {
			cacheTime = Long.parseLong((String) MCLoader.getInstance().get(
					"memcached.commonCacheTime"));
		}

		Calendar c = Calendar.getInstance();
		c.setTimeInMillis(cacheTime);
		Date ct = c.getTime();
		mc.set(key, value, ct);

	}

	/**
	 * 根据key从memcached服务中取得value
	 * 
	 * @param key
	 * @return
	 */
	public String getValue(String key) {
		String value = (String) mc.get(key);
		return value;
	}

	public static void main(String[] args) {

		//_instance.set("test", "gga22", "100000");
//    	 _instance.getInstance().mc.flushAll();//清空memecache 服务的缓存数据
		 System.out.println(_instance.getValue("eps.freetoplist1"));
		
	}

之后你就可以通过get,set方法从缓存中获得和存储数据了。