
平台论坛博客文库

› 论坛 › IT运维 › 分布式文件系统（FastDFS） › 做了个 PHP 客户端包装类

[FastDFS] 做了个 PHP 客户端包装类 [复制链接]

snkzhong

丰衣足食

论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2009-05-25 17:58 |只看该作者 |倒序浏览

根据 PHP 客户端的实例做了个简单的包装，在我的机子上测试过了
类文件名： FastDFS.php ，放在 php 客户端的那个文件夹中

<?php
require 'fdfs_common.php';
require 'fdfs_tracker_client.php';
require 'fdfs_storage_client.php';
class FastDFS
{
private $tracker_server;
private $storage_server;
private $group_name;
public function factory($group_name)
{
static $obj;
if(!$obj)
$obj = new FastDFS($group_name);
return $obj;
}
public function __construct($group_name)
{
$this->storage_server = null;
$this->group_name = $group_name;
$this->connection();
}
public function connection()
{
$tracker_server = tracker_get_connection();
if ($tracker_server == false)
{
return $this->halt("tracker_get_connection fail\n");
}
$this->tracker_server = $tracker_server;
}
/**
* 根据文件名上传
*
* @param string $local_filename
* @param array $meta_list
* @return remote filename
*/
public function upByFileName($local_filename, $meta_list=array())
{
//$local_filename = 'nginx-logo.png';
//$group_name = ''; //you can specify the group to upload file to
//$meta_list = array('width' => 1024, 'height' => 768, 'color' => '#c0c0c0');
$result = storage_upload_by_filename($this->tracker_server, $this->storage_server,
$local_filename, $meta_list,
$this->group_name, $remote_filename);
if ($result == 0)
{
//echo "group_name=$group_name, remote_filename=$remote_filename\n";
return $remote_filename;
}
else
{
return $this->halt("storage_upload_by_filename fail, result=$result\n");
}
}
/**
* 把文件 buff 上传
*
* @param string $file_buff
* @param string $file_ext
* @param array $meta_list
* @return remote filename
*/
public function upByBuff($file_buff, $file_ext, $meta_list=array())
{
if ($file_buff != false)
{
$file_size = strlen($file_buff);
//$group_name = ''; //you can specify the group to upload file to
$result = storage_upload_by_filebuff($this->tracker_server, $this->storage_server,
$file_buff, $file_size, $file_ext, $meta_list,
$this->group_name, $remote_filename);
if ($result == 0)
{
//echo "group_name=$group_name, remote_filename=$remote_filename\n";
return $remote_filename;
}
else
{
return $this->halt("storage_upload_by_filename fail, result=$result\n");
}
}
}
/**
* 下载到本地文件
*
* @param string $remote_filename 远程文件名
* @param string $local_filename 本地文件名
* @return bool
*/
public function downToFile($remote_filename, $local_filename)
{
//$remote_filename = 'M00/00/00/fWaowEoaQj8AAFMnYnV13w36.php';
$result = tracker_query_storage_fetch($this->tracker_server, $this->storage_server,
$this->group_name, $remote_filename);
if ($result == 0)
{
//echo "storage server ${storage_server['ip_addr']}:${storage_server['port']}\n ";
}
else
{
return $this->halt("tracker_query_storage_fetch fail, errno: $result\n");
}
$result = storage_download_file_to_file($this->tracker_server, $this->storage_server,
$this->group_name, $remote_filename, $local_filename, $file_size);
if ($result == 0)
{
//echo "download file to file success, file size: $file_size\n ";
return true;
}
else
{
return $this->halt("storage_download_file_to_file fail, errno: $result\n");
}
}
/**
* 下载到 buff
*
* @param string $remote_filename 远程文件名
* @return file name
*/
public function downToBuff($remote_filename)
{
$result = storage_download_file_to_buff($this->tracker_server, $this->storage_server,
$this->group_name, $remote_filename, $file_buff, $file_size);
if ($result == 0)
{
//echo "download file to buff success, file size: $file_size" . ", buff size:" . strlen($file_buff) . "\n ";
$fname = str_replace('/', '_', $remote_filename);
file_put_contents($fname, $file_buff);
return $fname;
}
else
{
return $this->halt("storage_download_file_to_buff fail, errno: $result\n");
}
}
public function downToFileEx($remote_filename)
{
$local_filename = str_replace('/', '-', $remote_filename);
$fp = fopen($local_filename, 'wb');
if ($fp === false)
{
die("open file \"$local_filename\" to write fail");
}
else
{
$result = storage_download_file_ex($this->tracker_server, $this->storage_server,
$this->group_name, $remote_filename, 'write_file_callback', $fp, $file_size);
if ($result == 0)
{
return $local_filename;
//echo "download file to file success, file size: $file_size\n ";
}
else
{
return $this->halt("storage_download_file_to_file fail, errno: $result\n");
}
fclose($fp);
}
}
/**
* 删除文件
*
* @param string $remote_filename 远程文件名
* @return bool
*/
public function delFile($remote_filename)
{
$result = storage_delete_file($this->tracker_server, $this->storage_server, $this->group_name, $remote_filename);
return ($result==0) ? true : false;
}
public function halt($msg)
{
echo "{$msg}";
return false;
}
public function disconnection()
{
fdfs_quit($this->tracker_server);
tracker_close_all_connections();
}
public function __destruct()
{
$this->disconnection();
}
}
function write_file_callback($arg, $file_size, $file_buff, $buff_bytes)
{
if (fwrite($arg, $file_buff, $buff_bytes) != $buff_bytes)
{
echo "in write_file_callback fwrite fail";
return FDFS_EIO;
}
return 0;
}
?>

复制代码

调用的例子：

<?php
require("FastDFS.php");
//download
echo FastDFS::factory('group1')->downToFile('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png', 'nginx.png'), " ";
echo FastDFS::factory('group1')->downToFileEx('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png'), " ";
echo FastDFS::factory('group1')->downToBuff('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png'), " ";
//delete
FastDFS::factory('group1')->delFile('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png');
//upload
echo FastDFS::factory('group1')->upByFileName('nginx.png'), " ";
echo FastDFS::factory('group1')->upByBuff( file_get_contents('nginx.png'), 'png' ), " ";
?>