feat: 实现断点续传 API

Author: sabakugaara

src/Upyun/Uploader.php

@@ -22,16 +22,84 @@ public function upload($path, $file, $params) {
         $stream = Psr7\stream_for($file);
         $size = $stream->getSize();
         $useBlock = $this->needUseBlock($size);
+
         if(! $useBlock) {
             $req = new Rest($this->config);
             return $req->request('PUT', $path)
                        ->withHeaders($params)
                        ->withFile($stream)
                        ->send();
         } else {
-            $req = new Multi($this->config);
-            return $req->upload($path, $stream, Util::md5Hash($file), $params);
+            return $this->pointUpload($path, $stream, $params);
+            /**
+             * 也可以使用分块上传替代, 不推荐使用
+             */
+            //$req = new Multi($this->config);
+            //return $req->upload($path, $stream, Util::md5Hash($file), $params);
+        }
+    }
+
+    /**
+     *  断点续传
+     * @param $path
+     * @param $stream
+     * @param $params
+     *
+     * @return mixed|\Psr\Http\Message\ResponseInterface
+     * @throws \Exception
+     */
+    private function pointUpload($path, $stream, $params) {
+        $req = new Rest($this->config);
+        $headers = array();
+        if (is_array($params)) {
+            foreach($params as $key => $val) {
+                $headers['X-Upyun-Meta-' . $key] = $val;
+            }
+        }
+        $res = $req->request('PUT', $path)
+            ->withHeaders(array_merge(array(
+                'X-Upyun-Multi-Stage' => 'initiate',
+                'X-Upyun-Multi-Type' => Psr7\mimetype_from_filename($path),
+                'X-Upyun-Multi-Length' => $stream->getSize(),
+            ), $headers))
+            ->send();
+        if ($res->getStatusCode() !== 204) {
+            throw new \Exception('init request failed when poinit upload!');
+        }
+
+        $init      = Util::getHeaderParams($res->getHeaders());
+        $uuid      = $init['x-upyun-multi-uuid'];
+        $blockSize = 1024 * 1024;
+        $partId    = 0;
+        do {
+            $fileBlock = $stream->read($blockSize);
+            $res = $req->request('PUT', $path)
+                ->withHeaders(array(
+                    'X-Upyun-Multi-Stage' => 'upload',
+                    'X-Upyun-Multi-Uuid' => $uuid,
+                    'X-Upyun-Part-Id' => $partId
+                ))
+                ->withFile(Psr7\stream_for($fileBlock))
+                ->send();
+
+            if ($res->getStatusCode() !== 204) {
+                throw new \Exception('upload request failed when poinit upload!');
+            }
+            $data   = Util::getHeaderParams($res->getHeaders());
+            $partId = $data['x-upyun-next-part-id'];
+        } while($partId != -1);
+
+        $res = $req->request('PUT', $path)
+            ->withHeaders(array(
+                'X-Upyun-Multi-Uuid' => $uuid,
+                'X-Upyun-Multi-Stage' => 'complete'
+            ))
+            ->send();
+
+        if ($res->getStatusCode() != 204 && $res->getStatusCode() != 201) {
+            throw new \Exception('end request failed when poinit upload!');
         }
+        return $res;
     }
 
     private function needUseBlock($fileSize) {

src/Upyun/Util.php

@@ -13,6 +13,7 @@ public static function trim($str) {
     public static function getHeaderParams($headers) {
         $params = [];
         foreach ($headers as $header => $value) {
+            $header = strtolower($header);
             if(strpos($header, 'x-upyun-') !== false) {
                 $params[$header] = $value[0];
             }