阿里云OSS文件上传封装

1.先用composer安装阿里云OSS的PHPSDK

2.配置文件里定义阿里云OSS的秘钥

3.在index控制器里的代码封装

<?php

namespace appindexcontroller;

use OSSOssClient;
use OSSCoreOssException;
use OSSCoreOssUtil;
use thinkConfig;

class Index extends Base
{
    // 阿里OSS相关参数
    protected $accessKeyId = '';
    protected $accessKeySecret = '';
    protected $endpoint = '';
    protected $bucket = '';
    // 文件上传相关设置
    protected $image_size = 0;
    protected $video_size = 0;
    protected $other_size = 0;

    /**
     * 构造函数
     */
    public function _initialize()
    {
        $this->accessKeyId = Config::get('aliyun_oss')['accessKeyId'];
        $this->accessKeySecret = Config::get('aliyun_oss')['accessKeySecret'];
        $this->endpoint = Config::get('aliyun_oss')['endpoint'];
        $this->bucket = Config::get('aliyun_oss')['bucket'];
        $this->image_size = Config::get('upload_set')['image_size'];
        $this->video_size = Config::get('upload_set')['video_size'];
        $this->other_size = Config::get('upload_set')['other_size'];
    }

    /**
     * 测试页面
     */
    public function index()
    {
        return $this->fetch();
    }

    /**
     * 创建存储空间
     */
    public function createBucket()
    {
        if (!request()->isPost()) {
            throw new 	hinkException('请求方式错误！');
        }
        $bucket = input('param.bucket');
        if (empty($bucket)) {
            return json(['data' => '', 'code' => 1, 'message' => '存储空间名不能为空！']);
        }
        try {
            $ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
            $ossClient->createBucket($bucket);
            return json(['data' => '', 'code' => 0, 'message' => $bucket . '存储空间创建成功']);
        } catch (OssException $e) {
            return json(['data' => $e->getMessage(), 'code' => 1, 'message' => '创建失败']);
        }
    }

    /**
     * 上传文件
     */
    public function uploadFile()
    {
        /*判断提交方式*/
        if (!request()->isPost()) {
            throw new 	hinkException('请求方式错误！');
        }
        /*获取到上传的文件*/
        $file = $_FILES['file'];
        if (!$file) {
            return json(['data' => '', 'code' => 1, 'message' => '文件不存在！']);
        }
        // 判断文件大小
        if ($file['size'] > $this->other_size) {
            return json(['data' => '', 'code' => 1, 'message' => '文件大小不能超过' . ($this->other_size / 1024 / 1024) . 'M']);
        }
        $name = $file['name'];
        $format = strrchr($name, '.');//截取文件后缀名如 (.jpg)
        /*判断图片格式*/
        $allow_type = ['.zip', '.rar', '.doc','.docx','xls','xlsx','mp3','wav'];
        if (!in_array($format, $allow_type)) {
            return json(['data' => '', 'code' => 1, 'message' => '文件格式不在允许范围内']);
        }
        // 尝试执行
        try {
            //实例化对象 将配置传入
            $ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
            //这里是有sha1加密 生成文件名 之后连接上后缀
            $fileName = 'upload/file/' . date("Ymd") . '/' . sha1(date('YmdHis', time()) . uniqid()) . $format;
            //执行阿里云上传
            $result = $ossClient->uploadFile($this->bucket, $fileName, $file['tmp_name']);
            /*组合返回数据*/
            $arr = [
                'oss_url' => $result['info']['url'],  //上传资源地址
                'relative_path' => $fileName     //数据库保存名称(相对路径)
            ];
        } catch (OssException $e) {
            return json(['data' => $e->getMessage(), 'code' => 1, 'message' => '上传失败！']);
        }
        //将结果返回
        return json(['data' => array('file' => $arr['oss_url']), 'code' => 0, 'message' => '成功上传到oss']);
    }

    /**
     * 上传视频
     */
    public function uploadVideo()
    {
        /*判断提交方式*/
        if (!request()->isPost()) {
            throw new 	hinkException('请求方式错误！');
        }
        /*获取到上传的文件*/
        $file = $_FILES['file'];
        if (!$file) {
            return json(['data' => '', 'code' => 1, 'message' => '文件不存在！']);
        }
        // 判断文件大小
        if ($file['size'] > $this->video_size) {
            return json(['data' => '', 'code' => 1, 'message' => '视频大小不能超过' . ($this->video_size / 1024 / 1024) . 'M']);
        }
        $name = $file['name'];
        $format = strrchr($name, '.');//截取文件后缀名如 (.jpg)
        /*判断图片格式*/
        $allow_type = ['.mp4', '.avi', '.rmvb'];
        if (!in_array($format, $allow_type)) {
            return json(['data' => '', 'code' => 1, 'message' => '视频格式不在允许范围内']);
        }
        // 尝试执行
        try {
            //实例化对象 将配置传入
            $ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
            //这里是有sha1加密 生成文件名 之后连接上后缀
            $fileName = 'upload/video/' . date("Ymd") . '/' . sha1(date('YmdHis', time()) . uniqid()) . $format;
            //执行阿里云上传
            $result = $ossClient->uploadFile($this->bucket, $fileName, $file['tmp_name']);
            /*组合返回数据*/
            $arr = [
                'oss_url' => $result['info']['url'],  //上传资源地址
                'relative_path' => $fileName     //数据库保存名称(相对路径)
            ];
        } catch (OssException $e) {
            return json(['data' => $e->getMessage(), 'code' => 1, 'message' => '上传失败！']);
        }
        //将结果返回
        return json(['data' => array('file' => $arr['oss_url']), 'code' => 0, 'message' => '成功上传到oss']);
    }

