package cn.com.atobo.adm.utils;
import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
/**
* memcached 缓存服务器
* @author guowb
* @date 2015-8-25 下午6:30:00
*/
public class MemUtils {
private static Logger logger = Logger.getLogger(MemUtils.class);
private static MemCachedClient mcc = new MemCachedClient();
/** 3600 秒 */
private static final Integer EXPIRE = 3600;
static {
SockIOPool pool = SockIOPool.getInstance();// 获取链接池的实例
String memCached = ResourceUtil.getConfigValueByKey("memchchedIP");// memcached服务器
pool.setServers(new String[] { memCached + ":11211" });
pool.setWeights(new Integer[] { 1 });// 权重
pool.setInitConn(10);// 初始链接
pool.setMinConn(10); // 最小链接
pool.setMaxConn(1000);// 最大链接
pool.setMaxIdle(1000 * 60 * 60);// 最大等待
pool.setMaintSleep(60);// 睡眠时间
pool.setNagle(false);
pool.setSocketTO(3000);// 链接超时 3秒
pool.setSocketConnectTO(0);
pool.initialize(); // 初始化并启动链接池
}
/**
* 添加值 ,存在则添加失败
*
* @author langwenjie
* @date 2015-8-25 下午4:18:06
*/
public static boolean add(String key, Object value) {
if(StringUtils.isNotBlank(key)){
logger.info("new add :key=" + key);
return mcc.add(key, value, EXPIRE);
}
return false;
}
/**
* 添加值,存在则替换
* 若是为用户登录时产生的数据,则"user"+用户ID
* 若是为用户没有登录时产品的数据,则key 由MemcachedBean控制
*
* @author langwenjie
* @date 2015-8-25 下午4:28:49
*/
public static boolean set(String key, Object value) {
logger.info("set value :key=" + key);
return mcc.set(key, value, EXPIRE);
}
/**
* 替换值,不存在则替换失败
*
* @author langwenjie
* @date 2015-8-25 下午4:29:08
*/
public static boolean replace(String key, Object value) {
logger.info("replace :key=" + key);
return mcc.replace(key, value, EXPIRE);
}
/**
* 取出值
*
* @author langwenjie
* @date 2015-8-25 下午4:30:33
*/
public static Object get(String key) {
Object object = mcc.get(key);
logger.info("key :" + key + " value :" + (object!=null));
return object;
}
/**
* 删除值
*
* @author langwenjie
* @date 2015-8-25 下午5:51:32
*/
public static boolean delete(String key) {
logger.info("delete :" + key);
return mcc.delete(key);
}
}
3.项目中直接调用
1. 准备安装文件node
下载memcached与libevent的安装文件linux
http://memcached.googlecode.com/files/memcached-1.4.15.tar.gz(memcached下载地址)git
https://github.com/downloads/libevent/libevent/libevent-2.0.21-stable.tar.gz(libevent下载地址)github
2. 具体安装步骤apache
1.因为memcached依赖于libevent,所以须要安装libevent。因为linux系统可能默认已经安装libevent,执行命令:缓存
rpm -qa|grep libevent服务器
查看系统是否带有该安装软件,若是有执行命令:网络
rpm -e libevent-1.4.13-4.el6.x86_64 --nodeps(因为系统自带的版本旧,忽略依赖删除)并发
3. 安装libevent命令:memcached
tar zxvf libevent-2.0.21-stable.tar.gz
cd libevent-2.0.21-stable
./configure --prefix=/usr/local/libevent
make
make install
至此libevent安装完毕;
安装过程当中出现:configure: error : no acceptable C compiler found in $PATH错误时是没有安装gcc,运行以下命令:
yum install gcc* make*
4. 安装memcached命令:
tar zxvf memcached-1.4.2.tar.gz
cd memcached-memcached-1.4.2
./configure --prefix=/usr/local/memcached --with-libevent=
/usr/local/libevent/
make
make install
至此memcached安装完毕;
5.当启动memcached时常常不能发现libevent.so;能够经过如下命令检查:
进入/usr/local/memcached/bin目录
LD_DEBUG=help ./memcached -v
LD_DEBUG=libs
./
memcached -v
解决方法:
ln -s /usr/local/libevent/lib/libevent-2.0.so.5 /lib64/libevent-2.0.so.5
6. 启动memcached
1.打开一个终端,输入如下命令:
./usr/local/memcached/bin/memcached -d -m 256 -u root -p 11211 -c 1024 –P /tmp/memcached.pid
启动参数说明:
-d 选项是启动一个守护进程。
-u root 表示启动memcached的用户为root。
-m 是分配给Memcache使用的内存数量,单位是MB,默认64MB。
-M return error on memory exhausted (rather than removing items)。
-u 是运行Memcache的用户,若是当前为root 的话,须要使用此参数指定用户。
-p 是设置Memcache的TCP监听的端口,最好是1024以上的端口。
-c 选项是最大运行的并发链接数,默认是1024。
-P 是设置保存Memcache的pid文件。
另外还有个更详细的参数说明:
Param代码
- memcached 1.4.2
- -p 监听的TCP端口(默认: 11211)
- -U 监听的UDP端口(默认: 11211, 0表示不监听)
- -s 用于监听的UNIX套接字路径(禁用网络支持)
- -a UNIX套接字访问掩码,八进制数字(默认:0700)
- -l 监听的IP地址。(默认:INADDR_ANY,全部地址)
- -d 做为守护进程来运行。
- -r 最大核心文件限制。
- -u 设定进程所属用户。(只有root用户可使用这个参数)
- -m 单个数据项的最大可用内存,以MB为单位。(默认:64MB)
- -M 内存用光时报错。(不会删除数据)
- -c 最大并发链接数。(默认:1024)
- -k 锁定全部内存页。注意你能够锁定的内存上限。
- 试图分配更多内存会失败的,因此留意启动守护进程时所用的用户可分配的内存上限。
- (不是前面的 -u 参数;在sh下,使用命令"ulimit -S -l NUM_KB"来设置。)
- -v 提示信息(在事件循环中打印错误/警告信息。)
- -vv 详细信息(还打印客户端命令/响应)
- -vvv 超详细信息(还打印内部状态的变化)
- -h 打印这个帮助信息并退出。
- -i 打印memcached和libevent的许可。
- -P 保存进程ID到指定文件,只有在使用 -d 选项的时候才有意义。
- -f 块大小增加因子。(默认:1.25)
- -n 分配给key+value+flags的最小空间(默认:48)
- -L 尝试使用大内存页(若是可用的话)。提升内存页尺寸能够减小"页表缓冲(TLB)"丢失次数,提升运行效率。
- 为了从操做系统得到大内存页,memcached会把所有数据项分配到一个大区块。
- -D 使用 做为前缀和ID的分隔符。
- 这个用于按前缀得到状态报告。默认是":"(冒号)。
- 若是指定了这个参数,则状态收集会自动开启;若是没指定,则须要用命令"stats detail on"来开启。
- -t 使用的线程数(默认:4)
- -R 每一个链接可处理的最大请求数。
- -C 禁用CAS。
- -b 设置后台日志队列的长度(默认:1024)
- -B 绑定协议 - 可能值:ascii,binary,auto(默认)
- -I 重写每一个数据页尺寸。调整数据项最大尺寸。
也能够启动多个守护进程,可是端口不能重复
查看memcached启动命令
ps aux|grep memcached
7.中止Memcache进程: kill `cat /tmp/memcached.pid`