关于导出memcached的全部数据，只是使用了memcached提供的几个功能接口而已，具体代码如下，但是有几个要注意的地方。
- 第一个是cachedump命令每次返回的数据大小只有2M，这个是memcached的代码中写死的一个数值，除非在编译前修改
- 第二个问题是在一个memcached做cachedump时，似乎不能在循环里面对另外一个memcached做set操作。这个只是在尝试的时候发现的问题，一开始我是在第一个foreach循环中获取数据并放到另外一个memcached里的，这个时候会出现放置的数据为2byte的一个假数据。经过测试，取的数据时对的，但是放的时候出现了错误，所以下面的代码先循环cachedump的key，再单独循环key列表去导出数据。
- 最后这个问题是有第一个引起的，根据我导入的情况看，2M一般只能拿到4万左右的key，有些slab的item达到了4千万，4万只是千分之一，所以只能边导出边删除，知道没有数据可以导出为止。
<?php
echo "Start time ".date("Y-m-d H:i:s")."\n";
$slabs = array_slice($argv, 1);
foreach ($slabs as $slabId) {
export($slabId);
}
echo "End time ".date("Y-m-d H:i:s")."\n";
function export($slabId)
{
$num = 0;
$total = 0;
$times = 0;
$deleteCount = 0;
$addCount = 0;
$fromCache = new Memcache();
$fromCache->connect("192.168.0.100", 11211);
for ($i = 0; $i < 200; $i++) {
$keys = array();
$cdump = $fromCache->getExtendedStats( 'cachedump' , intval( $slabId ) , 10000000 );
foreach( $cdump AS $entries )
{
if( $entries )
{
foreach( $entries AS $eName => $eData )
{
$keys[] = $eName;
}
}
}
$toCache = new Memcache();
$toCache->connect("192.168.0.101", 11211);
if (count($keys) == 0 ) {
break;
}
foreach ($keys as $key) {
$value = $fromCache->get($key);
if ($toCache->add($key, $value, MEMCACHE_COMPRESSED, 864000)) {
$back = $toCache->get($key);
if (strlen(serialize($value)) != strlen(serialize($back))) {
$toCache->delete($key);
} else {
$num++;
}
}
$fromCache->delete($key);
}
$deleteCount += count($keys);
$addCount += $num;
$num = 0;
}
echo "Total import $addCount items into slab $slabId.\n";
echo "Total remove $deleteCount items from $slabId.\n";
}
?>参考链接：
评论