简单入门Memcached

2016-08-10  本文已影响150人  snoweek
首先讲一下Memcache和Memcached。

为什么会有Memcache和Memcached两种名称呢?其实Memcache是这个项目的名称,而Memcached是它服务器端的主程序文件名。

什么是Memcached

Memcached是一种基于内存的key-value存储。它在内存里维护一个统一的巨大的hash表,用来存储各种格式的数据,包括图像、视频、文件以及数据库
检索的结果等。
Memcached通过缓存数据库查询结果,减少数据库访问次数,以提高动态Web应用的速度、提高可扩展性。

工作原理:

  1. 客户端第一次访问应用程序时,会到数据库(RDBMS)中取出数据,返回给客户端;同时也将取出的数据保存到Memcached中。
  2. 第二次访问时,因为数据已经缓存,不不用去数据库查询了,直接从Memcached取。
ubuntu下Memcached安装

由于Memcache是基于libevent的,所以确保你的系统已经装了libevent,libevent是个程序库,它将Linux的epoll、BSD类操作系统的kqueue等事件处理功能封装成统一的接口。
由于memcached和libevent是由C编写的,所以首先确保你的系统安装了gcc。

sudo apt-get install libevent libevent-deve //安装libevent库
sudo apt-get install build-essential//安装 C/C++ 的编译环境 gtk libgtk2.0-dev
sudo apt-get install libgtk2.0-dev
sudo apt-get install memcached//安装 Memcached
Memcached 连接

telnet 命令并指定主机ip和端口来连接 Memcached 服务。

telnet HOST PORT

telnet写入memcache命令格式
<command name> <key> <flags> <exptime> <bytes>\r\n <data block>\r\n

  1. <command name> 可以是”set”, “add”, “replace”
  2. <key> 保存数据的key
  3. <flags> 是一个16位的无符号的整数(以十进制的方式表示)。
  4. <exptime> 过期的时间。0表示存储的数据永远不过时
  5. <bytes> 需要存储的字节数 ,当用户希望存储空数据时,可以为0
  6. 最后客户端需要加上”\r\n”作为”命令头”的结束标志。

telnet响应命令

  1. STORED 表示存储成功
  2. NOT_STORED 表示存储失败,但是该失败不是由于错误
    其他操作命令方法同上

telnet 其他命令
1. Stats 状态
2. stats reset 清空统计数据
3. Flush_all 清空数据
4. Quit 退出telnet

Memcached 运行
memcached -p 11211 -m 64m -d

启动了memcached,监听TCP端口11211,最大内存使用量为64M。
启动Memcached 常用参数
-d是启动一个守护进程;
-m是分配给Memcache使用的内存数量,单位是MB;
-u是运行Memcache的用户;
-l是监听的服务器IP地址,可以有多个地址;
-p是设置Memcache监听的端口,,最好是1024以上的端口;
-c是最大运行的并发连接数,默认是1024;
-P是设置保存Memcache的pid文件。

Java 连接 Memcached 服务

在学习中我使用了两种驱动jar包

import java.net.InetSocketAddress;
import net.spy.memcached.MemcachedClient;

public class M {

    public static void main(String[] args) {
        try{       
             MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));  // 本地连接 Memcached 服务
             System.out.println("Connection to server sucessful.");           
             mcc.shutdown();       // 关闭连接     
          }catch(Exception ex){
             System.out.println( ex.getMessage() );
          }
    }
}


运行结果:
2016-08-10 18:50:33.404 INFO net.spy.memcached.MemcachedConnection:  Added {QA sa=/127.0.0.1:11211, #Rops=0, #Wops=0, #iq=0, topRop=null, topWop=null, toWrite=0, interested=0} to connect queue
Connection to server sucessful.
2016-08-10 18:50:33.409 INFO net.spy.memcached.MemcachedConnection:  Shut down memcached client
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
public class MemcachedJava {
    public static void main(String[] args) {
        //初始化SockIOPool,管理Memcached的连接池
        String[] server = { "127.0.0.1:11211" };
        SockIOPool pool = SockIOPool.getInstance();//获取sock连接池的实例对象  
        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();
        try{
             // 本地连接 Memcached 服务
             MemCachedClient mcc = new MemCachedClient();
             System.out.println("Connection to server sucessful.");
            // mcc.add("frady", "this is a test");  
             //System.out.println(mcc.get("frady"));             
          }catch(Exception ex){
             System.out.println( ex.getMessage() );
          }
    }
}

运行结果:
Connection to server sucessful.

具体的Memcached命令可以参见
Memcached 教程--菜鸟教程

上一篇下一篇

猜你喜欢

热点阅读