日期:2014-05-16  浏览次数:20762 次

Memcached struts2 java linux 简单例子

一、

Memcached安装和使用:
官网:http://monkey.org/~provos/libevent/
libevent
下载:http://monkey.org/~provos/libevent-1.4.9-stable.tar.gz
Memcached
官网:http://www.danga.com/memcached
Memcached
下载:http://www.danga.com/memcached/dist/memcached-1.2.6.tar.gz

二、

安装 libevent
# tar zxvf libevent-1.4.9-stable.tar.gz
# cd libevent-1.4.9-stable
# ./configure --prefix=/usr
# make
# make install
?
安装 Memcached
# tar zxvf memcached-1.2.6.tar.gz
# cd memcached-1.2.6
# ./configure --prefix=/usr/local
# make
# make install

三、

       安装成功启动

       ./memcached -d -u root -m 512 127.0.0.1 -p 11211

  到这里,看到memcached已经启动,说明安装成功。

  如果要结束Memcache进程,执行:

  # kill `cat /tmp/memcached.pid`

  也可以启动多个守护进程,不过端口不能重复。

  memcache启动参数说明:

  -d选项是启动一个守护进程,

  -m是分配给Memcache使用的内存数量,单位是MB,我这里是10MB,

  -u是运行Memcache的用户,我这里是root,

  -l是监听的服务器IP地址,如果有多个地址的话,我这里指定了服务器的IP地址192.168.0.200,

  -p是设置Memcache监听的端口,我这里设置了12000,最好是1024以上的端口,

  -c选项是最大运行的并发连接数,默认是1024,我这里设置了256,按照你服务器的负载量来设定,

  -P是设置保存Memcache的pid文件,我这里是保存在 /tmp/memcached.pid

四 、代码部分

1.MemCacheClient类

 

package com.uitl;

import java.util.Date;
import java.util.Map;

import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
/***
 * 
 * @author ZhuangZi
 * @version $Id: MemCacheClient.java,v 0.1 2013-3-5 下午04:35:56 ZhuangZi Exp $
 */
public class MemCacheClient {

	protected static MemCachedClient memcachedClient = new MemCachedClient();

	protected static String cacheIP = "192.168.3.27:11211";

	static {
		// 服务器列表和其权重,memcached地址和端口号
		String[] servers = { cacheIP };
		Integer[] weights = { 3 };
		// 获取socke连接池的实例对象
		SockIOPool pool = SockIOPool.getInstance();
		// 设置服务器信息
		pool.setServers(servers);
		pool.setWeights(weights);
		// 设置初始连接数、最小和最大连接数以及最大空闲时间
		pool.setInitConn(5);
		pool.setMinConn(5);
		pool.setMaxConn(500);
		pool.setMaxIdle(1000 * 60 * 60 * 6);
		// 设置主线程的睡眠时间秒
		pool.setMaintSleep(30);
		// 关闭nagle算法
		pool.setNagle(false);
		// 设置 读取 超时3秒钟
		pool.setSocketTO(3000);
		// 不设置连接超时
		pool.setSocketConnectTO(0);
		// 初始化一些值并与MemcachedServer段建立连接
		pool.initialize();
	}

	/***
	 * 读取缓存
	 * @param key
	 * @param times
	 * @return
	 */
	public static String getValue(String key, int times) {
		String value = "";
		try {
			value = memcachedClient.get(key, times).toString();
		} catch (Exception e) {
			e.printStackTrace();
			return null;
		}
		return value;
	}

	/***
	 * 设置缓存
	 * @param key
	 * @param value
	 * @param times
	 * @return
	 */
	public static boolean setValue(String key, String value, int times) {
		boolean result = false;
		try {
		    System.out.println("********");
			result = memcachedClient.set(key, value,
					new Date(System.currentTimeMillis() + times * 1000));
			  System.out.println("*1*******"+result);
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
		return result;
	}

	public static boolean setValue(String key, String value) {
		boolean result = false;
		try {
			result = memcachedClient.set(key, value);
		} catch (Exception e) {
		    e.printStackTrace();
			return false;
		}
		return result;
	}

	/***
	 * 删除缓存
	 * @param key
	 * @return
	 */
	public static boolean delete(String key) {
		return memcachedClient.delete(key);
	}

	@SuppressWarnings("unchecked")
    public static Map getStatus() {
		Map stats = memcachedClient.stats();
		return stats;
	}

	public Object[] getMultiArray(String[] sKeys) {
		return memcachedClient.getMultiArray(sKeys);
	}

	public static void main(String[] args) {
//		 System.out.println(setValue("2", "密密麻麻",100));
//		System.out.println(getValue("2", 1));
		// delete("eve