xiaoben-as2-php/protected/components/FDFS.php

<?php
/**
 * Created by 上海互教教育科技有限公司.
 * User: 刘红伟
 * Date: 2016/7/20
 * Email: 454303753@qq.com
 * File:FDFS.php
 * copy:http://wangying.sinaapp.com/archives/586
 */
class FDFS
{
    static $_instance;		//单例
    private	$_fdfs;			//FastDFS 类对象
    private	$tracker_host;	//tracker ip_addr
    private	$tracker_port;	//tracker port
    private	$group = null;	//storage中的组名,可以为空
    private	$tracker;		//type:array 客户端连接跟踪器(tracker)返回的tracker服务端相关信息
    private	$storage;		//type:array 客户端连接存储节点(storage)返回的storage服务端相关信息
    private	$debug = true; //错误控制false/true
    /*
    localfile	本地文件
    group		组名
    remotefile 、 masterfile	远程文件(服务器上的文件)
    file_id	、 masterfile_id	文件id : file_id(masterfile_id)= group/remotefile(或masterfile)
    $prefixname	从文件的标识
    file_ext	文件的后缀名,不包含点'.'
    meta		文件属性列表，可以包含多个键值对
    */
    /**
     * 构造方法
     */
    private	function __construct($config)
    {

        if (!extension_loaded('fastdfs_client')){
            Yii::log('系统未安装FastDFS扩展','error');
            die('系统未安装FastDFS扩展');

        }
        foreach	($config as	$key =>	$val){
            $this->$key	= $val;
        }
        $this->_fdfs = new FastDFS();
        $this->tracker = $this->_fdfs->connect_server($this->tracker_host,$this->tracker_port);
        if(is_array($this->tracker)	&& $this->group){
            $this->storage = $this->_fdfs->tracker_query_storage_store($this->group, $this->tracker);
            if(!is_array($this->storage)){
                $this->halt();
            }
        }else{
            if(!is_array($this->tracker)) $this->halt();
        }
    }
    public static function getInstance($config)	{
        if(	! (self::$_instance	instanceof self) ) {
            self::$_instance = new self($config);
        }
        return self::$_instance;
    }
    private	function  __clone(){}

