首页 > > 网络编程 > Php编程 >

前端学PHP之PHP操作memcache

2018-06-22 05:02:39来源：未知阅读 ()

前面的话

　　和访问mysql服务器类似，PHP也是作为客户端API访问memcached服务器的，所以同样需要为PHP程序安装memcache的扩展接口，比较常用的有memcache和memcached两种扩展。而memcached和memcache的守护进程memcached同名，比较容易引起混淆，甚至提到memcached，有些人第一想到的是后台的守护进程，这里还是有必要分析一下两者之间的区别。memcache是完全在PHP框架内开发的，而memecached是使用libmemcached的。从手册上看，memcached 会比 memcache 多几个方法，使用方式上都差不多。memcache是原生实现的，但是使用libmemcached的memached只支持OO接口，而 memcache则是OO和非OO两套接口并存，以后随着memcached服务器端的改进，这个lib也必定会马上跟进的。而memcache却不一定能做到按时跟进。memcached，还有个非常称赞的地方，就是flag不是在操作的时候设置了。而是有一个统一的setOption()。memcached 实现了更多的 memcached 协议(毕竟是基于 libmemcached库)。本文选择较简单的memcache扩展作介绍

安装

　　在window系统下安装memcache扩展比较简单，下载一个与PHP版本一致的memcache扩展库即可

　　将下载的php_memcache.dll文件保存到PHP的应用程序扩展ext目录中

　　在php.ini文件添加扩展的位置，加入一行"extension=php_memcache.dll"

　　重新启动apache服务器即可，通过phpInfo()可以找到memcache服务已经安装

连接

　　PHP的Memcache应用程序接口既然是作为memcached服务器的客户端，就需要先连接到memcached服务器。Memcache::connect()方法就用于连接到一个memcached服务器，如果连接成功则返回true，否则返回false

bool Memcache::connect ( string $host [, int $port [, int $timeout ]] )

　　该方法有三个参数。第一个参数host(必须项)表示memcached服务端监听主机地址；第二个参数port表示memcached服务端监听端口(可选项)，默认值为11211；第三个参数timeout表示连接持续(超时)时间，单位秒。默认值1秒

　　[注意]过长的连接持续时间可能会导致失去所有的缓存优势

　　使用Memcache::connect()连接到memcached服务器，并完成操作后，可以使用Memcache::close()方法关闭连接，完成一些会话过程。如果需要以长连接方式连接memcached服务器，可以使用Memcache::pconnect()方法实现，该方法的调用方法和Memcache::connect()完全相同，但长连接不能被Memcache::close()方法关闭

//实例化对象
$memcache = new Memcache;
//连接memcache服务器
$memcache->connect('localhost');
/*其他操作*/
//关闭连接
$memcache->close();

增删改查

增加

　　连接memcached服务器成功后，就可以添加一个要缓存的数据(add)，通过Memcache::add()来完成

bool Memcache::add ( string $key , mixed $var [, int $flag [, int $expire ]] )

　　在add()方法中，参数key表示将要分配给变量的key；参数var表示将要被存储的变量。字符串和整型被以原文存储，其他类型序列化后存储；参数flag(可选项)表示使用MEMCACHE_COMPRESSED标记对数据进行压缩(使用zlib)；参数expire(可选项)表示当前写入缓存的数据的失效时间。如果此值设置为0表明此数据永不过期。你可以设置一个UNIX时间戳或以秒为单位的整数(从当前算起的时间差)来说明此数据的过期时间，但是在后一种设置方式中，不能超过2592000秒(30天)

$memcache->add('id1','11111');

删除

Memcache::delete()

　　Memcache::delete — 从服务端删除一个元素

bool Memcache::delete ( string $key [, int $timeout = 0 ] )

　　在delete方法中，有两个参数。参数key表示要删除的元素的key；参数timeout表示删除该元素的执行时间。如果值为0,则该元素立即删除，如果值为30,元素会在30秒内被删除

$memcache->delete('id1');

Memcache::flush

