fafs 的一个php class

vyouzhi

FDFD class for php

1. 
   
2. <?php
   
3. /*
   
4. copyright by vyouzhi
   
5. 2011 12 08
   
6. vyouzhi#163#com
   
7. QQ: 84437129
   
8. */
   
9. 
   
10. 
    
11. class FDFS{
    
12. 
    
13.     function FDFS(){
    
14.         $this->tracker = fastdfs_tracker_get_connection();
    
15.         $this->server = fastdfs_connect_server($this->tracker['ip_addr'], $this->tracker['port']);
    
16.         $this->storage = fastdfs_tracker_query_storage_store();
    
17. 
    
18.         $this->server = fastdfs_connect_server($this->storage['ip_addr'], $this->storage['port']);
    
19.         if (!$this->server){
    
20.             error_log("errno1: " . fastdfs_get_last_error_no() . ", error info: " . fastdfs_get_last_error_info());
    
21.             exit(1);
    
22.         }
    
23. 
    
24.         $this->storage['sock'] = $this->server['sock'];
    
25. 
    
26.     }
    
27.    
    
28.    
    
29.     function fdfs_upload($input_name){
    
30.         $file_tmp = $_FILES[$input_name]['tmp_name'];
    
31.         $real_name = $_FILES[$input_name]['name'];
    
32.         $file_name = dirname($file_tmp)."/".$real_name;
    
33.         //@copy($file_tmp, $file_name);
    
34.         @rename($file_tmp, $file_name);
    
35. 
    
36.         $file_info = fastdfs_storage_upload_by_filename($file_name, null, array(), null, $this->tracker, $this->storage);
    
37.    
    
38.         if($file_info){
    
39.             $group_name = $file_info['group_name'];
    
40.             $remote_filename = $file_info['filename'];
    
41. 
    
42.             $i = fastdfs_get_file_info($group_name, $remote_filename);
    
43.             $storage_ip = $i['source_ip_addr'];
    
44.             //var_dump($file_info);
    
45.             return array($remote_filename, $group_name, $storage_ip, $real_name);
    
46.         }
    
47.         return false;
    
48.     }
    
49. 
    
50.     function fdfs_down($group_name, $file_id){
    
51.         $file_content = fastdfs_storage_download_file_to_buff($group_name, $file_id);
    
52.         return $file_content;
    
53.     }
    
54. 
    
55.     function fdfs_del($group_name, $file_id){
    
56.         fastdfs_storage_delete_file($group_name, $file_id);
    
57.     }
    
58. }
    
59. 
    
60. ?>
    
61. 
    

复制代码

mysql 的记录表

1. 
   
2. CREATE TABLE `fdfs` (
   
3. `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
   
4.   `file_id` char(100) NOT NULL DEFAULT '' COMMENT '文件ID',
   
5. `group_id` varchar(10) NOT NULL DEFAULT '' COMMENT '组名',
   
6. `real_name` varchar(100) NOT NULL COMMENT '真名',
   
7. `storage_ip` varchar(15) NOT NULL COMMENT 'ip',
   
8. PRIMARY KEY (`id`),
   
9. KEY `i_file_id` (`file_id`)
   
10. ) ENGINE=MyISAM  DEFAULT CHARSET=utf8
    

复制代码

使用样例

1. 
   
2. <?php
   
3. require_once("./bootstrap.php");
   
4. require_once("./fdfs.php");
   
5. 
   
6. 
   
7. if(!empty($_FILES['upload1'])){
   
8.     $fdfs_obj = new FDFS();
   
9.     $res = $fdfs_obj->fdfs_upload("upload1");
   
10.     $format = "INSERT INTO `%s`.`fdfs` (`file_id`, `group_id`, `storage_ip`, `real_name`) VALUES ('%s', '%s', '%s', '%s')";
    
11.     $sql = sprintf($format, "test", $res[0], $res[1], $res[2], $res[3]);
    
12.     MySQL::Insert($sql, GetPB("w"));
    
13. 
    
14. }else{
    
15.     $format = "SELECT * FROM `%s`.`fdfs` where id=4";
    
16.     $sql = sprintf($format, "test");
    
17.     $res = MySQL::FetchArray($sql, GetPB());
    
18.     if(is_array($res)){
    
19.         $fdfs_obj = new FDFS();
    
20.         /*
    
21.         $fdfs_obj->fdfs_del($res[0]['group_id'], $res[0]['file_id']);
    
22.         die();
    
23.         */
    
24.         $f = $fdfs_obj->fdfs_down($res[0]['group_id'], $res[0]['file_id']);
    
25.         file_put_contents("/tmp/".$res[0]['real_name'], $f);
    
26. 
    
27.         header('Content-Description: File Transfer');
    
28.         header('Content-Type: application/octet-stream');
    
29.         header('Content-Disposition: attachment; filename='.$res[0]['real_name']);
    
30.         header('Content-Transfer-Encoding: binary');
    
31.         header('Expires: 0');
    
32.         header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
    
33.         header('Pragma: public');
    
34.         header('Content-Length: ' . filesize("/tmp/".$res[0]['real_name']));
    
35.         ob_clean();
    
36.         flush();
    
37.         readfile("/tmp/".$res[0]['real_name']);
    
38.     }
    
39. }
    
40. 
    
41. ?>
    
42. 
    
43. <html>
    
44. <body>
    
45. <form action="./fdfs_class.php" method="post" enctype="multipart/form-data">
    
46.     <input type="text" name="myText" /><br />
    
47.     <input type="file" name="upload1" /><br />
    
48.     <input type="submit" />
    
49. </form>
    
50. </body>
    
51. </html>
    

复制代码