Memcache集群环境下缓存解决方案

Love The Way You Lie 2022-06-10 09:55 216阅读 0赞

Memcache是一个高性能的分布式的内存对象缓存系统，通过在内存里维护一个统一的巨大的hash表，它能够用来存储各种格式的数据，包括图像、视频、文件以及数据库检索的结果等。简单的说就是将数据调用到内存中，然后从内存中读取，从而大大提高读取速度。

## 一、在Linux上安装memcached：    ##

1. Linux上的memcache需要俩个安装包：libevent-1.4.12-stable.tar.gz 、memcached-1.4.3.tar.gz   
   解压安装：

**\[plain\]**  view plain  copy

print ?

1.  tar -zxf libevent-1.4.12-stable.tar.gz   
2.  tar -zxf memcached-1.4.3.tar.gz

tar -zxf libevent-1.4.12-stable.tar.gz 
        	tar -zxf memcached-1.4.3.tar.gz

进入libevent并安装

**\[plain\]**  view plain  copy

print ?

1.  \# cd libevent-1.4.12-stable  
2.  \# ./configure --prefix=/usr/local/libevent  
3.  \# make  
4.  \# sudo make install

# cd libevent-1.4.12-stable
    	# ./configure --prefix=/usr/local/libevent
    	# make
    	# sudo make install

测试libevent是否安装成功：

**\[plain\]**  view plain  copy

print ?

1.  \# ls -al /usr/lib | grep libevent

# ls -al /usr/lib | grep libevent

进入memcache并安装

**\[plain\]**  view plain  copy

print ?

1.  \# cd ../ memcached-1.4.3  
2.  \# ./configure --prefix=/usr/local/memcached --with-libevent=/usr/local/libevent  
3.  \# make  
4.  \# sudo make install

# cd ../ memcached-1.4.3
    	# ./configure --prefix=/usr/local/memcached --with-libevent=/usr/local/libevent
    	# make
    	# sudo make install

2、在Linux上启动memcached（启动时指定端口号）

\# /usr/local/memcached/bin/memcached -d -m 528 -u ligang -p12131

\-m 启动内存 \-u 启动用户 \-p 端口

[测试][Link 1]启动是否成功：

**\[plain\]**  view plain  copy

print ?

1.  telnet  ip port  
2.  telnet 172.17.3.135 12135

telnet  ip port
       	telnet 172.17.3.135 12135

3、查看memcached进程并关闭memcached

**\[plain\]**  view plain  copy

print ?

1.  ps -aux |grep mem

ps -aux |grep mem

## 二、Windows下安装： ##

1.  首先准备好memcache windows稳定版  
2.  以管理员省份运行DOS窗口  
3.  memcached.exe -d install  
4.  memcached.exe -d start  
5.  查看是否安装成功services.msc  
设置memcached，启动该服务后，memcached服务默认占用的端口是11211，占用的最大内存默认是64M。如果需要修改这两个参数，比如修改端口为10000，内存为512，则输入：

**\[plain\]**  view plain  copy

print ?

1.  D:\\memcached\\memcached.exe -p 10000 -m 512 -d start

D:\memcached\memcached.exe -p 10000 -m 512 -d start

\-p 表示要修改的端口，   
\-m表示占用的最大内存(单位为M)。  
上述命令无效，通过修改注册表实现

**\[plain\]**  view plain  copy

print ?

1.  HKEY\_LOCAL\_MACHINE\\SYSTEM\\CurrentControlSet\\Services\\memcached Server  
2.  其中的ImagePath项的值为："c:\\memcached\\memcached.exe" -d runservice  
3.  改成："c:\\memcached\\memcached.exe" -p 15000 -d runservice

HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\memcached Server
    其中的ImagePath项的值为："c:\memcached\memcached.exe" -d runservice
    改成："c:\memcached\memcached.exe" -p 15000 -d runservice

7.常用命令：  
A. telnet到memcache服务器，如:telnet 127.0.0.1 11211(11211是memcache的默认端口)  
进入上述环境后，下面命令可用：  
B. stats 查看基本信息  
C. stats items 查看items  
D. get key（key 为 item后面的字符串即键）  
E. -c 最大同时连接数，默认是1024  
F. -f 块大小增长因子，默认是1.25  
G. -n 最小分配空间，key+value+flags默认是48  
H. -h 显示帮助

## 三、JAVA实例 ##

所需要的jiar包：commons-pool-1.5.6.jar、java\_memcached-release\_2.6.3.jar、slf4j-api-1.6.1.jar、slf4j-simple-1.6.1.jar

**\[java\]**  view plain  copy

print ?

