{"id":10020875,"date":"2025-07-03T22:15:38","date_gmt":"2025-07-03T14:15:38","guid":{"rendered":"https:\/\/itmax.cn\/?p=10020875"},"modified":"2025-07-03T22:15:38","modified_gmt":"2025-07-03T14:15:38","slug":"laravel-%e9%98%bf%e9%87%8c%e4%ba%91-oss-%e8%a7%86%e9%a2%91%e4%b8%8a%e4%bc%a0%e5%ae%8c%e6%95%b4%e6%96%b9%e6%a1%88","status":"publish","type":"post","link":"https:\/\/itmax.cn\/?p=10020875","title":{"rendered":"Laravel \u963f\u91cc\u4e91 OSS \u89c6\u9891\u4e0a\u4f20\u5b8c\u6574\u65b9\u6848"},"content":{"rendered":"

\u4e00\u3001\u73af\u5883\u51c6\u5907<\/h2>\n

1.1 \u5b89\u88c5 OSS SDK<\/h3>\n
composer require aliyuncs\/oss-sdk-php<\/code><\/pre>\n
1.2 \u73af\u5883\u914d\u7f6e<\/h3>\n
\u5728 .env<\/code> \u6587\u4ef6\u4e2d\u6dfb\u52a0\uff1a<\/p>\n
OSS_ACCESS_KEY_ID=\u4f60\u7684AccessKeyId\nOSS_ACCESS_KEY_SECRET=\u4f60\u7684AccessKeySecret\nOSS_ENDPOINT=oss-cn-hangzhou.aliyuncs.com\nOSS_BUCKET=\u4f60\u7684Bucket\u540d\u79f0\nOSS_IS_PRIVATE=false<\/code><\/pre>\n
1.3 \u521b\u5efa\u914d\u7f6e\u6587\u4ef6<\/h3>\n
\u521b\u5efa config\/oss.php<\/code>\uff1a<\/p>\n
<?php\nreturn [\n    'access_key_id' => env('OSS_ACCESS_KEY_ID'),\n    'access_key_secret' => env('OSS_ACCESS_KEY_SECRET'),\n    'endpoint' => env('OSS_ENDPOINT'),\n    'bucket' => env('OSS_BUCKET'),\n    'is_private' => env('OSS_IS_PRIVATE', false),\n];<\/code><\/pre>\n
\u4e8c\u3001\u5206\u7247\u4e0a\u4f20\u5927\u89c6\u9891<\/h2>\n
2.1 \u57fa\u7840\u5206\u7247\u4e0a\u4f20\u4ee3\u7801<\/h3>\n
<?php\nuse OSS\/OssClient;\nuse OSS\/Core\/OssException;\n\nclass VideoUploader\n{\n    private $ossClient;\n    private $bucket;\n\n    public function __construct()\n    {\n        $this->ossClient = new OssClient(\n            config('oss.access_key_id'),\n            config('oss.access_key_secret'),\n            config('oss.endpoint')\n        );\n        $this->bucket = config('oss.bucket');\n    }\n\n    \/**\n     * \u5206\u7247\u4e0a\u4f20\u89c6\u9891\u6587\u4ef6\n     *\/\n    public function multipartUpload($filePath, $objectName)\n    {\n        try {\n            \/\/ \u521d\u59cb\u5316\u5206\u7247\u4e0a\u4f20\n            $uploadId = $this->ossClient->initiateMultipartUpload($this->bucket, $objectName);\n\n            $partSize = 5 * 1024 * 1024; \/\/ \u6bcf\u72475MB\n            $uploadFileSize = filesize($filePath);\n            $pieces = $this->ossClient->generateMultiuploadParts($uploadFileSize, $partSize);\n            $uploadParts = [];\n\n            \/\/ \u9010\u4e2a\u4e0a\u4f20\u5206\u7247\n            foreach ($pieces as $i => $piece) {\n                $fromPos = $piece[$this->ossClient::OSS_SEEK_TO];\n                $toPos = $piece[$this->ossClient::OSS_LENGTH];\n                \n                $uploadPart = fopen($filePath, 'r');\n                fseek($uploadPart, $fromPos);\n                \n                $eTag = $this->ossClient->uploadPart($this->bucket, $objectName, $uploadId, [\n                    'partNumber' => ($i + 1),\n                    'uploadPart' => $uploadPart,\n                    'length' => $toPos,\n                ]);\n                \n                fclose($uploadPart);\n                \n                $uploadParts[] = [\n                    'PartNumber' => ($i + 1),\n                    'ETag' => $eTag,\n                ];\n            }\n\n            \/\/ \u5b8c\u6210\u5206\u7247\u4e0a\u4f20\n            $result = $this->ossClient->completeMultipartUpload(\n                $this->bucket, \n                $objectName, \n                $uploadId, \n                $uploadParts\n            );\n\n            return [\n                'success' => true,\n                'url' => $this->getPublicUrl($objectName),\n                'etag' => $result\n            ];\n\n        } catch (OssException $e) {\n            return [\n                'success' => false,\n                'error' => $e->getMessage()\n            ];\n        }\n    }\n\n    private function getPublicUrl($objectName)\n    {\n        return "https:\/\/{$this->bucket}." . config('oss.endpoint') . "\/{$objectName}";\n    }\n}<\/code><\/pre>\n
2.2 \u4f18\u5316\u7248\u672c\uff08\u5e26\u8fdb\u5ea6\u56de\u8c03\uff09<\/h3>\n
public function multipartUploadWithProgress($filePath, $objectName, $progressCallback = null)\n{\n    try {\n        $uploadId = $this->ossClient->initiateMultipartUpload($this->bucket, $objectName);\n        $partSize = 5 * 1024 * 1024;\n        $uploadFileSize = filesize($filePath);\n        $pieces = $this->ossClient->generateMultiuploadParts($uploadFileSize, $partSize);\n        $uploadParts = [];\n\n        foreach ($pieces as $i => $piece) {\n            $fromPos = $piece[$this->ossClient::OSS_SEEK_TO];\n            $toPos = $piece[$this->ossClient::OSS_LENGTH];\n            \n            $uploadPart = fopen($filePath, 'r');\n            fseek($uploadPart, $fromPos);\n            \n            $eTag = $this->ossClient->uploadPart($this->bucket, $objectName, $uploadId, [\n                'partNumber' => ($i + 1),\n                'uploadPart' => $uploadPart,\n                'length' => $toPos,\n            ]);\n            \n            fclose($uploadPart);\n            \n            $uploadParts[] = [\n                'PartNumber' => ($i + 1),\n                'ETag' => $eTag,\n            ];\n\n            \/\/ \u8fdb\u5ea6\u56de\u8c03\n            if ($progressCallback) {\n                $progress = round(($i + 1) \/ count($pieces) * 100, 2);\n                call_user_func($progressCallback, $progress, $i + 1, count($pieces));\n            }\n        }\n\n        $result = $this->ossClient->completeMultipartUpload(\n            $this->bucket, \n            $objectName, \n            $uploadId, \n            $uploadParts\n        );\n\n        return ['success' => true, 'url' => $this->getPublicUrl($objectName), 'etag' => $result];\n\n    } catch (OssException $e) {\n        return ['success' => false, 'error' => $e->getMessage()];\n    }\n}<\/code><\/pre>\n
\u4e09\u3001\u89c6\u9891\u622a\u56fe\u529f\u80fd<\/h2>\n
3.1 \u751f\u6210\u7b2c\u4e00\u5e27\u622a\u56fe<\/h3>\n
\/**\n * \u83b7\u53d6\u89c6\u9891\u7b2c\u4e00\u5e27\u622a\u56fe\n *\/\npublic function getVideoSnapshot($objectName, $width = 800, $height = 600, $time = 0)\n{\n    $process = "video\/snapshot,t_{$time},f_jpg,w_{$width},h_{$height},m_fast";\n    \n    \/\/ \u516c\u5171\u8bfb\u53d6\u7684 Bucket\n    if (!config('oss.is_private')) {\n        $endpoint = config('oss.endpoint');\n        return "https:\/\/{$this->bucket}.{$endpoint}\/{$objectName}?x-oss-process={$process}";\n    }\n    \n    \/\/ \u79c1\u6709 Bucket\uff0c\u9700\u8981\u7b7e\u540d\n    return $this->ossClient->signUrl($this->bucket, $objectName, 3600, 'GET', [\n        'x-oss-process' => $process\n    ]);\n}<\/code><\/pre>\n
3.2 \u591a\u79cd\u622a\u56fe\u53c2\u6570<\/h3>\n
\/**\n * \u751f\u6210\u591a\u79cd\u89c4\u683c\u7684\u622a\u56fe\n *\/\npublic function generateMultipleSnapshots($objectName, $configs = [])\n{\n    $defaultConfigs = [\n        'thumbnail' => ['width' => 200, 'height' => 150, 'time' => 0],\n        'medium' => ['width' => 600, 'height' => 400, 'time' => 0],\n        'large' => ['width' => 1200, 'height' => 800, 'time' => 0],\n    ];\n    \n    $configs = array_merge($defaultConfigs, $configs);\n    $snapshots = [];\n    \n    foreach ($configs as $name => $config) {\n        $snapshots[$name] = $this->getVideoSnapshot(\n            $objectName,\n            $config['width'],\n            $config['height'],\n            $config['time']\n        );\n    }\n    \n    return $snapshots;\n}<\/code><\/pre>\n
\u56db\u3001\u63a7\u5236\u5668\u5b9e\u73b0<\/h2>\n
4.1 \u89c6\u9891\u4e0a\u4f20\u63a7\u5236\u5668<\/h3>\n
<?php\nnamespace App\/Http\/Controllers;\n\nuse Illuminate\/Http\/Request;\nuse Illuminate\/Http\/JsonResponse;\nuse Illuminate\/Support\/Str;\n\nclass VideoController extends Controller\n{\n    protected $videoUploader;\n\n    public function __construct()\n    {\n        $this->videoUploader = new VideoUploader();\n    }\n\n    \/**\n     * \u4e0a\u4f20\u89c6\u9891\n     *\/\n    public function upload(Request $request): JsonResponse\n    {\n        $request->validate([\n            'video' => 'required|file|mimes:mp4,avi,mov,wmv,flv,webm|max:2048000' \/\/ \u6700\u59272GB\n        ]);\n\n        $file = $request->file('video');\n        $extension = $file->getClientOriginalExtension();\n        \n        \/\/ \u751f\u6210\u5b58\u50a8\u8def\u5f84\n        $objectName = 'videos\/' . date('Y\/m\/d\/') . Str::uuid() . '.' . $extension;\n\n        \/\/ \u6267\u884c\u4e0a\u4f20\n        $result = $this->videoUploader->multipartUpload($file->getRealPath(), $objectName);\n\n        if ($result['success']) {\n            \/\/ \u751f\u6210\u622a\u56fe\n            $snapshotUrl = $this->videoUploader->getVideoSnapshot($objectName);\n            \n            return response()->json([\n                'success' => true,\n                'data' => [\n                    'url' => $result['url'],\n                    'object_name' => $objectName,\n                    'snapshot_url' => $snapshotUrl,\n                    'size' => $file->getSize(),\n                ]\n            ]);\n        }\n\n        return response()->json([\n            'success' => false,\n            'message' => $result['error']\n        ], 500);\n    }\n\n    \/**\n     * \u83b7\u53d6\u89c6\u9891\u622a\u56fe\n     *\/\n    public function getSnapshot(Request $request): JsonResponse\n    {\n        $request->validate([\n            'object_name' => 'required|string',\n            'width' => 'integer|min:100|max:1920',\n            'height' => 'integer|min:100|max:1080',\n            'time' => 'integer|min:0',\n        ]);\n\n        $objectName = $request->input('object_name');\n        $width = $request->input('width', 800);\n        $height = $request->input('height', 600);\n        $time = $request->input('time', 0);\n\n        $snapshotUrl = $this->videoUploader->getVideoSnapshot($objectName, $width, $height, $time);\n\n        return response()->json([\n            'success' => true,\n            'data' => ['snapshot_url' => $snapshotUrl]\n        ]);\n    }\n}<\/code><\/pre>\n
\u4e94\u3001\u8def\u7531\u914d\u7f6e<\/h2>\n
5.1 API \u8def\u7531<\/h3>\n
\u5728 routes\/api.php<\/code> \u4e2d\u6dfb\u52a0\uff1a<\/p>\n
Route::prefix('video')->group(function () {\n    Route::post('upload', [VideoController::class, 'upload']);\n    Route::post('snapshot', [VideoController::class, 'getSnapshot']);\n});<\/code><\/pre>\n
\u516d\u3001\u524d\u7aef\u8c03\u7528\u793a\u4f8b<\/h2>\n
6.1 JavaScript \u4e0a\u4f20<\/h3>\n
\/\/ \u4e0a\u4f20\u89c6\u9891\nasync function uploadVideo(file) {\n    const formData = new FormData();\n    formData.append('video', file);\n\n    try {\n        const response = await fetch('\/api\/video\/upload', {\n            method: 'POST',\n            body: formData,\n            headers: {\n                'X-CSRF-TOKEN': document.querySelector('meta[name="csrf-token"]').getAttribute('content')\n            }\n        });\n\n        const result = await response.json();\n        \n        if (result.success) {\n            console.log('\u4e0a\u4f20\u6210\u529f:', result.data);\n            \/\/ \u663e\u793a\u89c6\u9891\u548c\u622a\u56fe\n            showVideo(result.data.url, result.data.snapshot_url);\n        } else {\n            console.error('\u4e0a\u4f20\u5931\u8d25:', result.message);\n        }\n    } catch (error) {\n        console.error('\u4e0a\u4f20\u9519\u8bef:', error);\n    }\n}\n\n\/\/ \u663e\u793a\u89c6\u9891\nfunction showVideo(videoUrl, snapshotUrl) {\n    const videoHtml = `\n        <video controls poster="${snapshotUrl}">\n            <source src="${videoUrl}" type="video\/mp4">\n        <\/video>\n        <img src="${snapshotUrl}" alt="\u89c6\u9891\u622a\u56fe" \/>\n    `;\n    document.getElementById('video-container').innerHTML = videoHtml;\n}<\/code><\/pre>\n
6.2 \u5e26\u8fdb\u5ea6\u6761\u7684\u4e0a\u4f20<\/h3>\n
function uploadVideoWithProgress(file, progressCallback) {\n    const formData = new FormData();\n    formData.append('video', file);\n\n    const xhr = new XMLHttpRequest();\n    \n    \/\/ \u76d1\u542c\u4e0a\u4f20\u8fdb\u5ea6\n    xhr.upload.addEventListener('progress', (e) => {\n        if (e.lengthComputable) {\n            const progress = (e.loaded \/ e.total) * 100;\n            progressCallback(Math.round(progress));\n        }\n    });\n\n    xhr.addEventListener('load', () => {\n        if (xhr.status === 200) {\n            const result = JSON.parse(xhr.responseText);\n            console.log('\u4e0a\u4f20\u5b8c\u6210:', result);\n        }\n    });\n\n    xhr.open('POST', '\/api\/video\/upload');\n    xhr.setRequestHeader('X-CSRF-TOKEN', document.querySelector('meta[name="csrf-token"]').getAttribute('content'));\n    xhr.send(formData);\n}<\/code><\/pre>\n
\u4e03\u3001\u6700\u4f73\u5b9e\u8df5<\/h2>\n
7.1 \u9519\u8bef\u5904\u7406<\/h3>\n
try {\n    $result = $this->videoUploader->multipartUpload($filePath, $objectName);\n} catch (Exception $e) {\n    Log::error('\u89c6\u9891\u4e0a\u4f20\u5931\u8d25', [\n        'file' => $objectName,\n        'error' => $e->getMessage(),\n        'trace' => $e->getTraceAsString()\n    ]);\n    \n    return response()->json([\n        'success' => false,\n        'message' => '\u4e0a\u4f20\u5931\u8d25\uff0c\u8bf7\u7a0d\u540e\u91cd\u8bd5'\n    ], 500);\n}<\/code><\/pre>\n
7.2 \u6587\u4ef6\u9a8c\u8bc1<\/h3>\n
public function validateVideoFile($file)\n{\n    $allowedMimes = ['video\/mp4', 'video\/avi', 'video\/mov', 'video\/wmv'];\n    $maxSize = 2 * 1024 * 1024 * 1024; \/\/ 2GB\n\n    if (!in_array($file->getMimeType(), $allowedMimes)) {\n        throw new InvalidArgumentException('\u4e0d\u652f\u6301\u7684\u89c6\u9891\u683c\u5f0f');\n    }\n\n    if ($file->getSize() > $maxSize) {\n        throw new InvalidArgumentException('\u6587\u4ef6\u5927\u5c0f\u8d85\u8fc7\u9650\u5236');\n    }\n\n    return true;\n}<\/code><\/pre>\n
7.3 \u6027\u80fd\u4f18\u5316<\/h3>\n