　　Memcache::flush — 清洗（删除）已经存储的所有的元素。成功时返回 TRUE，或者在失败时返回 FALSE

bool Memcache::flush ( void )

　　[注意]Memcache::flush()立即使所有已经存在的元素失效。方法Memcache::flush()并不会真正的释放任何资源，而是仅仅标记所有元素都失效了，因此已经被使用的内存会被新的元素复写

修改

Memcache::set

　　Memcache::set — 设置一个指定key的缓存内容

bool Memcache::set ( string $key , mixed $var [, int $flag [, int $expire ]] )

　　[注意]set()有一个别名是replace()

$memcache->set('id1','12345');

查看

Memcache::get

　　Memcache::get — 从服务端检回一个元素，返回key对应的存储元素的字符串值或者在失败或key未找到的时候返回FALSE

　　get()有以下两种用法

string Memcache::get ( string $key [, int &$flags ] )
array Memcache::get ( array $keys [, array &$flags ] )

　　如果服务端之前有以key作为key存储的元素，Memcache::get()方法此时返回之前存储的值；也可以给Memcache::get()方法传递一个数组(多个key)来获取一个数组的元素值，返回的数组仅仅包含从服务端查找到的key-value对

　　get方法包括两个参数。第一个参数key表示要获取值的key或key数组；第二个参数为flags，如果给定这个参数(以引用方式传递)，该参数会被写入一些key对应的信息。这些标记和Memcache::set()方法中的同名参数意义相同。用int值的低位保留了pecl/memcache的内部用法(比如：用来说明压缩和序列化状态)

$memcache->set('id1','11111');
$memcache->add('id2','22222');
echo $memcache->get('id1') ."<br>";//11111
echo $memcache->get(['id1','id2'])['id2'];//22222

分布式

　　如果有多台memcached服务器端，最好使用Memcache::addServer()来连接服务器，而不是使用Memcache::connect()去连接memcached服务器，因为PHP客户端是利用服务器池，根据"crc32(key) % current_server_num"哈希算法将key哈希到不同的服务器中。Memcache::addServer()方法的格式如下所示

bool Memcache::addServer ( string $host [, int $port = 11211 [, bool $persistent [, int $weight [, int $timeout [, int $retry_interval [, bool $status [, callback $failure_callback [, int $timeoutms ]]]]]]]] )

　　Memcache::addServer()增加一个服务器到连接池中。通过Memcache::addServer()打开的连接将会在脚本执行结束后自动关闭，也可以使用Memcache::close()进行手动关闭，也可以使用memcache_add_server()来添加服务器

　　当使用这个方法时(与Memcache::connect()和Memcache::pconnect()相反)，网络连接并不会立刻建立，而是直到真正使用的时候才建立。因此在加入大量服务器到连接池中时也是没有开销的，因为它们可能并不会被使用

　　故障转移可能在方法的任何一个层次发生，通常只要其他服务器可用，用户就不会感受到。任何的socket或memcache服务器级别的错误(比如内存溢出)都可能导致故障转移。而一般的客户端错误比如使用Memcache::add尝试增加一个已经存在的key则不会导致故障转移

　　参数host表示要连接的memcached服务端监听的主机位置。这个参数通常指定其他类型的传输比如Unix域套接字使用 unix:///path/to/memcached.sock，这种情况下参数port 必须设置为0

　　参数port表示要连接的memcached服务端监听的端口。当使用UNIX域套接字连接时设置为0

　　参数persistent用来控制是否使用持久化连接。默认TRUE

　　参数weight表示为此服务器创建的桶的数量，用来控制此服务器被选中的权重，单个服务器被选中的概率是相对于所有服务器weight总和而言的

　　参数timeout表示连接持续(超时)时间(单位秒)，默认值1秒

　　参数retry_interval表示服务器连接失败时重试的间隔时间，默认值15秒。如果此参数设置为-1表示不重试。此参数和persistent参数在扩展以dl()函数动态加载的时候无效