    /**
     * 上传图片
     */
    public function uploadImage()
    {
        /*判断提交方式*/
        if (!request()->isPost()) {
            throw new 	hinkException('请求方式错误！');
        }
        /*获取到上传的文件*/
        $file = $_FILES['file'];
        if (!$file) {
            return json(['data' => '', 'code' => 1, 'message' => '文件不存在！']);
        }
        // 判断文件大小
        if ($file['size'] > $this->image_size) {
            return json(['data' => '', 'code' => 1, 'message' => '视频大小不能超过' . ($this->image_size / 1024 / 1024) . 'M']);
        }
        $name = $file['name'];
        $format = strrchr($name, '.');//截取文件后缀名如 (.jpg)
        /*判断图片格式*/
        $allow_type = ['.jpg', '.jpeg', '.gif', '.bmp', '.png'];
        if (!in_array($format, $allow_type)) {
            return json(['data' => '', 'code' => 1, 'message' => '图片格式不在允许范围内']);
        }
        // 尝试执行
        try {
            //实例化对象 将配置传入
            $ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
            //这里是有sha1加密 生成文件名 之后连接上后缀
            $fileName = 'upload/image/' . date("Ymd") . '/' . sha1(date('YmdHis', time()) . uniqid()) . $format;
            //执行阿里云上传
            $result = $ossClient->uploadFile($this->bucket, $fileName, $file['tmp_name']);
            /*组合返回数据*/
            $arr = [
                'oss_url' => $result['info']['url'],  //上传资源地址
                'relative_path' => $fileName     //数据库保存名称(相对路径)
            ];
        } catch (OssException $e) {
            return json(['data' => $e->getMessage(), 'code' => 1, 'message' => '上传失败！']);
        }
        //将结果返回
        return json(['data' => array('file' => $arr['oss_url']), 'code' => 0, 'message' => '成功上传到oss']);
    }

    /**
     * 上传图片base64
     */
    public function uploadImageBase64()
    {
        // 判断提交方式及图片类型
        if (!request()->has('base64', 'post')) {
            return json(['data' => '', 'code' => 1, 'message' => '请求方式错误，或图片非base64格式类型']);
        }
        $data = $_POST['base64'];
        $result = $this->new_base64_upload($data);
        if ($result['code'] !== 200) {
            return json(['data' => '', 'code' => 1, 'message' => $result['msg']]);
        }
        $fileResult = &$result['data'];
        $filePath = $fileResult['path'] . $fileResult['name'];
        $ossFileName = implode('/', ['upload/image', date('Ymd'), $fileResult['name']]);
        try {
            //实例化对象 将配置传入
            $ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
            $result = $ossClient->uploadFile($this->bucket, $ossFileName, $filePath);
            $arr = [
                'oss_url' => $result['info']['url'],  //上传资源地址
                'relative_path' => $ossFileName     //数据库保存名称(相对路径)
            ];
        } catch (OssException $e) {
            return json(['data' => $e->getMessage(), 'code' => 1, 'message' => '上传失败']);
        }
        unlink($filePath);
        return json(['data' => array('file' => $arr['oss_url']), 'code' => 0, 'message' => '成功上传到oss']);
    }

    /**
     * 将Base64数据转换成二进制并存储到指定路径
     */
    protected function new_base64_upload($base64, $image_path = 'upload/posts/')
    {
        $data = explode(',', $base64);
        trace($data, 'api');
        unset($base64);
        if (count($data) !== 2) {
            return ['code' => 400, 'msg' => '文件格式错误'];
        }
        if (!preg_match('/^(data:s*image/(w+);base64)/', $data[0], $result)) {
            return ['code' => 400, 'msg' => '文件格式错误'];
        }
        $type = $result[2];
        if (!in_array($type, array('jpeg', 'jpg', 'gif', 'bmp', 'png'))) {
            return ['code' => 400, 'msg' => '文件格式不在允许范围内'];
        }
        $image_name = md5(uniqid()) . '.' . $result[2];
        $image_file = $image_path . $image_name;
        //服务器文件存储路径
        try {
            if (file_put_contents($image_file, base64_decode($data[1]))) {
                return ['code' => 200, 'msg' => '成功', 'data' => ['name' => $image_name, 'path' => $image_path]];
            } else {
                return ['code' => 400, 'msg' => '文件保存失败'];
            }
        } catch (Exception $e) {
            $msg = $e->getMessage();
            return ['code' => 400, 'msg' => $msg];
        }
    }
}