做了个 PHP 客户端包装类

Question

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

2. <?php
3. require 'fdfs_common.php';
4. require 'fdfs_tracker_client.php';
5. require 'fdfs_storage_client.php';
7. class FastDFS
8. {
9.         private $tracker_server;
10.         private $storage_server;
11.         private $group_name;
12.        
13.         public function factory($group_name)
14.         {
15.                 static $obj;
16.                
17.                 if(!$obj)
18.                         $obj = new FastDFS($group_name);
19.                        
20.                 return $obj;
21.         }
22.        
23.         public function __construct($group_name)
24.         {
25.                 $this->storage_server = null;
26.                 $this->group_name = $group_name;
27.                
28.                 $this->connection();
29.         }
30.        
31.         public function connection()
32.         {
33.                 $tracker_server = tracker_get_connection();
34.                 if ($tracker_server == false)
35.                 {
36.                         return $this->halt("tracker_get_connection fail\n");
37.                 }
38.                
39.                 $this->tracker_server = $tracker_server;
40.         }
41.        
42.         /**
43.          * 根据文件名上传
44.          *
45.          * @param string $local_filename
46.          * @param array $meta_list
47.          * @return remote filename
48.          */
49.         public function upByFileName($local_filename, $meta_list=array())
50.         {
51.                 //$local_filename = 'nginx-logo.png';
52.                 //$group_name = '';   //you can specify the group to upload file to
53.                 //$meta_list = array('width' => 1024, 'height' => 768, 'color' => '#c0c0c0');
54.                
55.                 $result = storage_upload_by_filename($this->tracker_server, $this->storage_server,
56.                                         $local_filename, $meta_list,
57.                                         $this->group_name, $remote_filename);
58.                 if ($result == 0)
59.                 {
60.                         //echo "group_name=$group_name, remote_filename=$remote_filename\n";
61.                         return $remote_filename;
62.                 }
63.                 else
64.                 {
65.                         return $this->halt("storage_upload_by_filename fail, result=$result\n");
66.                 }
67.         }
68.        
69.         /**
70.          * 把文件 buff 上传
71.          *
72.          * @param string $file_buff
73.          * @param string $file_ext
74.          * @param array $meta_list
75.          * @return remote filename
76.          */
77.         public function upByBuff($file_buff, $file_ext, $meta_list=array())
78.         {
79.                 if ($file_buff != false)
80.                 {
81.                         $file_size = strlen($file_buff);
82.                         //$group_name = '';  //you can specify the group to upload file to
83.                         $result = storage_upload_by_filebuff($this->tracker_server, $this->storage_server,
84.                                 $file_buff, $file_size, $file_ext, $meta_list,
85.                                 $this->group_name, $remote_filename);
86.                        
87.                         if ($result == 0)
88.                         {
89.                                 //echo "group_name=$group_name, remote_filename=$remote_filename\n";
90.                                 return $remote_filename;
91.                         }
92.                         else
93.                         {
94.                                 return $this->halt("storage_upload_by_filename fail, result=$result\n");
95.                         }
96.                 }
97.         }
98.        
99.         /**
100.          * 下载到本地文件
101.          *
102.          * @param string $remote_filename 远程文件名
103.          * @param string $local_filename 本地文件名
104.          * @return bool
105.          */
106.         public function downToFile($remote_filename, $local_filename)
107.         {
108.                 //$remote_filename = 'M00/00/00/fWaowEoaQj8AAFMnYnV13w36.php';
110.                 $result = tracker_query_storage_fetch($this->tracker_server, $this->storage_server,
111.                                 $this->group_name, $remote_filename);
112.                 if ($result == 0)
113.                 {
114.                         //echo "storage server ${storage_server['ip_addr']}:${storage_server['port']}\n <br />";
115.                 }
116.                 else
117.                 {
118.                         return $this->halt("tracker_query_storage_fetch fail, errno: $result\n");
119.                 }
120.                
121.                 $result = storage_download_file_to_file($this->tracker_server, $this->storage_server,
122.                                 $this->group_name, $remote_filename, $local_filename, $file_size);
123.                 if ($result == 0)
124.                 {
125.                         //echo "download file to file success, file size: $file_size\n <br />";
126.                         return true;
127.                 }
128.                 else
129.                 {
130.                         return $this->halt("storage_download_file_to_file fail, errno: $result\n");
131.                 }
132.         }
133.        
134.         /**
135.          * 下载到 buff
136.          *
137.          * @param string $remote_filename 远程文件名
138.          * @return file name
139.          */
140.         public function downToBuff($remote_filename)
141.         {
142.                 $result = storage_download_file_to_buff($this->tracker_server, $this->storage_server,
143.                 $this->group_name, $remote_filename, $file_buff, $file_size);
144.                 if ($result == 0)
145.                 {
146.                         //echo "download file to buff success, file size: $file_size" . ", buff size:" . strlen($file_buff) . "\n <br />";
147.                         $fname = str_replace('/', '_', $remote_filename);
148.                         file_put_contents($fname, $file_buff);
149.                         return $fname;
150.                 }
151.                 else
152.                 {
153.                         return $this->halt("storage_download_file_to_buff fail, errno: $result\n");
154.                 }
155.         }
156.        
157.         public function downToFileEx($remote_filename)
158.         {
159.                 $local_filename = str_replace('/', '-', $remote_filename);
160.                 $fp = fopen($local_filename, 'wb');
161.                 if ($fp === false)
162.                 {
163.                         die("open file \"$local_filename\" to write fail");
164.                 }
165.                 else
166.                 {
167.                         $result = storage_download_file_ex($this->tracker_server, $this->storage_server,
168.                                 $this->group_name, $remote_filename, 'write_file_callback', $fp, $file_size);
169.                         if ($result == 0)
170.                         {
171.                                 return $local_filename;
172.                                 //echo "download file to file success, file size: $file_size\n <br />";
173.                         }
174.                         else
175.                         {
176.                                 return $this->halt("storage_download_file_to_file fail, errno: $result\n");
177.                         }
178.                         fclose($fp);
179.                 }
180.         }
181.        
182.         /**
183.          * 删除文件
184.          *
185.          * @param string $remote_filename 远程文件名
186.          * @return bool
187.          */
188.         public function delFile($remote_filename)
189.         {
190.                 $result = storage_delete_file($this->tracker_server, $this->storage_server, $this->group_name, $remote_filename);
191.                
192.                 return ($result==0) ? true : false;
193.         }
194.        
195.        
196.         public function halt($msg)
197.         {
198.                 echo "<p>{$msg}</p>";
199.                 return false;
200.         }
201.        
202.         public function disconnection()
203.         {
204.                 fdfs_quit($this->tracker_server);
205.                 tracker_close_all_connections();
206.         }
207.        
208.         public function __destruct()
209.         {
210.                 $this->disconnection();
211.         }
212.        
213. }
217. function write_file_callback($arg, $file_size, $file_buff, $buff_bytes)
218. {
219.         if (fwrite($arg, $file_buff, $buff_bytes) != $buff_bytes)
220.         {
221.                 echo "in write_file_callback fwrite fail";
222.                 return FDFS_EIO;
223.         }
224.        
225.         return 0;
226. }
227. ?>

复制代码

调用的例子：

2. <?php
3. require("FastDFS.php");
5. //download
6. echo FastDFS::factory('group1')->downToFile('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png', 'nginx.png'), "<br />";
7. echo FastDFS::factory('group1')->downToFileEx('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png'), "<br />";
8. echo FastDFS::factory('group1')->downToBuff('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png'), "<br />";
10. //delete
11. FastDFS::factory('group1')->delFile('M00/00/00/fWaowEoaUtwAADwWZmBRJw73.png');
13. //upload
14. echo FastDFS::factory('group1')->upByFileName('nginx.png'), "<br />";
15. echo FastDFS::factory('group1')->upByBuff( file_get_contents('nginx.png'), 'png' ), "<br />";
17. ?>

复制代码

Answer 1

不错，顶一个！

Answer 2

那是相当的不错呀。

Answer 3

不错，学习~~~~~

Answer 4

谢谢，不过还不是很熟悉这个……

Answer 5

require 'fdfs_common.php';

require 'fdfs_tracker_client.php';

require 'fdfs_storage_client.php';

这三个文件当前目录下面没有

Answer 6

那是很老的版本了，最开始直接用纯php实现的php client API。
FastDFS从v1.19以后改成了php扩展模块方式，更加简洁高效！