    /**文件上传**/
    /**
     * 上传文件
     * @param	(string)$localfile
    本地文件(若文件为完整文件名+后缀的形式，$file_ext可以为空)
     * @param	(string)$group		 文件组名
     * @param	(array)	$file_ext	 文件的后缀名,不包含点'.'(例：'png')
     * @param	(array)	$meta
    文件的附加信息,数组格式,array('hight'=>'350px');
     * @return	 Array	$file_info
    返回包含文件组名和文件名的数组,array('group_name'=>'ab','localfile'=>'kajdsf');
     */
    public function	upload_filename($localfile,	$group = null,$file_ext	= null,	$meta =	array())
    {
        $bool =	$this->check_string($localfile);
        if(!$bool)	return false;
        $file_info = $this->_fdfs->storage_upload_by_filename($localfile,$file_ext,$meta,$group,$this->tracker);
        if($file_info){
            return	$file_info;
        }else{
            $this->halt();
        }
    }
    /**
     * 上传文件
     * @param	(string)$localfile	  文件存放位置(若文件为完整文件名+后缀的形式，$file_ext可以为空)
     * @param	(string)$group		 文件组名
     * @param	(array)	$file_ext	 文件的后缀名,不包含点'.'
     * @param	(array)	$meta		 文件的附加信息,数组格式,array('hight'=>'350px','author'=>'bobo');
     * @return	 string				 返回file_id(文件组名/文件名)
     */
    public function	upload_filename1($localfile, $group	= null,$file_ext = null, $meta = array())
    {
        $bool =	$this->check_string($localfile);
        if(!$bool)	return false;
        $file_id = $this->_fdfs->storage_upload_by_filename1($localfile,$file_ext,$meta,$group,$this->tracker);
        if($file_id){
            return	$file_id;
        }else{
            $this->halt();
        }
    }
    /**
     * 上传从文件
     * @param	(string)$localfile			从文件名
     * @param	(string)$group				主文件组名
     * @param	(string)$masterfile			主文件名
     * @param	(string)$prefixname			从文件的标识符;	例如,主文件为abc.jpg,从文件需要大图,添加'_b',则$prefixname = '_b';
     * @param	(string)$file_ext			从文件后缀名
     * @param	(array)$meta			文件的附加信息,数组格式,array('hight'=>'350px','author'=>'bobo');
     * @return	 Array			  返回包含文件组名和文件名的数组,array('group_name'=>'ab','localfile'=>'kajdsf');
     */
    public function	upload_slave_filename($localfile, $group, $masterfile,$prefixname,$file_ext=null,$meta=array())
    {
        $bool =	$this->check_string($localfile,$group,$masterfile,$prefixname);
        if(!$bool)	return false;
        if(!$file_ext) $file_ext=null;
        $file_info = $this->_fdfs->storage_upload_slave_by_filename($localfile,$group,$masterfile,$prefixname,$file_ext,$meta,$this->tracker);
        if($file_info){
            return $file_info;
        }else{
            $this->halt();
        }
    }
    /**
     * 上传从文件
     * @param	(string)$localfile		  从文件名
     * @param	(string)$masterfile_id	主文件file_id
     * @param	(string)$prefixname		 从文件的标识符; 例如,主文件为abc.jpg,从文件需要大图,添加'_b',则$prefixname	= '_b';
     * @param	(string)$file_ext		 从文件后缀名
     * @param	(array)$meta			文件的附加信息,数组格式,array('hight'=>'350px','author'=>'bobo');
     * @return	 Array			  返回包含文件组名和文件名的数组,array('group_name'=>'ab','localfile'=>'kajdsf');
     */
    public function	upload_slave_filename1($localfile,$masterfile_id,$prefixname,$file_ext=null,$meta=array())
    {
        $bool =	$this->check_string($localfile,$masterfile_id,$prefixname);
        if(!$bool)	return false;
        if(!$file_ext) $file_ext=null;
        $file_id = $this->_fdfs->storage_upload_slave_by_filename1($localfile,$masterfile_id,$prefixname,$file_ext,$meta,$this->tracker);
        if($file_id){
            return $file_id;
        }else{
            $this->halt();
        }
    }
    /**
     * 上传文件,通过文件流的方式（未测试）
     * @param	$filebuff			 文件流
     * @param	(string)$file_ext	 文件的后缀名,不包含点'.'
     * @param	(array)	$meta	  文件的附加信息,数组格式,array('hight'=>'350px','author'=>'bobo');
     * @param	(string)$group		 文件组名
     * @return	 Array				 返回包含文件组名和文件名的数组,array('group_name'=>'ab','filename'=>'kajdsf');
     */
    public function	upload_filebuff($filebuff,$file_ext,$group = null,$meta	= array())
    {
        $bool =	$this->check_string($filebuff,$file_ext);
        if(!$bool)	return false;
        $file_info = $this->_fdfs->storage_upload_by_filebuff($filebuff,$file_ext,$meta,$group,$this->tracker);
        if($file_info){
            return $file_info;
        }else{
            $this->halt();
        }
    }
    /**
     * 上传从文件,通过文件流的方式（未测试）
     * @param	$filebuff			 文件流
     * @param	(string)$file_ext	 文件的后缀名,不包含点'.'
     * @param	(array)	$meta	  文件的附加信息,数组格式,array('hight'=>'350px','author'=>'bobo');
     * @param	(string)$group		 文件组名
     * @return	 Array				 返回包含文件组名和文件名的数组,array('group_name'=>'ab','filename'=>'kajdsf');
     */
    public function	upload_slave_filebuff($filebuff,$group,$masterfile,$prefix_name=null,$file_ext=null,$meta =	array())
    {
        $bool =	$this->check_string($filebuff,$group,$masterfile);
        if(!$bool)	return false;
        $file_info = $this->_fdfs->storage_upload_slave_by_filebuff($filebuff,$group,$masterfile,$prefix_name,$file_ext,$meta,$this->tracker);
        if($file_info){
            return $file_info;
        }else{
            $this->halt();
        }
    }