　　每个失败的连接结构有自己的超时时间，并且在它失效之前选择后端服务请求时该结构会被跳过。一旦一个连接失效，它将会被成功重新连接或被标记为失败连接以在下一个retry_interval秒重连。典型的影响是每个web服务子进程在服务于一个页面时将会每retry_interval秒尝试重新连接一次

　　参数status用来控制此服务器是否可以被标记为在线状态。设置此参数值为FALSE并且retry_interval参数设置为-1时，允许将失败的服务器保留在一个池中以免影响key的分配算法。对于这个服务器的请求会进行故障转移或者立即失败，这受限于memcache.allow_failover参数的设置。该参数默认TRUE，表明允许进行故障转移

　　参数failure_callback表示允许用户指定一个运行时发生错误后的回调函数。回调函数会在故障转移之前运行。回调函数会接受到两个参数，分别是失败主机的主机名和端口号

<?php
//实例化对象
$memcache = new Memcache;
//连接memcache服务器
$memcache->addServer('localhost');
$memcache->addServer('192.168.1.2');
$memcache->addServer('192.168.1.3');

for($i=0;$i<100;$i++){
    $memcache->set('key'.$i,md5($i),0,60);
}
//关闭连接
$memcache->close();
?>

状态

Memcache::getStats

　　Memcache::getStats — 获取服务器统计信息

array Memcache::getStats ([ string $type [, int $slabid [, int $limit = 100 ]]] )

　　Memcache::getStats()返回一个关联数据的服务器统计信息。数组key是统计信息名，值就是统计信息的值。同样可以使用函数memcache_get_stats()

　　参数type表示期望抓取的统计信息类型，可以使用的值有{reset, malloc, maps, cachedump, slabs, items, sizes}。通过memcached协议指定这些附加参数是为了方便memcache开发者(检查其中的变动)

　　参数slabid用于与参数type联合从指定slab分块拷贝数据，cachedump命令会完全占用服务器通常用于比较严格的调试。

　　参数limit用于和参数type联合来设置cachedump时从服务端获取的实体条数

<?php
//实例化对象
$memcache = new Memcache;
//连接memcache服务器
$memcache->addServer('localhost');
/*
Array ( [pid] => 6268 [uptime] => 3054571472 [time] => 240596173 [version] => 1.4.4-14-g9c660c0 [pointer_size] => 64 [curr_connections] => 13 [total_connections] => 24 [connection_structures] => 14 [cmd_get] => 37 [cmd_set] => 526 [cmd_flush] => 1 [get_hits] => 31 [get_misses] => 6 [delete_misses] => 0 [delete_hits] => 2 [incr_misses] => 0 [incr_hits] => 0 [decr_misses] => 0 [decr_hits] => 0 [cas_misses] => 0 [cas_hits] => 0 [cas_badval] => 0 [auth_cmds] => 0 [auth_errors] => 0 [bytes_read] => 27834 [bytes_written] => 9658 [limit_maxbytes] => 67108864 [accepting_conns] => 1 [listen_disabled_num] => 0 [threads] => 4 [conn_yields] => 0 [bytes] => 10655 [curr_items] => 105 [total_items] => 518 [evictions] => 0 )
 */
print_r($memcache->getStats()); 
//关闭连接
$memcache->close();
?>

Memcache::getExtendedStats

　　Memcache::getExtendedStats — 缓存服务器池中所有服务器统计信息

array Memcache::getExtendedStats ([ string $type [, int $slabid [, int $limit = 100 ]]] )

　　Memcache::getExtendedStats() 返回一个二维关联数据的服务器统计信息。数组的key由host:port方式组成，无效的服务器返回的统计信息被设置为false，同样的，可以使用函数memcache_get_extended_stats()

　　参数slabid用于与参数type联合从指定slab分块拷贝数据，cachedump命令会完全占用服务器通常用于比较严格的调试

　　参数limit用于和参数type联合来设置cachedump时从服务端获取的实体条数

<?php
    $memcache_obj = new Memcache;
    $memcache_obj->addServer('memcache_host', 11211);
    $memcache_obj->addServer('failed_host', 11211);
    
    $stats = $memcache_obj->getExtendedStats();
