很多项目经常会用到阿里云的OSS，每次都需要集成一遍oss的sdk。
那么有没有一劳永逸的方法呢。答案当然是yes！
我们可以将oss上传做成一个可以对外提供的服务，以后再需要使用的时候就直接调用就好了。
本服务采用RESTFull接口设计。
提供两个方法：upload，urlsign
upload为统一上传接口，通过这个接口可以上传任意文件到OSS。
urlsign为url签名接口，通过这个接口可以拿到私有bucket的签名地址。
下面直接来看代码
/**
* 验证来源ID
*/
private function checkSource() {
if (empty($GLOBALS['sources']) || empty($this->_sourceid)) {
Output::jsonStr(Error::ERROR_AUTH_SOURCE_FAIL);
}
foreach($GLOBALS['sources'] as $key => $value) {
if ($value['sourceid'] == $this->_sourceid) {
$this->_bucket = $value['bucket'];
$this->_domain = $value['domain'];
$this->_project = $key;
}
}
if (empty($this->_bucket)) {
Output::jsonStr(Error::ERROR_AUTH_SOURCE_FAIL);
}
}
这样可能看不懂，再来看下配置
配置
这回是不是理解了呢。
通过这段代码可以实现在配置里指定单独的Bucket和绑定的域名。
但是，实际情况是如果绑定的域名是CDN域名，那么就无法操作oss了，那么有什么解决办法呢。
答案就是：所有的上传操作都走oss的内网域名，上传成功之后返回的地址走绑定域名。
代码如下：
/**
* 初始化ossClient
* @param type $useDomain
* @return OssClient
*/
public function ossClient($useDomain = 0) {
$endpoint = self::endPoint;
$isCName = 0;
if($useDomain && $this->_domain){
$endpoint = $this->_domain;
$isCName = 1;
}
try {
return new OssClient(self::accessKeyId, self::accessKeySecret, $endpoint, $isCName);
} catch (OssException $e) {
Output::jsonStr(Error::ERROR_SYSTEM_FAIL, $e->getMessage());
}
}
因为同一个方法中不一定使用绑定的域名还是原始域名，所以这里封装了一个方法，目的就是可以指定使用绑定的域名或者不使用。
下面就是具体的接口代码
/**
* 统一上传服务
* @param type $file_content
* @param type $save_name
* @param type $save_path
*/
public function _upload($file_content, $save_name, $save_path) {
//获取文件类型
$type = Tools::getFileType($file_content);
if(!$type){
Output::jsonStr(Error::ERROR_PARAM_INVALID, 'unknow type.');
}
//获取目标文件名
$filename = $this->_getSaveName($save_name, $type);
$object = ($save_path) ? "$this->_project/$save_path/$filename" : "$this->_project/$filename";
try {
$this->ossClient()->putObject($this->_bucket, $object, $file_content);
} catch (Exception $exc) {
Output::jsonStr(Error::ERROR_SYSTEM_FAIL, $exc->getMessage());
}
$data = ['object' => $object, 'url' => $this->_getUrl($object)];
$img_info = OssPictureModel::info($this->url);
Output::jsonStr(Error::SUCCESS, $img_info ? array_merge($data, $img_info) : $data);
}
/**
* API:获取私有Bucket中Object的signUrl
*/
public function urlSignAction() {
$object = $this->input_post_param('object');
$timeout = $this->input_post_param('timeout', 60);
if(!$object){
Output::jsonStr(Error::ERROR_PARAM_MISS);
}
try {
$this->ossClient()->doesObjectExist($this->_bucket, $object);
} catch (Exception $exc) {
Output::jsonStr(Error::ERROR_PARAM_INVALID, $exc->getMessage());
}
try {
$sign_url = $this->ossClient(1)->signUrl($this->_bucket, $object, $timeout);
} catch (Exception $exc) {
Output::jsonStr(Error::ERROR_PARAM_INVALID, $exc->getMessage());
}
Output::jsonStr(Error::SUCCESS, $sign_url);}
到这里，我们就搭建好了一个基本的服务，以后有需要用到oss上传的项目，只要在本服务配置文件的sources数组中新增一个成员，然后就可以通过接口直接调用了。
我是闫大伯，一只永不停歇的野生程序猿
