OSS文件上传与签名

相信大家日常开发中,经常使用到云文件的上传与下载等功能,而国内常用的阿里云和华为云,laravel自带的Storage默认并未进行友好支持。
刚好最近云迁移过程中的各种恶心,主要涉及上传与签名接口。特地记录下OSS云环境文件上传与签名的重点代码,以供参考。

相关包安装命令:

// 阿里云oss
composer require aliyuncs/oss-sdk-php
// 华为云obs
composer require obs/esdk-obs-php

需注意包版本,是否与php版本适用。

.env配置项:

# OSS相关配置
OSS_DRIVER=HW_OBS
#华为OBS
OSS_HW_ENDPOINT=https://obs.cn-east-3.myhuaweicloud.com
OSS_HW_KEY=ME0AVBTNJTSJB2LH0EGI
OSS_HW_SECRET=eCGffrwdx3Rt5QEmKbtEvruvGgg1mCUjMsnHfjWo
OSS_HW_BUCKET=pub-obs-test-1
#阿里云
OSS_ENDPOINT=https://oss-cn-hangzhou.aliyuncs.com
OSS_KEYID=LTAI4Ftno9DsfiVHADX73osa
OSS_KEYSECRET=vo9KuqgaDN727eOOz1tDg77Egeg7wE
OSS_BUCKET=xgimi-ipr

代码:

1.接口声明

<?php


namespace App\Service\OSS;


interface IOSS
{
    /**
     * 上传
     *
     * @param $fullFileName
     * @param $filePath
     * @return mixed
     */
    public function publicUpload($fullFileName, $filePath);

    /**
     * url验签、下载
     *
     * @param $fullFileName | 含前缀的完整url文件名
     * @param $expires      |   过期时效
     * @return mixed
     */
    public function getUrl($fullFileName, $expires);

    /**
     * 可替换url域名
     *
     * @param $url
     * @return mixed
     */
    public function replaceUrl($url);

}

2.阿里OSS实现

<?php


namespace App\Service\OSS;


use OSS\OssClient;

class AliOSS implements IOSS
{

    private $endPoint;

    private $keyId;

    private $secret;

    private $bucket;

    private $ossClient;

    private $expires = 3 * 24 * 3600;
    private $aliHost = '';
    private $myHost = '';

    public function __construct()
    {
        $this->endPoint = env("OSS_ENDPOINT");
        $this->keyId = env("OSS_KEYID");
        $this->secret = env("OSS_KEYSECRET");
        $this->bucket = env("OSS_BUCKET");

        try {
            $this->ossClient = new OssClient($this->keyId, $this->secret, $this->endPoint);
        } catch (\Exception $e) {
        }
    }


    /**
     * 上传
     *
     * @param $fullFileName
     * @param $filePath
     * @return mixed
     * @throws \Exception
     */
    public function publicUpload($fullFileName, $filePath)
    {
        return $this->ossClient->uploadFile($this->bucket, $fullFileName, $filePath);
    }

    /**
     * url验签、下载
     *
     * @param $fullFileName
     * @param $expires |   过期时效
     * @return mixed
     * @throws \Exception
     */
    public function getUrl($fullFileName, $expires)
    {
        $expires = $expires ? $expires : $this->expires;
        $signUrl = $this->ossClient->signUrl($this->bucket, $fullFileName, $expires);

        return $signUrl;
    }


    /**
     * 替换url域名
     *
     * @param $url
     * @return mixed
     */
    public function replaceUrl($url)
    {
        return str_replace($this->aliHost, $this->myHost, $url);
    }

}

3.华为OBS实现

<?php


namespace App\Service\OSS;


use Obs\ObsClient;

class HuaweiOBS implements IOSS
{

    private $endPoint;

    private $key;

    private $secret;

    private $bucket;

    private $obsClient;


    private $expires = 3 * 24 * 3600;
    private $hwHost = '';
    private $myHost = '';

    public function __construct()
    {
        $this->endPoint = env("OSS_HW_ENDPOINT");
        $this->key = env("OSS_HW_KEY");
        $this->secret = env("OSS_HW_SECRET");
        $this->bucket = env("OSS_HW_BUCKET");

        try {
            $this->obsClient = new ObsClient(['key' => $this->key, 'secret' => $this->secret, 'endpoint' => $this->endPoint]);
        } catch (\Exception $e) {
        }
    }

    /**
     * 上传
     *
     * @param $fullFileName
     * @param $filePath
     * @return mixed
     */
    public function publicUpload($fullFileName, $filePath)
    {
        $res = $this->obsClient->putObject([
            'Bucket' => $this->bucket,
            'Key' => $fullFileName,
            'SourceFile' => $filePath
        ]);

        return $res;
    }