/*
Array
(
    [memcache_host:11211] => Array
        (
            [pid] => 3756
            [uptime] => 603011
            [time] => 1133810435
            [version] => 1.1.12
            [rusage_user] => 0.451931
            [rusage_system] => 0.634903
            [curr_items] => 2483
            [total_items] => 3079
            [bytes] => 2718136
            [curr_connections] => 2
            [total_connections] => 807
            [connection_structures] => 13
            [cmd_get] => 9748
            [cmd_set] => 3096
            [get_hits] => 5976
            [get_misses] => 3772
            [bytes_read] => 3448968
            [bytes_written] => 2318883
            [limit_maxbytes] => 33554432
        )

    [failed_host:11211] => false
)
 */    
    print_r($stats);
?>

安全

　　访问MYSQL数据库服务器时必须通过用户验证后才能进入，而访问memcached服务器则是通过客户端连接后直接操作，没有任何的验证过程。这样如果服务器直接暴露在互联网上的话是比较危险，轻则数据泄露被其他无关人员查看，重则服务器被入侵。为了安全起见，有以下两点安全措施

　　1、内网访问

　　最好把两台服务器之间的访问设置为内网形态的，一般在Web服务器跟Memcache服务器之间。普遍的服务器都是有两块网卡，一块指向互联网，一块指向内网，那么就让Web服务器通过内网的网卡来访问Memcache服务器，Memcache服务器启动时，就监听内网的IP地址和端口，内网间的访问能够有效阻止其他非法的访问

# memcached -d -m 1024 -u root -l 192.168.0.200 -p 11211 -c 1024 start

　　Memcache服务器端设置监听通过内网的192.168.0.200的ip的11211端口，占用1024MB内存，并且允许最大1024个并发连接

　　2、设置防火墙

　　防火墙是简单有效的方式，如果memcache和web Server在同一台机器上，或通过外网IP来访问Memcache的话，就需要使用防火墙或者代理程序来过滤非法访问

　　一般在Linux下可以使用iptables或者FreeBSD下的ipfw来指定一些规则防止一些非法的访问，比如可以设置只允许Web服务器来访问Memcache服务器，同时阻止其他的访问

# iptables -F
# iptables -P INPUT DROP
# iptables -A INPUT -p tcp -s 192.168.0.2 –dport 11211 -j ACCEPT
# iptables -A INPUT -p udp -s 192.168.0.2 –dport 11211 -j ACCEPT

　　上面的iptables规则是只允许192.168.0.2这台Web服务器对Memcache服务器的访问，能够有效的阻止一些非法访问，相应的也可以增加一些其他的规则来加强安全性，这个可以根据自己的需要来做

应用

　　在项目中最常见的memcache应用，是缓存从数据库中查询的数据结果，以及保存会话控制信息。会话控制将在以后介绍。下面主要介绍如何将数据库查询出来的结果使用memcache服务器进行缓存，以减少频繁的数据库连接及大量的查询对数据库造成的压力。设计的原则是只要数据库中的记录没有被改变，就不需要重新连接数据库并反复执行重复的查询语句，相同的查询结果都应该从缓存服务器中获取

<?php 
function select($sql,MemCache $memcache){
    $key=md5($sql);
    $data = $memcache->get($key);
    if(!$data) {
        try {
            $pdo = new PDO("mysql:host=localhost;dbname=xsphp", "root", "123456");
        }catch(PDOException $e) {
            die("数据库连接失败:".$e->getMessage());
        }
        $stmt = $pdo -> prepare($sql);
        $stmt -> execute();
        $data = $stmt -> fetchAll(PDO::FETCH_ASSOC);
        $memcache -> add($key, $data, MEMCACHE_COMPRESSED, 0);
    }
    return $data;
}
$memcache = new Memcache;
$memcache -> connect("localhost", 11211);
$data = select("SELECT * FROM user",$memcache);
var_dump($data);
$memcache -> close();
?>