thinkphp6上传图片至七牛云

一、注册七牛云

在七牛云官网注册自己的账号，并申请好对象存储资源。创建一个空间，绑定域名。新注册有一个测试使用的域名。

去个人中心密钥管理把 AK，SK秘钥复制。

二、在tp6项目安装sdk

1，安装命令

composer require qiniu/php-sdk

2，在config目录里新建qiniu.php

config/qiniu.php

3,创建Qiniu.php

app/server/Qiniu.php

<?php


namespace app\service;


use think\facade\Config;
use Qiniu\Auth;
use Qiniu\Config as QiniuConfig;
use Qiniu\Storage\BucketManager;
use const true;

class Qiniu
{

    public function getUpToken()
    {
        $accessKey = Config::get('qiniu.access_key');
        $secretKey = Config::get('qiniu.secret_key');
        $bucket = Config::get('qiniu.bucket');
        $auth = new Auth($accessKey, $secretKey);
        return $auth->uploadToken($bucket);
    }

    public function getSignedUrl($key)
    {
        $accessKey = Config::get('qiniu.access_key');
        $secretKey = Config::get('qiniu.secret_key');
        $auth = new Auth($accessKey, $secretKey);
        $bucket_domain = Config::get('qiniu.bucket_domain');
        $baseUrl = $bucket_domain.$key;
        return $auth->privateDownloadUrl($baseUrl);
    }

    public function delete($key)
    {
        $accessKey = Config::get('qiniu.access_key');
        $secretKey = Config::get('qiniu.secret_key');
        $bucket = Config::get('qiniu.bucket_name');
        $auth = new Auth($accessKey, $secretKey);
        $conf = new QiniuConfig();
        $bucketManager = new BucketManager($auth,$conf);
        $err = $bucketManager->delete($bucket,$key);
        if ($err) {
            print_r($err);
            return 1;
        }else{
            return 1;
        }
    }

    public function getFileList()
    {
        $accessKey = Config::get('qiniu.access_key');
        $secretKey = Config::get('qiniu.secret_key');
        $bucket = Config::get('qiniu.bucket_name');
        $auth = new Auth($accessKey, $secretKey);
        $bucketManager = new BucketManager($auth);
// 要列取文件的公共前缀
        $prefix = '';
// 上次列举返回的位置标记，作为本次列举的起点信息。
        $marker = '';
// 本次列举的条目数
        $limit = 100;
        $delimiter = '/';
// 列举文件
        list($ret, $err) = $bucketManager->listFiles($bucket, $prefix, $marker, $limit, $delimiter);
        if ($err !== null) {
            echo "\n====> list file err: \n";
            var_dump($err);
        } else {
            foreach ($ret['items'] as $item)
            {
                echo "<br/>".$item['key'];
            }
//            dump($ret['items']);
//            if (array_key_exists('marker', $ret)) {
//                echo "Marker:" . $ret["marker"] . "\n";
//            }
//            echo "\nList Iterms====>\n";
            dump($ret['items']);
        }
    }
}

4，控制器Index.php

<?php
declare (strict_types = 1);

namespace app\admin\controller;

use app\BaseController;
use app\Request;
use think\App;
use Qiniu\Storage\UploadManager;
use app\service\Qiniu as QiniuService;
use think\facade\Config;
use think\facade\Db;
use think\facade\View;

class Index extends BaseController
{
    protected $service;
    public function __construct(App $app, QiniuService $service)
    {
        parent::__construct($app);
        $this->service = $service;
    }

    public function index()
    {
       
        View::assign(
            [
                'token'=>$this->service->getUpToken()
            ]
        );
        
        return view();
    }

    /**
     * 上传接口
     * @param Request $request
     * @return string|null
     * @throws \Exception
     */
    public function uploadFile(Request $request)
    {
        $fileName = $request->post('file_name');
        $token = $request->post('upload_token');
        $image = $request->file('file');
//        获取临时路径
        $filePath = $image->getRealPath();
//        获取文件后缀
        $ext = $image->getOriginalExtension();
//        上传到七牛后保存的新文件名
        $newImageName = 'images/'.$fileName.'.'.$ext;


//        初始化UploadManager
        $uploadMgr = new UploadManager();
        // 调用 UploadManager 的 putFile 方法进行文件的上传。
         
         
        list($ret, $err) = $uploadMgr->putFile($token,$newImageName,$filePath);     // token、七牛云地址、上传文件路径
       
        if ($err !== null){
            dd($err);
            return null;

        }else{
//            图片上传成功
            $dataTpl = [
                'fname' => $fileName,
                'fpath' => $ret['key']
            ];
            Db::name('qiniu')->save($dataTpl);
            return '上传成功';

        }

    }

    public function downloadFile()
    {
        $dataList = Db::name('qiniu')->select()->toArray();
        $finalArr = array();
        foreach ($dataList as $data)
        {
            $tpl['name'] = $data['fname'];
            $tpl['key'] = $data['key'];
            $tpl['url'] = $this->service->getSignedUrl($data['key']);
            $finalArr[] = $tpl;
        }
        View::assign(
            ['dataList'=>$finalArr]
        );
        return view();
    }

    public function del(Request $request)
    {
        $key = $request->get('key');
        $res = Db::name('qiniu')->where('key',$key)->delete();
        if($res)
        {
            if($this->service->delete($key))
            {
                return '都删除成功了！';
            }else{
                return '数据库删除成功了，但是七牛上没删除成功！';
            }
        }else{
            return '删除失败！';
        }

    }

    public function allFile()
    {
        $this->service->getFileList();
    }


}

5，前端

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>

<form action="{:url('index/uploadFile')}" enctype="multipart/form-data" method="post">
    <input type="text" name="upload_token" value="{$token}" /><br/>
    <input type="text" name="file_name" value="123" /><br/>
    <input type="file" name="file" /> <br>
    <input type="submit" value="上传" />
</form>

</body>
</html>

三、结果