    /**
     * url验签、下载
     *
     * @param $fullFileName
     * @param $expires |   过期时效
     * @return mixed
     * @throws \Exception
     */
    public function getUrl($fullFileName, $expires)
    {
        $expires = $expires ? $expires : $this->expires;
        // 生成下载对象的带授权信息的URL
        $res = $this->obsClient->createSignedUrl([
            'Method' => 'GET',
            'Bucket' => $this->bucket,
            'Key' => $fullFileName,
            'Expires' => $expires
        ]);

        return $res['SignedUrl'];
    }

    /**
     * 替换url域名
     *
     * @param $url
     * @return mixed
     */
    public function replaceUrl($url)
    {
        return str_replace($this->hwHost, $this->myHost, $url);
    }

}

Demo:业务逻辑 + OSS类

<?php

namespace App\Service;


class UploadFile
{

    /**
     * 文件上传 带签名访问
     *
     * @param        $files
     * @param string $prefix
     * @return array 
     * @throws \Exception
     */
    public static function upload($files, $prefix = '')
    {
        if (empty($files)) {
            return ['ok' => false, 'message' => '请上传文件!'];
        }
        if (is_array($files)) {
            $pics = [];
            foreach ($files as $key => $file) {
                if ($file->isValid()) {
                    $name = $file->getClientOriginalName();
                    $fullName = OSS::getFullFileName($name, $prefix);
                    $ret = OSS::publicUpload($fullName, $file, $prefix);
                    if ($ret) {
                        $url = OSS::getUrl($fullName);
                        $url = OSS::replaceUrl($url);
                        $pics[] = ['name' => $name, 'url' => $url, 'file_name' => $fullName];
                    }
                } else {
                    return ['ok' => false, 'message' => '无效文件!'];
                }
            }

            if (count($pics) > 0) {
                return ['ok' => true, 'data' => $pics];
            }
        } else {
            $name = $files->getClientOriginalName();
            $fullName = OSS::getFullFileName($name, $prefix);
            $ret = OSS::publicUpload($fullName, $files, $prefix);
            if ($ret) {
                $url = OSS::getUrl($fullName);
                $url = OSS::replaceUrl($url);
                return ['ok' => true, 'data' => ['name' => $name, 'url' => $url, 'file_name' => $fullName]];
            } else {
                return ['ok' => false, 'message' => '无效文件!'];
            }

        }
    }


}
<?php

namespace App\Service;

use App\Service\OSS\AliOSS;

use App\Service\OSS\HuaweiOBS;
use Exception;

class OSS
{

    const DEFAULT_DRIVER = 'HW_OBS';

    const OSS_PREFIX = 'oss/';

    public $OSSService;

    /**
     * 初始化 service
     */
    public function __construct()
    {
        if (env('OSS_DRIVER') === self::DEFAULT_DRIVER) {
            $this->OSSService = new HuaweiOBS();
        } else {
            $this->OSSService = new AliOSS();
        }

    }

    public static function getInstance()
    {
        return new self();
    }

    /**
     * 使用外网上传文件
     *
     * @param $fullName
     * @param $filePath
     * @param $prefix
     * @return mixed
     * @throws Exception
     */
    public static function publicUpload($fullName, $filePath, $prefix)
    {
        return self::getInstance()->OSSService->publicUpload($fullName, $filePath);
    }


    /**
     * 获取oss图片url
     *
     * @param $fullName
     * @param $expires |    过期时效
     * @return string
     * @throws Exception
     */
    public static function getUrl($fullName, $expires = '')
    {
        return self::getInstance()->OSSService->getUrl($fullName, $expires);
    }


    /**
     * 替换url域名
     *
     * @param $url
     * @return mixed
     */
    public static function replaceUrl($url)
    {
        return self::getInstance()->OSSService->replaceUrl($url);
    }


    /**
     * 获取完整的文件名含路径
     *
     * @param $fileName
     * @param $prefix
     * @return string
     */
    public static function getFullFileName($fileName, $prefix)
    {
        return self::OSS_PREFIX . $prefix . self::setFileName($fileName);
    }


    /**
     * 设置新的文件名(重命名规则)
     *
     * @param $fileName
     * @return string
     */
    public static function setFileName($fileName)
    {
        $nameArray = explode('.', $fileName);
        $extension = $nameArray[count($nameArray) - 1];
        $newName = date('Ymd') . '/' . date('YmdHis') . rand(10000, 99999) . '.' . $extension;

        return $newName;
    }

}

有时间可以对其进行功能接口补充,丰富更多云接口能力。
附:
composer包:packagist.org/packages/league/flys...

composer require league/flysystem

Spring mvn包:X Spring File Storage | spring-file-storage.xuyanwu.cn/#/

本作品采用《CC 协议》,转载必须注明作者和本文链接
《L01 基础入门》
我们将带你从零开发一个项目并部署到线上,本课程教授 Web 开发中专业、实用的技能,如 Git 工作流、Laravel Mix 前端工作流等。
《G01 Go 实战入门》
从零开始带你一步步开发一个 Go 博客项目,让你在最短的时间内学会使用 Go 进行编码。项目结构很大程度上参考了 Laravel。
讨论数量: 0
(= ̄ω ̄=)··· 暂无内容!

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!