    /**文件删除**/
    /**
     * 删除文件
     * @param	(string)$group		 文件组名
     * @param	(string)$remotefile	 文件名
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	  扩展后缀名
     * @return	bool		成功返回true,失败返回false;
     */
    public function	delete_filename($group,$remotefile,$prefix=null,$file_ext=null)
    {
        $bool =	$this->check_string($group,$remotefile);
        if(!$bool)	return false;
        if ($prefix) {
            $remotefile	= $this->get_slave_filename($remotefile,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_delete_file($group, $remotefile, $this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**
     * 删除文件
     * @param	(string)masterfile_id  文件id
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	  扩展后缀名
     * @return	bool		成功返回true,失败返回false;
     */
    public function	delete_filename1($masterfile_id,$prefix=null,$file_ext=null)
    {
        $bool =	$this->check_string($masterfile_id);
        if(!$bool)	return false;
        if ($prefix) {
            $masterfile_id = $this->get_slave_filename($masterfile_id,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_delete_file1($masterfile_id, $this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**文件下载**/
    /**
     * 下载文件到本地服务器
     * @param	(string)$group		 文件组名
     * @param	(string)$remotefile	   文件名
     * @param	(string)$localfile	 本地文件名
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	  扩展后缀名
     * @param	$file_offset  //file start offset, default value is	0
     * @param	$download_bytes	//0	(default value)	means from the file	offset to the file end
     * @return	bool			成功返回true,失败返回false
     */
    public function	download_filename($group,$remotefile,$localfile,$prefix=null,$file_ext=null,$file_offset=0,$download_bytes=0){
        $bool =	$this->check_string($group,$remotefile,$localfile);
        if(!$bool)	return false;
        if ($prefix) {
            $remotefile	= $this->get_slave_filename($remotefile,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_download_file_to_file($group,$remotefile,$localfile,$file_offset,$download_bytes,$this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**
     * 下载文件到本地服务器
     * @param	(string)$file_id	文件id
     * @param	(string)$localfile		本地文件名
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	  扩展后缀名
     * @param	$file_offset  //file start offset, default value is	0
     * @param	$download_bytes	//0	(default value)	means from the file	offset to the file end
     * @return	bool		   成功返回true,失败返回false
     */
    public function	download_filename1($file_id,$localfile,$prefix=null,$file_ext=null,$file_offset=0,$download_bytes=0)
    {
        $bool =	$this->check_string($file_id,$localfile);
        if(!$bool)	return false;
        if ($prefix) {
            $file_id = $this->get_slave_filename($file_id,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_download_file_to_file1($file_id, $localfile,$file_offset,$download_bytes,	$this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**
     * 下载文件流（未测试）
     * @param	(string)$group		  文件组名
     * @param	(string)$remotefile		文件名
     * @param	(string)$filename		主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	  扩展后缀名
     * @param	$file_offset  //file start offset, default value is	0
     * @param	$download_bytes	//0	(default value)	means from the file	offset to the file end
     * @return				  成功返回文件流,失败返回false
     */
    public function	download_filebuff($group,$remotefile,$file_offset=0,$download_bytes=0)
    {
        $bool =	$this->check_string($group,$remotefile);
        if(!$bool)	return false;
        $bool =	$this->_fdfs->storage_download_file_to_buff($group,$remotefile,$file_offset,$download_bytes,$this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**辅助方法--判断文件是否存在**/
    /**
     * 判断文件是否存在
     * @param	(string)$remotefile	 文件名
     * @param	(string)$group		 文件组名
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	 扩展后缀名
     * @return	 Bool
     */
    public function	file_exist($group, $remotefile,$prefix=null,$file_ext=null)
    {
        $bool =	$this->check_string($group,	$remotefile);
        if(!$bool)	return false;
        if ($prefix) {
            $remotefile	= $this->get_slave_filename($remotefile,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_file_exist($group, $remotefile,$this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**
     * 判断文件是否存在
     * @param	(string)$file_id	文件id
     * @param	(string)$filename	主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	扩展后缀名
     * @return	 Bool
     */
    public function	file_exist1($file_id,$prefix=null,$file_ext=null)
    {
        $bool =	$this->check_string($file_id);
        if(!$bool)	return false;
        if ($prefix) {
            $file_id = $this->get_slave_filename($file_id,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_file_exist1($file_id,$this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**辅助方法--根扩展后缀获取从文件名**/
    /**
     * 根据扩展后缀获取从文件名(masterfile或file_id 两种形式)
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	 扩展后缀名
     * @param	(string)$file_ext	   文件后缀名(这个后缀名替换掉原有文件后缀名)
     * @return	 string
     */
    public function	get_slave_filename($filename,$prefixname,$file_ext=null)
    {
        $bool =	$this->check_string($filename,$prefixname);
        if(!$bool)	return false;
        if(!$file_ext) $file_ext=null;
        $filename =	$this->_fdfs->gen_slave_filename($filename,$prefixname,$file_ext);
        if($filename){
            return $filename;
        }else{
            $this->halt();
        }
    }
    /**辅助方法--反解析远程文件名**/
    /**
     * 反解析远程文件名(只解析主文件名)
     * 通过此方法可以分析文件名的组成
     * @param	(string)$remotefile	 文件名
     * @param	(string)$group		 文件组名
     * @return	 array
    Array (	[create_timestamp] => 1346085049 [file_size] =>	1235 [source_ip_addr] => 192.168.127.6 [crc32] => -52246624	)
     */
    public function	get_file_info($group, $remotefile)
    {
        $bool =	$this->check_string($group,	$remotefile);
        if(!$bool)	return false;
        $res = $this->_fdfs->get_file_info($group, $remotefile);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 反解析远程文件名(只解析主文件名)
     * 通过此方法可以分析文件名的组成
     * @param	(string)$file_id	文件id
     * @return	 array
    Array (	[create_timestamp] => 1346085049 [file_size] =>	1235 [source_ip_addr] => 192.168.127.6 [crc32] => -52246624	)
     */
    public function	get_file_info1($file_id)
    {
        $bool =	$this->check_string($file_id);
        if(!$bool)	return false;
        $res = $this->_fdfs->get_file_info1($file_id);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**辅助方法--文件meta操作**/
    /**
     * 设置文件meta
     * @param	(string)$remotefile	 文件名
     * @param	(string)$group		 文件组名
     * @param	(array)$metadata	 meta信息
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	 扩展后缀名
     * @return	 bool
     */
    public function	set_metadata($group, $remotefile,$metadata,$prefix=null,$file_ext=null)
    {

        $bool =	$this->check_string($group,	$remotefile,$metadata);
        if(!$bool)	return false;
        if ($prefix) {
            $remotefile	= $this->get_slave_filename($remotefile,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_set_metadata($group, $remotefile,$metadata,FDFS_STORAGE_SET_METADATA_FLAG_OVERWRITE,$this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**
     * 设置文件meta
     * @param	(string)$file_id	文件id
     * @param	(array)$metadata	meta信息
     * @param	(string)$filename	主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	扩展后缀名
     * @return	 bool
     */
    public function	set_metadata1($file_id,$metadata,$prefix=null,$file_ext=null)
    {
        $bool =	$this->check_string($file_id,$metadata);
        if(!$bool)	return false;
        if ($prefix) {
            $file_id = $this->get_slave_filename($file_id,$prefix,$file_ext);
        }
        $bool =	$this->_fdfs->storage_set_metadata1($file_id,$metadata,FDFS_STORAGE_SET_METADATA_FLAG_MERGE,$this->tracker);
        if($bool){
            return true;
        }else{
            $this->halt();
        }
    }
    /**
     * 得到文件meta
     * @param	(string)$remotefile	 文件名
     * @param	(string)$group		 文件组名
     * @param	(string)$filename	 主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	 扩展后缀名
     * @return	array
     */
    public function	get_metadata($group, $remotefile,$prefix=null,$file_ext=null)
    {
        $bool =	$this->check_string($group,	$remotefile);
        if(!$bool)	return false;
        if ($prefix) {
            $remotefile	= $this->get_slave_filename($remotefile,$prefix,$file_ext);
        }
        $res = $this->_fdfs->storage_get_metadata($group, $remotefile,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 得到文件meta
     * @param	(string)$file_id	文件id
     * @param	(string)$filename	主文件名(masterfile或file_id 两种形式)
     * @param	(string)$prefixname	扩展后缀名
     * @return	array
     */
    public function	get_metadata1($file_id,$prefix=null,$file_ext=null)
    {
        $bool =	$this->check_string($file_id);
        if(!$bool)	return false;
        if ($prefix) {
            $file_id = $this->get_slave_filename($file_id,$prefix,$file_ext);
        }
        $res = $this->_fdfs->storage_get_metadata1($file_id,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**辅助方法--获取storage server信息**/
    /**
     * 获取一个$group内的所有server信息
     * @param	(string)$group		 文件组名
     * @return	 array
    Array (	[0]	=> Array ( [ip_addr] =>	192.168.127.13 [port] => 23000 [sock] => -1	[store_path_index] => 0	) [1] => Array ( [ip_addr] => 192.168.127.14 [port]	=> 23000 [sock]	=> -1 [store_path_index] =>	0 )	)
     */
    public function	get_storage_store_list($group)
    {
        $bool =	$this->check_string($group);
        if(!$bool)	return false;
        $res = $this->_fdfs->tracker_query_storage_store_list($group,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 获取一个$group内的所有server的状态信息
     * @param	(string/null)$group		  文件组名
     * @return	 array
     * @说明
     */
    public function	get_tracker_list_groups($group)
    {
        $bool =	$this->check_string($group);
        if(!$bool)	return false;
        $res = $this->_fdfs->tracker_list_groups($group,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 返回当前操作到$group/$remotefile资源的storage	server信息
     * @param	(string)$remotefile	   文件名
     * @param	(string)$group		 文件组名
     * @return	 array
    Array (	[0]	=> Array ( [ip_addr] =>	192.168.127.6 [port] =>	23000 [sock] =>	-1 ) )
     * @说明	一个group内如果存在多台storage,每台都存在'group/remotefile'相同资源,当下载或者获取数据时此方法返回的是正在操作的资源所在的storage service信息
     */
    public function	get_storage_fetch($group, $remotefile)
    {
        $bool =	$this->check_string($group,	$remotefile);
        if(!$bool)	return false;
        $res = $this->_fdfs->tracker_query_storage_fetch($group, $remotefile,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 返回当前操作到$group/$remotefile资源的storage	server信息
     * @param	(string)$file_id	文件id
     * @return	 array
    Array (	[0]	=> Array ( [ip_addr] =>	192.168.127.6 [port] =>	23000 [sock] =>	-1 ) )
     * @说明	一个group内如果存在多台storage,每台都存在'group/remotefile'相同资源,当下载或者获取数据时此方法返回的是正在操作的资源所在的storage service信息
     */
    public function	get_storage_fetch1($file_id)
    {
        $bool =	$this->check_string($file_id);
        if(!$bool)	return false;
        $res = $this->_fdfs->tracker_query_storage_fetch1($file_id,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 查找有$group/$remotefile资源的所有storage	server信息
     * @param	(string)$remotefile	   文件名
     * @param	(string)$group		 文件组名
     * @return	 array
    Array (	[0]	=> Array ( [ip_addr] =>	192.168.127.6 [port] =>	23000 [sock] =>	-1 ) )
     * @说明	一个group内如果存在多台storage,就会返回拥有上述资源的storage 数组信息
     */
    public function	get_storage_list($group, $remotefile)
    {
        $bool =	$this->check_string($group,	$remotefile);
        if(!$bool)	return false;
        $res = $this->_fdfs->tracker_query_storage_list($group,	$remotefile,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 查找有$file_id资源的所有storage server信息(返回值同上例)
     * @param	(string)$file_id	文件id
     * @return	 array
    Array (	[0]	=> Array ( [ip_addr] =>	192.168.127.6 [port] =>	23000 [sock] =>	-1 ) )
     * @说明	一个group内如果存在多台storage,就会返回拥有上述资源的storage 数组信息
     */
    public function	get_storage_list1($file_id)
    {
        $bool =	$this->check_string($file_id);
        if(!$bool)	return false;
        $res = $this->_fdfs->tracker_query_storage_list1($file_id,$this->tracker);
        if($res){
            return $res;
        }else{
            $this->halt();
        }
    }
    /**
     * 判断是否是有值的字符串
     * @param	(array)$arr_str
     * @return	 bool
     */
    public function	check_string()
    {
        $arr_str = func_get_args();
        foreach	($arr_str as $value)
        {
            if(empty($value))
            {
                return false;
            }
        }
        return true;
    }
    /**
     * 错误控制
     *
     */
    public function	halt($message=null)
    {
        if($this->debug){
            //调试模式下优雅输出错误信息
            $trace = debug_backtrace();

            $trace_string	 = '';
            foreach	($trace	as $key=>$t) {
                $trace_string .= '#'. $key . ' ' . $t['file'] .	'('. $t['line']	. ')' .	$t['class']	. $t['type'] . $t['function'] .'<br class="last">';
            }
            $errorinfo = $this->_fdfs->get_last_error_info();
            echo $errorinfo.''.$trace_string;
            Yii::log($errorinfo.''.$trace_string,'error');
            exit;
        }
        return false;
    }
    /**
     * 析构方法
     * 在对象被销毁前调用这个方法,对象属性所占用的内存并销毁对象相关的资源
     */
    public function	__destruct()
    {
        if(is_array($this->tracker)){
            $this->_fdfs->disconnect_server($this->tracker);
        }
    }
}