1.  package memcachedDemo;  
2.    
3.  import java.util.Date;  
4.    
5.  import com.danga.MemCached.MemCachedClient;  
6.  import com.danga.MemCached.SockIOPool;  
7.    
8.  public class Memcached \{  
9.      private static MemCachedClient mcc = new MemCachedClient();  
10.     private static Memcached memcached = new Memcached();  
11.       
12.     //服务群组  
13.     private static final String\[\] services = \{ "127.0.0.1:11211"\};  
14.     //服务器群各自对应的权重  
15.     private static final Integer\[\] weights = \{ 1\};  
16.     //初始化连接数  
17.     private static final Integer init\_connection = 5;  
18.     //最小连接数  
19.     private static final Integer min\_connection = 5;  
20.     //最大连接数  
21.     private static final Integer max\_connection = 250;  
22.     //最大处理时间 60\*60  
23.     private static final Long max\_idle = 3600L;  
24.     //主程序睡眠时间  
25.     private static final Long maint\_sleep = 10L;  
26.       
27.     static\{  
28.         //获取scoke连接池的实例对象  
29.         SockIOPool pool = SockIOPool.getInstance();  
30.         pool.setServers(services);  
31.         pool.setWeights(weights);  
32.         pool.setInitConn(init\_connection);  
33.         pool.setMinConn(min\_connection);  
34.         pool.setMaxConn(max\_connection);  
35.         pool.setMaxIdle(max\_idle);  
36.         pool.setMaintSleep(maint\_sleep);  
37.           
38.         //设置TCP的参数，连接超时等  
39.         pool.setNagle(false);  
40.         pool.setSocketTO(3000);  
41.         pool.setSocketConnectTO(0);  
42.           
43.         //初始化连接池  
44.         pool.initialize();  
45.           
46.         //超过指定大小就压缩  
47.         //mcc.setCompressEnable(true);  
48.         //mcc.setCompressThreshold(65536L);  
49.     \}  
50.       
51.     private Memcached()\{\}  
52.       
53.     private static Memcached getInstance()\{  
54.         return memcached;  
55.     \}  
56.     public boolean add(String key,Object value)\{  
57.         return mcc.add(key, value);  
58.     \}  
59.        
60.     public boolean add(String key,Object value,Date expiry)\{  
61.         return mcc.add(key, value, expiry);  
62.     \}  
63.     public boolean replace(String key, Object value)\{   
64.         return mcc.replace(key, value);   
65.     \}   
66.     public boolean replace(String key, Object value, Date expiry)\{   
67.         return mcc.replace(key, value, expiry);   
68.     \}   
69.     public Object get(String key)\{   
70.         return mcc.get(key);   
71.     \}  
72.       
73.     public static void main(String\[\] args) \{  
74.         Memcached memcached = Memcached.getInstance();  
75.         boolean s = memcached.add("abc", new String("123"));  
76.         System.out.println(s);  
77.         System.out.println(memcached.get("abc"));  
78.     \}  
79.   
80. \}

package memcachedDemo;
    
    import java.util.Date;
    
    import com.danga.MemCached.MemCachedClient;
    import com.danga.MemCached.SockIOPool;
    
    public class Memcached {
    	private static MemCachedClient mcc = new MemCachedClient();
    	private static Memcached memcached = new Memcached();
    	
    	//服务群组
    	private static final String[] services = {"127.0.0.1:11211"};
    	//服务器群各自对应的权重
    	private static final Integer[] weights = {1};
    	//初始化连接数
    	private static final Integer init_connection = 5;
    	//最小连接数
    	private static final Integer min_connection = 5;
    	//最大连接数
    	private static final Integer max_connection = 250;
    	//最大处理时间 60*60
    	private static final Long max_idle = 3600L;
    	//主程序睡眠时间
    	private static final Long maint_sleep = 10L;
    	
    	static{
    		//获取scoke连接池的实例对象
    		SockIOPool pool = SockIOPool.getInstance();
    		pool.setServers(services);
    		pool.setWeights(weights);
    		pool.setInitConn(init_connection);
    		pool.setMinConn(min_connection);
    		pool.setMaxConn(max_connection);
    		pool.setMaxIdle(max_idle);
    		pool.setMaintSleep(maint_sleep);
    		
    		//设置TCP的参数，连接超时等
    		pool.setNagle(false);
    		pool.setSocketTO(3000);
    		pool.setSocketConnectTO(0);
    		
    		//初始化连接池
    		pool.initialize();
    		
    		//超过指定大小就压缩
    		//mcc.setCompressEnable(true);
    		//mcc.setCompressThreshold(65536L);
    	}
    	
    	private Memcached(){}
    	
    	private static Memcached getInstance(){
    		return memcached;
    	}
    	public boolean add(String key,Object value){
            return mcc.add(key, value);
        }
         
        public boolean add(String key,Object value,Date expiry){
            return mcc.add(key, value, expiry);
        }
        public boolean replace(String key, Object value){ 
            return mcc.replace(key, value); 
        } 
        public boolean replace(String key, Object value, Date expiry){ 
            return mcc.replace(key, value, expiry); 
        } 
        public Object get(String key){ 
            return mcc.get(key); 
        }
        
        public static void main(String[] args) {
    		Memcached memcached = Memcached.getInstance();
    		boolean s = memcached.add("abc", new String("123"));
    		System.out.println(s);
    		System.out.println(memcached.get("abc"));
    	}
    
    }

**所需JAR和安装包**： [http://pan.baidu.com/s/1sjjX23r][http_pan.baidu.com_s_1sjjX23r]

[Link 1]: http://lib.csdn.net/base/softwaretest
[http_pan.baidu.com_s_1sjjX23r]: http://pan.baidu.com/s/1sjjX23r