no message

+<?php
+require_once __DIR__ . '/../autoload.php';
+
+use \Qiniu\Auth;
+
+$accessKey = getenv('QINIU_ACCESS_KEY');
+$secretKey = getenv('QINIU_SECRET_KEY');
+$bucket = getenv('QINIU_TEST_BUCKET');
+
+// 初始化Auth状态
+$auth = new Auth($accessKey, $secretKey);
+
+// 简单上传凭证
+$expires = 3600;
+
+$policy = null;
+$upToken = $auth->uploadToken($bucket, null, $expires, $policy, true);
+print($upToken . "\n");
+
+// 自定义凭证有效期（示例2小时）
+$expires = 7200;
+$upToken = $auth->uploadToken($bucket, null, $expires, $policy, true);
+print($upToken . "\n");
+
+// 覆盖上传凭证
+$expires = 3600;
+$keyToOverwrite = 'qiniu.mp4';
+$upToken = $auth->uploadToken($bucket, $keyToOverwrite, $expires, $policy, true);
+print($upToken . "\n");
+
+//自定义上传回复（非callback模式）凭证
+$returnBody = '{"key":"$(key)","hash":"$(etag)","fsize":$(fsize),"bucket":"$(bucket)","name":"$(x:name)"}';
+$policy = array(
+    'returnBody' => $returnBody
+);
+$upToken = $auth->uploadToken($bucket, null, $expires, $policy, true);
+print($upToken . "\n");
+
+//带回调业务服务器的凭证（application/json）
+$policy = array(
+    'callbackUrl' => 'http://api.example.com/qiniu/upload/callback',
+    'callbackBody' => '{"key":"$(key)","hash":"$(etag)","fsize":$(fsize),"bucket":"$(bucket)","name":"$(x:name)"}',
+    'callbackBodyType' => 'application/json'
+);
+$upToken = $auth->uploadToken($bucket, null, $expires, $policy, true);
+print($upToken . "\n");
+
+
+//带回调业务服务器的凭证（application/x-www-form-urlencoded）
+$policy = array(
+    'callbackUrl' => 'http://api.example.com/qiniu/upload/callback',
+    'callbackBody' => 'key=$(key)&hash=$(etag)&bucket=$(bucket)&fsize=$(fsize)&name=$(x:name)'
+);
+$upToken = $auth->uploadToken($bucket, null, $expires, $policy, true);
+print($upToken . "\n");
+
+//带数据处理的凭证
+$saveMp4Entry = \Qiniu\base64_urlSafeEncode($bucket . ":avthumb_test_target.mp4");
+$saveJpgEntry = \Qiniu\base64_urlSafeEncode($bucket . ":vframe_test_target.jpg");
+$avthumbMp4Fop = "avthumb/mp4|saveas/" . $saveMp4Entry;
+$vframeJpgFop = "vframe/jpg/offset/1|saveas/" . $saveJpgEntry;
+$policy = array(
+    'persistentOps' => $avthumbMp4Fop . ";" . $vframeJpgFop,
+    'persistentPipeline' => "video-pipe",
+    'persistentNotifyUrl' => "http://api.example.com/qiniu/pfop/notify",
+);
+$upToken = $auth->uploadToken($bucket, null, $expires, $policy, true);
+print($upToken . "\n");

+<?php
+require_once __DIR__ . '/../autoload.php';
+
+use Qiniu\Auth;
+
+$accessKey = getenv('QINIU_ACCESS_KEY');
+$secretKey = getenv('QINIU_SECRET_KEY');
+$bucket = getenv('QINIU_TEST_BUCKET');
+
+$auth = new Auth($accessKey, $secretKey);
+
+//获取回调的body信息
+$callbackBody = file_get_contents('php://input');
+
+//回调的contentType
+$contentType = 'application/x-www-form-urlencoded';
+
+//回调的签名信息，可以验证该回调是否来自七牛
+$authorization = $_SERVER['HTTP_AUTHORIZATION'];
+
+//七牛回调的url，具体可以参考：http://developer.qiniu.com/docs/v6/api/reference/security/put-policy.html
+$url = 'http://172.30.251.210/upload_verify_callback.php';
+
+$isQiniuCallback = $auth->verifyCallback($contentType, $authorization, $url, $callbackBody);
+
+if ($isQiniuCallback) {
+    $resp = array('ret' => 'success');
+} else {
+    $resp = array('ret' => 'failed');
+}
+
+echo json_encode($resp);

+<?php
+namespace Qiniu;
+
+use Qiniu\Zone;
+
+final class Auth
+{
+    private $accessKey;
+    private $secretKey;
+
+    public function __construct($accessKey, $secretKey)
+    {
+        $this->accessKey = $accessKey;
+        $this->secretKey = $secretKey;
+    }
+
+    public function getAccessKey()
+    {
+        return $this->accessKey;
+    }
+
+    public function sign($data)
+    {
+        $hmac = hash_hmac('sha1', $data, $this->secretKey, true);
+        return $this->accessKey . ':' . \Qiniu\base64_urlSafeEncode($hmac);
+    }
+
+    public function signWithData($data)
+    {
+        $encodedData = \Qiniu\base64_urlSafeEncode($data);
+        return $this->sign($encodedData) . ':' . $encodedData;
+    }
+
+    public function signRequest($urlString, $body, $contentType = null)
+    {
+        $url = parse_url($urlString);
+        $data = '';
+        if (array_key_exists('path', $url)) {
+            $data = $url['path'];
+        }
+        if (array_key_exists('query', $url)) {
+            $data .= '?' . $url['query'];
+        }
+        $data .= "\n";
+
+        if ($body !== null && $contentType === 'application/x-www-form-urlencoded') {
+            $data .= $body;
+        }
+        return $this->sign($data);
+    }
+
+    public function verifyCallback($contentType, $originAuthorization, $url, $body)
+    {
+        $authorization = 'QBox ' . $this->signRequest($url, $body, $contentType);
+        return $originAuthorization === $authorization;
+    }
+
+    public function privateDownloadUrl($baseUrl, $expires = 3600)
+    {
+        $deadline = time() + $expires;
+
+        $pos = strpos($baseUrl, '?');
+        if ($pos !== false) {
+            $baseUrl .= '&e=';
+        } else {
+            $baseUrl .= '?e=';
+        }
+        $baseUrl .= $deadline;
+
+        $token = $this->sign($baseUrl);
+        return "$baseUrl&token=$token";
+    }
+
+    public function uploadToken($bucket, $key = null, $expires = 3600, $policy = null, $strictPolicy = true)
+    {
+        $deadline = time() + $expires;
+        $scope = $bucket;
+        if ($key !== null) {
+            $scope .= ':' . $key;
+        }
+
+        $args = self::copyPolicy($args, $policy, $strictPolicy);
+        $args['scope'] = $scope;
+        $args['deadline'] = $deadline;
+
+        $b = json_encode($args);
+        return $this->signWithData($b);
+    }
+
+    /**
+     *上传策略，参数规格详见
+     *http://developer.qiniu.com/docs/v6/api/reference/security/put-policy.html
+     */
+    private static $policyFields = array(
+        'callbackUrl',
+        'callbackBody',
+        'callbackHost',
+        'callbackBodyType',
+        'callbackFetchKey',
+
+        'returnUrl',
+        'returnBody',
+
+        'endUser',
+        'saveKey',
+        'insertOnly',
+
+        'detectMime',
+        'mimeLimit',
+        'fsizeMin',
+        'fsizeLimit',
+
+        'persistentOps',
+        'persistentNotifyUrl',
+        'persistentPipeline',
+
+        'deleteAfterDays',
+        'fileType',
+        'isPrefixalScope',
+    );
+
+    private static function copyPolicy(&$policy, $originPolicy, $strictPolicy)
+    {
+        if ($originPolicy === null) {
+            return array();
+        }
+        foreach ($originPolicy as $key => $value) {
+            if (!$strictPolicy || in_array((string)$key, self::$policyFields, true)) {
+                $policy[$key] = $value;
+            }
+        }
+        return $policy;
+    }
+
+    public function authorization($url, $body = null, $contentType = null)
+    {
+        $authorization = 'QBox ' . $this->signRequest($url, $body, $contentType);
+        return array('Authorization' => $authorization);
+    }
+
+    public function authorizationV2($url, $method, $body = null, $contentType = null)
+    {
+        $urlItems = parse_url($url);
+        $host = $urlItems['host'];
+
+        if (isset($urlItems['port'])) {
+            $port = $urlItems['port'];
+        } else {
+            $port = '';
+        }
+
+        $path = $urlItems['path'];
+        if (isset($urlItems['query'])) {
+            $query = $urlItems['query'];
+        } else {
+            $query = '';
+        }
+
+        //write request uri
+        $toSignStr = $method . ' ' . $path;
+        if (!empty($query)) {
+            $toSignStr .= '?' . $query;
+        }
+
+        //write host and port
+        $toSignStr .= "\nHost: " . $host;
+        if (!empty($port)) {
+            $toSignStr .= ":" . $port;
+        }
+
+        //write content type
+        if (!empty($contentType)) {
+            $toSignStr .= "\nContent-Type: " . $contentType;
+        }
+
+        $toSignStr .= "\n\n";
+
+        //write body
+        if (!empty($body)) {
+            $toSignStr .= $body;
+        }
+
+        $sign = $this->sign($toSignStr);
+        $auth = 'Qiniu ' . $sign;
+        return array('Authorization' => $auth);
+    }
+}

+<?php
+
+namespace Qiniu\Cdn;
+
+use Qiniu\Auth;
+use Qiniu\Http\Error;
+use Qiniu\Http\Client;
+
+final class CdnManager
+{
+
+    private $auth;
+    private $server;
+
+    public function __construct(Auth $auth)
+    {
+        $this->auth = $auth;
+        $this->server = 'http://fusion.qiniuapi.com';
+    }
+
+    /**
+     * @param array $urls 待刷新的文件链接数组
+     * @return array
+     */
+    public function refreshUrls(array $urls)
+    {
+        return $this->refreshUrlsAndDirs($urls, array());
+    }
+
+    /**
+     * @param array $dirs 待刷新的文件链接数组
+     * @return array
+     * 目前客户默认没有目录刷新权限，刷新会有400038报错，参考：https://developer.qiniu.com/fusion/api/1229/cache-refresh
+     * 需要刷新目录请工单联系技术支持 https://support.qiniu.com/tickets/category
+     */
+    public function refreshDirs(array $dirs)
+    {
+        return $this->refreshUrlsAndDirs(array(), $dirs);
+    }
+
+    /**
+     * @param array $urls 待刷新的文件链接数组
+     * @param array $dirs 待刷新的目录链接数组
+     *
+     * @return array 刷新的请求回复和错误，参考 examples/cdn_manager.php 代码
+     * @link http://developer.qiniu.com/article/fusion/api/refresh.html
+     *
+     * 目前客户默认没有目录刷新权限，刷新会有400038报错，参考：https://developer.qiniu.com/fusion/api/1229/cache-refresh
+     * 需要刷新目录请工单联系技术支持 https://support.qiniu.com/tickets/category
+     */
+    public function refreshUrlsAndDirs(array $urls, array  $dirs)
+    {
+        $req = array();
+        if (!empty($urls)) {
+            $req['urls'] = $urls;
+        }
+        if (!empty($dirs)) {
+            $req['dirs'] = $dirs;
+        }
+
+        $url = $this->server . '/v2/tune/refresh';
+        $body = json_encode($req);
+        return $this->post($url, $body);
+    }
+
+    /**
+     * @param array $urls 待预取的文件链接数组
+     *
+     * @return array 预取的请求回复和错误，参考 examples/cdn_manager.php 代码
+     *
+     * @link http://developer.qiniu.com/article/fusion/api/refresh.html
+     */
+    public function prefetchUrls(array $urls)
+    {
+        $req = array(
+            'urls' => $urls,
+        );
+
+        $url = $this->server . '/v2/tune/prefetch';
+        $body = json_encode($req);
+        return $this->post($url, $body);
+    }
+
+    /**
+     * @param array $domains 待获取带宽数据的域名数组
+     * @param string $startDate 开始的日期，格式类似 2017-01-01
+     * @param string $endDate 结束的日期，格式类似 2017-01-01
+     * @param string $granularity 获取数据的时间间隔，可以是 5min, hour 或者 day
+     *
+     * @return array 带宽数据和错误信息，参考 examples/cdn_manager.php 代码
+     *
+     * @link http://developer.qiniu.com/article/fusion/api/traffic-bandwidth.html
+     */
+    public function getBandwidthData(array $domains, $startDate, $endDate, $granularity)
+    {
+        $req = array();
+        $req['domains'] = implode(';', $domains);
+        $req['startDate'] = $startDate;
+        $req['endDate'] = $endDate;
+        $req['granularity'] = $granularity;
+
+        $url = $this->server . '/v2/tune/bandwidth';
+        $body = json_encode($req);
+        return $this->post($url, $body);
+    }
+
+    /**
+     * @param array $domains 待获取流量数据的域名数组
+     * @param string $startDate 开始的日期，格式类似 2017-01-01
+     * @param string $endDate 结束的日期，格式类似 2017-01-01
+     * @param string $granularity 获取数据的时间间隔，可以是 5min, hour 或者 day
+     *
+     * @return array 流量数据和错误信息，参考 examples/cdn_manager.php 代码
+     *
+     * @link http://developer.qiniu.com/article/fusion/api/traffic-bandwidth.html
+     */
+    public function getFluxData(array $domains, $startDate, $endDate, $granularity)
+    {
+        $req = array();
+        $req['domains'] = implode(';', $domains);
+        $req['startDate'] = $startDate;
+        $req['endDate'] = $endDate;
+        $req['granularity'] = $granularity;
+
+        $url = $this->server . '/v2/tune/flux';
+        $body = json_encode($req);
+        return $this->post($url, $body);
+    }
+
+    /**
+     * @param array $domains 待获取日志下载链接的域名数组
+     * @param string $logDate 获取指定日期的日志下载链接，格式类似 2017-01-01
+     *
+     * @return array 日志下载链接数据和错误信息，参考 examples/cdn_manager.php 代码
+     *
+     * @link http://developer.qiniu.com/article/fusion/api/log.html
+     */
+    public function getCdnLogList(array $domains, $logDate)
+    {
+        $req = array();
+        $req['domains'] = implode(';', $domains);
+        $req['day'] = $logDate;
+
+        $url = $this->server . '/v2/tune/log/list';
+        $body = json_encode($req);
+        return $this->post($url, $body);
+    }
+
+    private function post($url, $body)
+    {
+        $headers = $this->auth->authorization($url, $body, 'application/json');
+        $headers['Content-Type'] = 'application/json';
+        $ret = Client::post($url, $body, $headers);
+        if (!$ret->ok()) {
+            return array(null, new Error($url, $ret));
+        }
+        $r = ($ret->body === null) ? array() : $ret->json();
+        return array($r, null);
+    }
+
+    /**
+     * 构建时间戳防盗链鉴权的访问外链
+     *
+     * @param string $rawUrl 需要签名的资源url
+     * @param string $encryptKey 时间戳防盗链密钥
+     * @param string $durationInSeconds 链接的有效期（以秒为单位）
+     *
+     * @return string 带鉴权信息的资源外链，参考 examples/cdn_timestamp_antileech.php 代码
+     */
+    public static function createTimestampAntiLeechUrl($rawUrl, $encryptKey, $durationInSeconds)
+    {
+
+        $parsedUrl = parse_url($rawUrl);
+
+        $deadline = time() + $durationInSeconds;
+        $expireHex = dechex($deadline);
+        $path = isset($parsedUrl['path']) ? $parsedUrl['path'] : '';
+
+        $strToSign = $encryptKey . $path . $expireHex;
+        $signStr = md5($strToSign);
+
+        if (isset($parsedUrl['query'])) {
+            $signedUrl = $rawUrl . '&sign=' . $signStr . '&t=' . $expireHex;
+        } else {
+            $signedUrl = $rawUrl . '?sign=' . $signStr . '&t=' . $expireHex;
+        }
+
+        return $signedUrl;
+    }
+}

+<?php
+namespace Qiniu;
+
+final class Config
+{
+    const SDK_VER = '7.2.5';
+
+    const BLOCK_SIZE = 4194304; //4*1024*1024 分块上传块大小，该参数为接口规格，不能修改
+
+    const RSF_HOST = 'rsf.qiniu.com';
+    const API_HOST = 'api.qiniu.com';
+    const RS_HOST = 'rs.qiniu.com';      //RS Host
+    const UC_HOST = 'https://api.qiniu.com';              //UC Host
+    const RTCAPI_HOST = 'http://rtc.qiniuapi.com';
+    const RTCAPI_VERSION = 'v3';
+
+    // Zone 空间对应的机房
+    public $zone;
+    //BOOL 是否使用https域名
+    public $useHTTPS;
+    //BOOL 是否使用CDN加速上传域名
+    public $useCdnDomains;
+    // Zone Cache
+    private $zoneCache;
+
+    // 构造函数
+    public function __construct(Zone $z = null)
+    {
+        $this->zone = $z;
+        $this->useHTTPS = false;
+        $this->useCdnDomains = false;
+        $this->zoneCache = array();
+    }
+
+    public function getUpHost($accessKey, $bucket)
+    {
+        $zone = $this->getZone($accessKey, $bucket);
+        if ($this->useHTTPS === true) {
+            $scheme = "https://";
+        } else {
+            $scheme = "http://";
+        }
+
+        $host = $zone->srcUpHosts[0];
+        if ($this->useCdnDomains === true) {
+            $host = $zone->cdnUpHosts[0];
+        }
+
+        return $scheme . $host;
+    }
+
+    public function getUpBackupHost($accessKey, $bucket)
+    {
+        $zone = $this->getZone($accessKey, $bucket);
+        if ($this->useHTTPS === true) {
+            $scheme = "https://";
+        } else {
+            $scheme = "http://";
+        }
+
+        $host = $zone->cdnUpHosts[0];
+        if ($this->useCdnDomains === true) {
+            $host = $zone->srcUpHosts[0];
+        }
+
+        return $scheme . $host;
+    }
+
+    public function getRsHost($accessKey, $bucket)
+    {
+        $zone = $this->getZone($accessKey, $bucket);
+
+        if ($this->useHTTPS === true) {
+            $scheme = "https://";
+        } else {
+            $scheme = "http://";
+        }
+
+        return $scheme . $zone->rsHost;
+    }
+
+    public function getRsfHost($accessKey, $bucket)
+    {
+        $zone = $this->getZone($accessKey, $bucket);
+
+        if ($this->useHTTPS === true) {
+            $scheme = "https://";
+        } else {
+            $scheme = "http://";
+        }
+
+        return $scheme . $zone->rsfHost;
+    }
+
+    public function getIovipHost($accessKey, $bucket)
+    {
+        $zone = $this->getZone($accessKey, $bucket);
+
+        if ($this->useHTTPS === true) {
+            $scheme = "https://";
+        } else {
+            $scheme = "http://";
+        }
+
+        return $scheme . $zone->iovipHost;
+    }
+
+    public function getApiHost($accessKey, $bucket)
+    {
+        $zone = $this->getZone($accessKey, $bucket);
+
+        if ($this->useHTTPS === true) {
+            $scheme = "https://";
+        } else {
+            $scheme = "http://";
+        }
+
+        return $scheme . $zone->apiHost;
+    }
+
+    private function getZone($accessKey, $bucket)
+    {
+        $cacheId = "$accessKey:$bucket";
+
+        if (isset($this->zoneCache[$cacheId])) {
+            $zone = $this->zoneCache[$cacheId];
+        } elseif (isset($this->zone)) {
+            $zone = $this->zone;
+            $this->zoneCache[$cacheId] = $zone;
+        } else {
+            $zone = Zone::queryZone($accessKey, $bucket);
+            $this->zoneCache[$cacheId] = $zone;
+        }
+        return $zone;
+    }
+}

+<?php
+
+namespace Qiniu;
+
+use Qiniu\Config;
+
+final class Etag
+{
+    private static function packArray($v, $a)
+    {
+        return call_user_func_array('pack', array_merge(array($v), (array)$a));
+    }
+
+    private static function blockCount($fsize)
+    {
+        return intval(($fsize + (Config::BLOCK_SIZE - 1)) / Config::BLOCK_SIZE);
+    }
+
+    private static function calcSha1($data)
+    {
+        $sha1Str = sha1($data, true);
+        $err = error_get_last();
+        if ($err !== null) {
+            return array(null, $err);
+        }
+        $byteArray = unpack('C*', $sha1Str);
+        return array($byteArray, null);
+    }
+
+
+    public static function sum($filename)
+    {
+        $fhandler = fopen($filename, 'r');
+        $err = error_get_last();
+        if ($err !== null) {
+            return array(null, $err);
+        }
+
+        $fstat = fstat($fhandler);
+        $fsize = $fstat['size'];
+        if ((int)$fsize === 0) {
+            fclose($fhandler);
+            return array('Fto5o-5ea0sNMlW_75VgGJCv2AcJ', null);
+        }
+        $blockCnt = self::blockCount($fsize);
+        $sha1Buf = array();
+
+        if ($blockCnt <= 1) {
+            array_push($sha1Buf, 0x16);
+            $fdata = fread($fhandler, Config::BLOCK_SIZE);
+            if ($err !== null) {
+                fclose($fhandler);
+                return array(null, $err);
+            }
+            list($sha1Code,) = self::calcSha1($fdata);
+            $sha1Buf = array_merge($sha1Buf, $sha1Code);
+        } else {
+            array_push($sha1Buf, 0x96);
+            $sha1BlockBuf = array();
+            for ($i = 0; $i < $blockCnt; $i++) {
+                $fdata = fread($fhandler, Config::BLOCK_SIZE);
+                list($sha1Code, $err) = self::calcSha1($fdata);
+                if ($err !== null) {
+                    fclose($fhandler);
+                    return array(null, $err);
+                }
+                $sha1BlockBuf = array_merge($sha1BlockBuf, $sha1Code);
+            }
+            $tmpData = self::packArray('C*', $sha1BlockBuf);
+            list($sha1Final,) = self::calcSha1($tmpData);
+            $sha1Buf = array_merge($sha1Buf, $sha1Final);
+        }
+        $etag = \Qiniu\base64_urlSafeEncode(self::packArray('C*', $sha1Buf));
+        return array($etag, null);
+    }
+}

+<?php
+namespace Qiniu\Http;
+
+use Qiniu\Config;
+use Qiniu\Http\Request;
+use Qiniu\Http\Response;
+
+final class Client
+{
+    public static function get($url, array $headers = array())
+    {
+        $request = new Request('GET', $url, $headers);
+        return self::sendRequest($request);
+    }
+
+    public static function delete($url, array $headers = array())
+    {
+        $request = new Request('DELETE', $url, $headers);
+        return self::sendRequest($request);
+    }
+
+    public static function post($url, $body, array $headers = array())
+    {
+        $request = new Request('POST', $url, $headers, $body);
+        return self::sendRequest($request);
+    }
+
+    public static function multipartPost(
+        $url,
+        $fields,
+        $name,
+        $fileName,
+        $fileBody,
+        $mimeType = null,
+        array $headers = array()
+    ) {
+        $data = array();
+        $mimeBoundary = md5(microtime());
+
+        foreach ($fields as $key => $val) {
+            array_push($data, '--' . $mimeBoundary);
+            array_push($data, "Content-Disposition: form-data; name=\"$key\"");
+            array_push($data, '');
+            array_push($data, $val);
+        }
+
+        array_push($data, '--' . $mimeBoundary);
+        $finalMimeType = empty($mimeType) ? 'application/octet-stream' : $mimeType;
+        $finalFileName = self::escapeQuotes($fileName);
+        array_push($data, "Content-Disposition: form-data; name=\"$name\"; filename=\"$finalFileName\"");
+        array_push($data, "Content-Type: $finalMimeType");
+        array_push($data, '');
+        array_push($data, $fileBody);
+
+        array_push($data, '--' . $mimeBoundary . '--');
+        array_push($data, '');
+
+        $body = implode("\r\n", $data);
+        $contentType = 'multipart/form-data; boundary=' . $mimeBoundary;
+        $headers['Content-Type'] = $contentType;
+        $request = new Request('POST', $url, $headers, $body);
+        return self::sendRequest($request);
+    }
+
+    private static function userAgent()
+    {
+        $sdkInfo = "QiniuPHP/" . Config::SDK_VER;
+
+        $systemInfo = php_uname("s");
+        $machineInfo = php_uname("m");
+
+        $envInfo = "($systemInfo/$machineInfo)";
+
+        $phpVer = phpversion();
+
+        $ua = "$sdkInfo $envInfo PHP/$phpVer";
+        return $ua;
+    }
+
+    public static function sendRequest($request)
+    {
+        $t1 = microtime(true);
+        $ch = curl_init();
+        $options = array(
+            CURLOPT_USERAGENT => self::userAgent(),
+            CURLOPT_RETURNTRANSFER => true,
+            CURLOPT_SSL_VERIFYPEER => false,
+            CURLOPT_SSL_VERIFYHOST => false,
+            CURLOPT_HEADER => true,
+            CURLOPT_NOBODY => false,
+            CURLOPT_CUSTOMREQUEST => $request->method,
+            CURLOPT_URL => $request->url,
+        );
+
+        // Handle open_basedir & safe mode
+        if (!ini_get('safe_mode') && !ini_get('open_basedir')) {
+            $options[CURLOPT_FOLLOWLOCATION] = true;
+        }
+
+        if (!empty($request->headers)) {
+            $headers = array();
+            foreach ($request->headers as $key => $val) {
+                array_push($headers, "$key: $val");
+            }
+            $options[CURLOPT_HTTPHEADER] = $headers;
+        }
+        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Expect:'));
+
+        if (!empty($request->body)) {
+            $options[CURLOPT_POSTFIELDS] = $request->body;
+        }
+        curl_setopt_array($ch, $options);
+        $result = curl_exec($ch);
+        $t2 = microtime(true);
+        $duration = round($t2 - $t1, 3);
+        $ret = curl_errno($ch);
+        if ($ret !== 0) {
+            $r = new Response(-1, $duration, array(), null, curl_error($ch));
+            curl_close($ch);
+            return $r;
+        }
+        $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        $header_size = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
+        $headers = self::parseHeaders(substr($result, 0, $header_size));
+        $body = substr($result, $header_size);
+        curl_close($ch);
+        return new Response($code, $duration, $headers, $body, null);
+    }
+
+    private static function parseHeaders($raw)
+    {
+        $headers = array();
+        $headerLines = explode("\r\n", $raw);
+        foreach ($headerLines as $line) {
+            $headerLine = trim($line);
+            $kv = explode(':', $headerLine);
+            if (count($kv) > 1) {
+                $kv[0] =self::ucwordsHyphen($kv[0]);
+                $headers[$kv[0]] = trim($kv[1]);
+            }
+        }
+        return $headers;
+    }
+
+    private static function escapeQuotes($str)
+    {
+        $find = array("\\", "\"");
+        $replace = array("\\\\", "\\\"");
+        return str_replace($find, $replace, $str);
+    }
+    
+    private static function ucwordsHyphen($str)
+    {
+        return str_replace('- ', '-', ucwords(str_replace('-', '- ', $str)));
+    }
+}

+<?php
+namespace Qiniu\Http;
+
+/**
+ * 七牛业务请求逻辑错误封装类，主要用来解析API请求返回如下的内容：
+ * <pre>
+ *     {"error" : "detailed error message"}
+ * </pre>
+ */
+final class Error
+{
+    private $url;
+    private $response;
+
+    public function __construct($url, $response)
+    {
+        $this->url = $url;
+        $this->response = $response;
+    }
+
+    public function code()
+    {
+        return $this->response->statusCode;
+    }
+
+    public function getResponse()
+    {
+        return $this->response;
+    }
+
+    public function message()
+    {
+        return $this->response->error;
+    }
+}

+<?php
+namespace Qiniu\Http;
+
+final class Request
+{
+    public $url;
+    public $headers;
+    public $body;
+    public $method;
+
+    public function __construct($method, $url, array $headers = array(), $body = null)
+    {
+        $this->method = strtoupper($method);
+        $this->url = $url;
+        $this->headers = $headers;
+        $this->body = $body;
+    }
+}

+<?php
+
+namespace Qiniu\Http;
+
+/**
+ * HTTP response Object
+ */
+final class Response
+{
+    public $statusCode;
+    public $headers;
+    public $body;
+    public $error;
+    private $jsonData;
+    public $duration;
+
+    /** @var array Mapping of status codes to reason phrases */
+    private static $statusTexts = array(
+        100 => 'Continue',
+        101 => 'Switching Protocols',
+        102 => 'Processing',
+        200 => 'OK',
+        201 => 'Created',
+        202 => 'Accepted',
+        203 => 'Non-Authoritative Information',
+        204 => 'No Content',
+        205 => 'Reset Content',
+        206 => 'Partial Content',
+        207 => 'Multi-Status',
+        208 => 'Already Reported',
+        226 => 'IM Used',
+        300 => 'Multiple Choices',
+        301 => 'Moved Permanently',
+        302 => 'Found',
+        303 => 'See Other',
+        304 => 'Not Modified',
+        305 => 'Use Proxy',
+        307 => 'Temporary Redirect',
+        308 => 'Permanent Redirect',
+        400 => 'Bad Request',
+        401 => 'Unauthorized',
+        402 => 'Payment Required',
+        403 => 'Forbidden',
+        404 => 'Not Found',
+        405 => 'Method Not Allowed',
+        406 => 'Not Acceptable',
+        407 => 'Proxy Authentication Required',
+        408 => 'Request Timeout',
+        409 => 'Conflict',
+        410 => 'Gone',
+        411 => 'Length Required',
+        412 => 'Precondition Failed',
+        413 => 'Request Entity Too Large',
+        414 => 'Request-URI Too Long',
+        415 => 'Unsupported Media Type',
+        416 => 'Requested Range Not Satisfiable',
+        417 => 'Expectation Failed',
+        422 => 'Unprocessable Entity',
+        423 => 'Locked',
+        424 => 'Failed Dependency',
+        425 => 'Reserved for WebDAV advanced collections expired proposal',
+        426 => 'Upgrade required',
+        428 => 'Precondition Required',
+        429 => 'Too Many Requests',
+        431 => 'Request Header Fields Too Large',
+        500 => 'Internal Server Error',
+        501 => 'Not Implemented',
+        502 => 'Bad Gateway',
+        503 => 'Service Unavailable',
+        504 => 'Gateway Timeout',
+        505 => 'HTTP Version Not Supported',
+        506 => 'Variant Also Negotiates (Experimental)',
+        507 => 'Insufficient Storage',
+        508 => 'Loop Detected',
+        510 => 'Not Extended',
+        511 => 'Network Authentication Required',
+    );
+
+    /**
+     * @param int $code 状态码
+     * @param double $duration 请求时长
+     * @param array $headers 响应头部
+     * @param string $body 响应内容
+     * @param string $error 错误描述
+     */
+    public function __construct($code, $duration, array $headers = array(), $body = null, $error = null)
+    {
+        $this->statusCode = $code;
+        $this->duration = $duration;
+        $this->headers = $headers;
+        $this->body = $body;
+        $this->error = $error;
+        $this->jsonData = null;
+        if ($error !== null) {
+            return;
+        }
+
+        if ($body === null) {
+            if ($code >= 400) {
+                $this->error = self::$statusTexts[$code];
+            }
+            return;
+        }
+        if (self::isJson($headers)) {
+            try {
+                $jsonData = self::bodyJson($body);
+                if ($code >= 400) {
+                    $this->error = $body;
+                    if ($jsonData['error'] !== null) {
+                        $this->error = $jsonData['error'];
+                    }
+                }
+                $this->jsonData = $jsonData;
+            } catch (\InvalidArgumentException $e) {
+                $this->error = $body;
+                if ($code >= 200 && $code < 300) {
+                    $this->error = $e->getMessage();
+                }
+            }
+        } elseif ($code >= 400) {
+            $this->error = $body;
+        }
+        return;
+    }
+
+    public function json()
+    {
+        return $this->jsonData;
+    }
+
+    private static function bodyJson($body)
+    {
+        return \Qiniu\json_decode((string) $body, true, 512);
+    }
+
+    public function xVia()
+    {
+        $via = $this->headers['X-Via'];
+        if ($via === null) {
+            $via = $this->headers['X-Px'];
+        }
+        if ($via === null) {
+            $via = $this->headers['Fw-Via'];
+        }
+        return $via;
+    }
+
+    public function xLog()
+    {
+        return $this->headers['X-Log'];
+    }
+
+    public function xReqId()
+    {
+        return $this->headers['X-Reqid'];
+    }
+
+    public function ok()
+    {
+        return $this->statusCode >= 200 && $this->statusCode < 300 && $this->error === null;
+    }
+
+    public function needRetry()
+    {
+        $code = $this->statusCode;
+        if ($code < 0 || ($code / 100 === 5 and $code !== 579) || $code === 996) {
+            return true;
+        }
+    }
+
+    private static function isJson($headers)
+    {
+        return array_key_exists('Content-Type', $headers) &&
+        strpos($headers['Content-Type'], 'application/json') === 0;
+    }
+}

+<?php
+namespace Qiniu\Processing;
+
+use Qiniu;
+
+/**
+ * 主要涉及图片链接拼接
+ *
+ * @link http://developer.qiniu.com/code/v6/api/kodo-api/image/imageview2.html
+ */
+final class ImageUrlBuilder
+{
+    /**
+     * mode合法范围值
+     *
+     * @var array
+     */
+    protected $modeArr = array(0, 1, 2, 3, 4, 5);
+
+    /**
+     * format合法值
+     *
+     * @var array
+     */
+    protected $formatArr = array('psd', 'jpeg', 'png', 'gif', 'webp', 'tiff', 'bmp');
+
+    /**
+     * 水印图片位置合法值
+     *
+     * @var array
+     */
+    protected $gravityArr = array('NorthWest', 'North', 'NorthEast',
+        'West', 'Center', 'East', 'SouthWest', 'South', 'SouthEast');
+
+    /**
+     * 缩略图链接拼接
+     *
+     * @param  string $url 图片链接
+     * @param  int $mode 缩略模式
+     * @param  int $width 宽度
+     * @param  int $height 长度
+     * @param  string $format 输出类型
+     * @param  int $quality 图片质量
+     * @param  int $interlace 是否支持渐进显示
+     * @param  int $ignoreError 忽略结果
+     * @return string
+     * @link http://developer.qiniu.com/code/v6/api/kodo-api/image/imageview2.html
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    public function thumbnail(
+        $url,
+        $mode,
+        $width,
+        $height,
+        $format = null,
+        $interlace = null,
+        $quality = null,
+        $ignoreError = 1
+    ) {
+
+        // url合法效验
+        if (!$this->isUrl($url)) {
+            return $url;
+        }
+
+        // 参数合法性效验
+        if (!in_array(intval($mode), $this->modeArr, true)) {
+            return $url;
+        }
+
+        if (!$width || !$height) {
+            return $url;
+        }
+
+        $thumbStr = 'imageView2/' . $mode . '/w/' . $width . '/h/' . $height . '/';
+
+        // 拼接输出格式
+        if (!is_null($format)
+            && in_array($format, $this->formatArr)
+        ) {
+            $thumbStr .= 'format/' . $format . '/';
+        }
+
+        // 拼接渐进显示
+        if (!is_null($interlace)
+            && in_array(intval($interlace), array(0, 1), true)
+        ) {
+            $thumbStr .= 'interlace/' . $interlace . '/';
+        }
+
+        // 拼接图片质量
+        if (!is_null($quality)
+            && intval($quality) >= 0
+            && intval($quality) <= 100
+        ) {
+            $thumbStr .= 'q/' . $quality . '/';
+        }
+
+        $thumbStr .= 'ignore-error/' . $ignoreError . '/';
+
+        // 如果有query_string用|线分割实现多参数
+        return $url . ($this->hasQuery($url) ? '|' : '?') . $thumbStr;
+    }
+
+    /**
+     * 图片水印
+     *
+     * @param  string $url 图片链接
+     * @param  string $image 水印图片链接
+     * @param  numeric $dissolve 透明度
+     * @param  string $gravity 水印位置
+     * @param  numeric $dx 横轴边距
+     * @param  numeric $dy 纵轴边距
+     * @param  numeric $watermarkScale 自适应原图的短边比例
+     * @link   http://developer.qiniu.com/code/v6/api/kodo-api/image/watermark.html
+     * @return string
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    public function waterImg(
+        $url,
+        $image,
+        $dissolve = 100,
+        $gravity = 'SouthEast',
+        $dx = null,
+        $dy = null,
+        $watermarkScale = null
+    ) {
+        // url合法效验
+        if (!$this->isUrl($url)) {
+            return $url;
+        }
+
+        $waterStr = 'watermark/1/image/' . \Qiniu\base64_urlSafeEncode($image) . '/';
+
+        // 拼接水印透明度
+        if (is_numeric($dissolve)
+            && $dissolve <= 100
+        ) {
+            $waterStr .= 'dissolve/' . $dissolve . '/';
+        }
+
+        // 拼接水印位置
+        if (in_array($gravity, $this->gravityArr, true)) {
+            $waterStr .= 'gravity/' . $gravity . '/';
+        }
+
+        // 拼接横轴边距
+        if (!is_null($dx)
+            && is_numeric($dx)
+        ) {
+            $waterStr .= 'dx/' . $dx . '/';
+        }
+
+        // 拼接纵轴边距
+        if (!is_null($dy)
+            && is_numeric($dy)
+        ) {
+            $waterStr .= 'dy/' . $dy . '/';
+        }
+
+        // 拼接自适应原图的短边比例
+        if (!is_null($watermarkScale)
+            && is_numeric($watermarkScale)
+            && $watermarkScale > 0
+            && $watermarkScale < 1
+        ) {
+            $waterStr .= 'ws/' . $watermarkScale . '/';
+        }
+
+        // 如果有query_string用|线分割实现多参数
+        return $url . ($this->hasQuery($url) ? '|' : '?') . $waterStr;
+    }
+
+    /**
+     * 文字水印
+     *
+     * @param  string $url 图片链接
+     * @param  string $text 文字
+     * @param  string $font 文字字体
+     * @param  string $fontSize 文字字号
+     * @param  string $fontColor 文字颜色
+     * @param  numeric $dissolve 透明度
+     * @param  string $gravity 水印位置
+     * @param  numeric $dx 横轴边距
+     * @param  numeric $dy 纵轴边距
+     * @link   http://developer.qiniu.com/code/v6/api/kodo-api/image/watermark.html#text-watermark
+     * @return string
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    public function waterText(
+        $url,
+        $text,
+        $font = '黑体',
+        $fontSize = 0,
+        $fontColor = null,
+        $dissolve = 100,
+        $gravity = 'SouthEast',
+        $dx = null,
+        $dy = null
+    ) {
+        // url合法效验
+        if (!$this->isUrl($url)) {
+            return $url;
+        }
+
+        $waterStr = 'watermark/2/text/'
+            . \Qiniu\base64_urlSafeEncode($text) . '/font/'
+            . \Qiniu\base64_urlSafeEncode($font) . '/';
+
+        // 拼接文字大小
+        if (is_int($fontSize)) {
+            $waterStr .= 'fontsize/' . $fontSize . '/';
+        }
+
+        // 拼接文字颜色
+        if (!is_null($fontColor)
+            && $fontColor
+        ) {
+            $waterStr .= 'fill/' . \Qiniu\base64_urlSafeEncode($fontColor) . '/';
+        }
+
+        // 拼接水印透明度
+        if (is_numeric($dissolve)
+            && $dissolve <= 100
+        ) {
+            $waterStr .= 'dissolve/' . $dissolve . '/';
+        }
+
+        // 拼接水印位置
+        if (in_array($gravity, $this->gravityArr, true)) {
+            $waterStr .= 'gravity/' . $gravity . '/';
+        }
+
+        // 拼接横轴边距
+        if (!is_null($dx)
+            && is_numeric($dx)
+        ) {
+            $waterStr .= 'dx/' . $dx . '/';
+        }
+
+        // 拼接纵轴边距
+        if (!is_null($dy)
+            && is_numeric($dy)
+        ) {
+            $waterStr .= 'dy/' . $dy . '/';
+        }
+
+        // 如果有query_string用|线分割实现多参数
+        return $url . ($this->hasQuery($url) ? '|' : '?') . $waterStr;
+    }
+
+    /**
+     * 效验url合法性
+     *
+     * @param  string $url url链接
+     * @return string
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    protected function isUrl($url)
+    {
+        $urlArr = parse_url($url);
+
+        return $urlArr['scheme']
+        && in_array($urlArr['scheme'], array('http', 'https'))
+        && $urlArr['host']
+        && $urlArr['path'];
+    }
+
+    /**
+     * 检测是否有query
+     *
+     * @param  string $url url链接
+     * @return string
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    protected function hasQuery($url)
+    {
+        $urlArr = parse_url($url);
+
+        return !empty($urlArr['query']);
+    }
+}

+<?php
+
+namespace Qiniu\Processing;
+
+use Qiniu\Http\Client;
+use Qiniu\Http\Error;
+
+final class Operation
+{
+
+    private $auth;
+    private $token_expire;
+    private $domain;
+
+    public function __construct($domain, $auth = null, $token_expire = 3600)
+    {
+        $this->auth = $auth;
+        $this->domain = $domain;
+        $this->token_expire = $token_expire;
+    }
+
+
+    /**
+     * 对资源文件进行处理
+     *
+     * @param $key   待处理的资源文件名
+     * @param $fops   string|array  fop操作，多次fop操作以array的形式传入。
+     *                eg. imageView2/1/w/200/h/200, imageMogr2/thumbnail/!75px
+     *
+     * @return array 文件处理后的结果及错误。
+     *
+     * @link http://developer.qiniu.com/docs/v6/api/reference/fop/
+     */
+    public function execute($key, $fops)
+    {
+        $url = $this->buildUrl($key, $fops);
+        $resp = Client::get($url);
+        if (!$resp->ok()) {
+            return array(null, new Error($url, $resp));
+        }
+        if ($resp->json() !== null) {
+            return array($resp->json(), null);
+        }
+        return array($resp->body, null);
+    }
+
+    public function buildUrl($key, $fops, $protocol = 'http')
+    {
+        if (is_array($fops)) {
+            $fops = implode('|', $fops);
+        }
+
+        $url = $protocol . "://$this->domain/$key?$fops";
+        if ($this->auth !== null) {
+            $url = $this->auth->privateDownloadUrl($url, $this->token_expire);
+        }
+
+        return $url;
+    }
+}

+<?php
+namespace Qiniu\Processing;
+
+use Qiniu\Config;
+use Qiniu\Http\Client;
+use Qiniu\Http\Error;
+use Qiniu\Processing\Operation;
+
+/**
+ * 持久化处理类,该类用于主动触发异步持久化操作.
+ *
+ * @link http://developer.qiniu.com/docs/v6/api/reference/fop/pfop/pfop.html
+ */
+final class PersistentFop
+{
+    /**
+     * @var 账号管理密钥对，Auth对象
+     */
+    private $auth;
+
+    /*
+     * @var 配置对象，Config 对象
+     * */
+    private $config;
+
+
+    public function __construct($auth, $config = null)
+    {
+        $this->auth = $auth;
+        if ($config == null) {
+            $this->config = new Config();
+        } else {
+            $this->config = $config;
+        }
+    }
+
+    /**
+     * 对资源文件进行异步持久化处理
+     * @param $bucket     资源所在空间
+     * @param $key        待处理的源文件
+     * @param $fops       string|array  待处理的pfop操作，多个pfop操作以array的形式传入。
+     *                    eg. avthumb/mp3/ab/192k, vframe/jpg/offset/7/w/480/h/360
+     * @param $pipeline   资源处理队列
+     * @param $notify_url 处理结果通知地址
+     * @param $force      是否强制执行一次新的指令
+     *
+     *
+     * @return array 返回持久化处理的persistentId, 和返回的错误。
+     *
+     * @link http://developer.qiniu.com/docs/v6/api/reference/fop/
+     */
+    public function execute($bucket, $key, $fops, $pipeline = null, $notify_url = null, $force = false)
+    {
+        if (is_array($fops)) {
+            $fops = implode(';', $fops);
+        }
+        $params = array('bucket' => $bucket, 'key' => $key, 'fops' => $fops);
+        \Qiniu\setWithoutEmpty($params, 'pipeline', $pipeline);
+        \Qiniu\setWithoutEmpty($params, 'notifyURL', $notify_url);
+        if ($force) {
+            $params['force'] = 1;
+        }
+        $data = http_build_query($params);
+        $scheme = "http://";
+        if ($this->config->useHTTPS === true) {
+            $scheme = "https://";
+        }
+        $url = $scheme . Config::API_HOST . '/pfop/';
+        $headers = $this->auth->authorization($url, $data, 'application/x-www-form-urlencoded');
+        $headers['Content-Type'] = 'application/x-www-form-urlencoded';
+        $response = Client::post($url, $data, $headers);
+        if (!$response->ok()) {
+            return array(null, new Error($url, $response));
+        }
+        $r = $response->json();
+        $id = $r['persistentId'];
+        return array($id, null);
+    }
+
+    public function status($id)
+    {
+        $scheme = "http://";
+
+        if ($this->config->useHTTPS === true) {
+            $scheme = "https://";
+        }
+        $url = $scheme . Config::API_HOST . "/status/get/prefop?id=$id";
+        $response = Client::get($url);
+        if (!$response->ok()) {
+            return array(null, new Error($url, $response));
+        }
+        return array($response->json(), null);
+    }
+}

+<?php
+namespace Qiniu\Rtc;
+
+use Qiniu\Http\Client;
+use Qiniu\Http\Error;
+use Qiniu\Config;
+use Qiniu\Auth;
+
+class AppClient
+{
+    private $auth;
+    private $baseURL;
+
+    public function __construct(Auth $auth)
+    {
+        $this->auth = $auth;
+
+        $this->baseURL = sprintf("%s/%s/apps", Config::RTCAPI_HOST, Config::RTCAPI_VERSION);
+    }
+
+    /*
+     * hub: 直播空间名
+     * title: app 的名称  注意，Title 不是唯一标识，重复 create 动作将生成多个 app
+     * maxUsers：人数限制
+     * NoAutoKickUser: bool 类型，可选，禁止自动踢人（抢流）。默认为 false ，
+       即同一个身份的 client (app/room/user) ，新的连麦请求可以成功，旧连接被关闭。
+     */
+    public function createApp($hub, $title, $maxUsers = null, $noAutoKickUser = null)
+    {
+        $params['hub'] = $hub;
+        $params['title'] = $title;
+        if (!empty($maxUsers)) {
+            $params['maxUsers'] = $maxUsers;
+        }
+        if (!empty($noAutoKickUser)) {
+            $params['noAutoKickUser'] = $noAutoKickUser;
+        }
+        $body = json_encode($params);
+        $ret = $this->post($this->baseURL, $body);
+        return $ret;
+    }
+
+    /*
+     * appId: app 的唯一标识，创建的时候由系统生成。
+     * Title: app 的名称， 可选。
+     * Hub: 绑定的直播 hub，可选，用于合流后 rtmp 推流。
+     * MaxUsers: int 类型，可选，连麦房间支持的最大在线人数。
+     * NoAutoKickUser: bool 类型，可选，禁止自动踢人。
+     * MergePublishRtmp: 连麦合流转推 RTMP 的配置，可选择。其详细配置包括如下
+            Enable: 布尔类型，用于开启和关闭所有房间的合流功能。
+            AudioOnly: 布尔类型，可选，指定是否只合成音频。
+            Height, Width: int64，可选，指定合流输出的高和宽，默认为 640 x 480。
+            OutputFps: int64，可选，指定合流输出的帧率，默认为 25 fps 。
+            OutputKbps: int64，可选，指定合流输出的码率，默认为 1000 。
+            URL: 合流后转推旁路直播的地址，可选，支持魔法变量配置按照连麦房间号生成不同的推流地址。如果是转推到七牛直播云，不建议使用该配置。
+            StreamTitle: 转推七牛直播云的流名，可选，支持魔法变量配置按照连麦房间号生成不同的流名。例如，配置 Hub 为 qn-zhibo ，配置 StreamTitle 为 $(roomName) ，则房间 meeting-001 的合流将会被转推到 rtmp://pili-publish.qn-zhibo.***.com/qn-zhibo/meeting-001地址。详细配置细则，请咨询七牛技术支持。
+     */
+    public function updateApp($appId, $hub, $title, $maxUsers = null, $mergePublishRtmp = null, $noAutoKickUser = null)
+    {
+        $url = $this->baseURL . '/' . $appId;
+        $params['hub'] = $hub;
+        $params['title'] = $title;
+        if (!empty($maxUsers)) {
+            $params['maxUsers'] = $maxUsers;
+        }
+        if (!empty($noAutoKickUser)) {
+            $params['noAutoKickUser'] = $noAutoKickUser;
+        }
+        if (!empty($mergePublishRtmp)) {
+            $params['mergePublishRtmp'] = $mergePublishRtmp;
+        }
+        $body = json_encode($params);
+        $ret = $this->post($url, $body);
+        return $ret;
+    }
+
+    /*
+     * appId: app 的唯一标识，创建的时候由系统生成。
+     */
+    public function getApp($appId)
+    {
+        $url = $this->baseURL . '/' . $appId;
+        $ret  = $this->get($url);
+        return $ret;
+    }
+
+    /*
+     * appId: app 的唯一标识，创建的时候由系统生成
+     */
+    public function deleteApp($appId)
+    {
+        $url = $this->baseURL . '/' . $appId;
+        list(, $err)  = $this->delete($url);
+        return $err;
+    }
+
+    /*
+     * 获取房间的人数
+     * appId: app 的唯一标识，创建的时候由系统生成。
+     * roomName: 操作所查询的连麦房间。
+     */
+    public function listUser($appId, $roomName)
+    {
+        $url = sprintf("%s/%s/rooms/%s/users", $this->baseURL, $appId, $roomName);
+        $ret  = $this->get($url);
+        return $ret;
+    }
+
+   /*
+    * 踢出玩家
+    * appId: app 的唯一标识，创建的时候由系统生成。
+    * roomName: 连麦房间
+    * userId: 请求加入房间的用户ID
+    */
+    public function kickUser($appId, $roomName, $userId)
+    {
+        $url = sprintf("%s/%s/rooms/%s/users/%s", $this->baseURL, $appId, $roomName, $userId);
+        list(, $err)  = $this->delete($url);
+        return $err;
+    }
+
+    /*
+     * 获取房间的人数
+     * appId: app 的唯一标识，创建的时候由系统生成。
+     * prefix: 所查询房间名的前缀索引，可以为空。
+     * offset: int 类型，分页查询的位移标记。
+     * limit: int 类型，此次查询的最大长度。
+     * GET /v3/apps/<AppID>/rooms?prefix=<RoomNamePrefix>&offset=<Offset>&limit=<Limit>
+     */
+    public function listActiveRooms($appId, $prefix = null, $offset = null, $limit = null)
+    {
+        if (isset($prefix)) {
+            $query['prefix'] = $prefix;
+        }
+        if (isset($offset)) {
+            $query['offset'] = $offset;
+        }
+        if (isset($limit)) {
+            $query['limit'] = $limit;
+        }
+        if (isset($query) && !empty($query)) {
+            $query = '?' . http_build_query($query);
+            $url = sprintf("%s/%s/rooms%s", $this->baseURL, $appId, $query);
+        } else {
+            $url = sprintf("%s/%s/rooms", $this->baseURL, $appId);
+        }
+        $ret  = $this->get($url);
+        return $ret;
+    }
+
+    /*
+     * appId: app 的唯一标识，创建的时候由系统生成。
+     * roomName: 房间名称，需满足规格 ^[a-zA-Z0-9_-]{3,64}$
+     * userId: 请求加入房间的用户 ID，需满足规格 ^[a-zA-Z0-9_-]{3,50}$
+     * expireAt: int64 类型，鉴权的有效时间，传入以秒为单位的64位Unix
+       绝对时间，token 将在该时间后失效。
+     * permission: 该用户的房间管理权限，"admin" 或 "user"，默认为 "user" 。
+       当权限角色为 "admin" 时，拥有将其他用户移除出房间等特权.
+     */
+    public function appToken($appId, $roomName, $userId, $expireAt, $permission)
+    {
+        $params['appId'] = $appId;
+        $params['userId'] = $userId;
+        $params['roomName'] = $roomName;
+        $params['permission'] = $permission;
+        $params['expireAt'] = $expireAt;
+        $appAccessString = json_encode($params);
+        return $this->auth->signWithData($appAccessString);
+    }
+
+    private function get($url, $cType = null)
+    {
+        $rtcToken = $this->auth->authorizationV2($url, "GET", null, $cType);
+        $rtcToken['Content-Type'] = $cType;
+        $ret = Client::get($url, $rtcToken);
+        if (!$ret->ok()) {
+            return array(null, new Error($url, $ret));
+        }
+        return array($ret->json(), null);
+    }
+
+    private function delete($url, $contentType = 'application/json')
+    {
+        $rtcToken = $this->auth->authorizationV2($url, "DELETE", null, $contentType);
+        $rtcToken['Content-Type'] = $contentType;
+        $ret = Client::delete($url, $rtcToken);
+        if (!$ret->ok()) {
+            return array(null, new Error($url, $ret));
+        }
+        return array($ret->json(), null);
+    }
+
+    private function post($url, $body, $contentType = 'application/json')
+    {
+        $rtcToken = $this->auth->authorizationV2($url, "POST", $body, $contentType);
+        $rtcToken['Content-Type'] = $contentType;
+        $ret = Client::post($url, $body, $rtcToken);
+        if (!$ret->ok()) {
+            return array(null, new Error($url, $ret));
+        }
+        $r = ($ret->body === null) ? array() : $ret->json();
+        return array($r, null);
+    }
+}

+<?php
+namespace Qiniu;
+
+use Qiniu\Http\Client;
+use Qiniu\Http\Error;
+
+final class Zone
+{
+
+    //源站上传域名
+    public $srcUpHosts;
+    //CDN加速上传域名
+    public $cdnUpHosts;
+    //资源管理域名
+    public $rsHost;
+    //资源列举域名
+    public $rsfHost;
+    //资源处理域名
+    public $apiHost;
+    //IOVIP域名
+    public $iovipHost;
+
+    //构造一个Zone对象
+    public function __construct(
+        $srcUpHosts = array(),
+        $cdnUpHosts = array(),
+        $rsHost = "rs.qiniu.com",
+        $rsfHost = "rsf.qiniu.com",
+        $apiHost = "api.qiniu.com",
+        $iovipHost = null
+    ) {
+
+        $this->srcUpHosts = $srcUpHosts;
+        $this->cdnUpHosts = $cdnUpHosts;
+        $this->rsHost = $rsHost;
+        $this->rsfHost = $rsfHost;
+        $this->apiHost = $apiHost;
+        $this->iovipHost = $iovipHost;
+    }
+
+    //华东机房
+    public static function zone0()
+    {
+        $Zone_z0 = new Zone(
+            array("up.qiniup.com", 'up-jjh.qiniup.com', 'up-xs.qiniup.com'),
+            array('upload.qiniup.com', 'upload-jjh.qiniup.com', 'upload-xs.qiniup.com'),
+            'rs.qbox.me',
+            'rsf.qbox.me',
+            'api.qiniu.com',
+            'iovip.qbox.me'
+        );
+        return $Zone_z0;
+    }
+
+    //华北机房
+    public static function zone1()
+    {
+        $Zone_z1 = new Zone(
+            array('up-z1.qiniup.com'),
+            array('upload-z1.qiniup.com'),
+            "rs-z1.qbox.me",
+            "rsf-z1.qbox.me",
+            "api-z1.qiniu.com",
+            "iovip-z1.qbox.me"
+        );
+
+        return $Zone_z1;
+    }
+
+    //华南机房
+    public static function zone2()
+    {
+        $Zone_z2 = new Zone(
+            array('up-z2.qiniup.com', 'up-dg.qiniup.com', 'up-fs.qiniup.com'),
+            array('upload-z2.qiniup.com', 'upload-dg.qiniup.com', 'upload-fs.qiniup.com'),
+            "rs-z2.qbox.me",
+            "rsf-z2.qbox.me",
+            "api-z2.qiniu.com",
+            "iovip-z2.qbox.me"
+        );
+        return $Zone_z2;
+    }
+
+    //北美机房
+    public static function zoneNa0()
+    {
+        //北美机房
+        $Zone_na0 = new Zone(
+            array('up-na0.qiniup.com'),
+            array('upload-na0.qiniup.com'),
+            "rs-na0.qbox.me",
+            "rsf-na0.qbox.me",
+            "api-na0.qiniu.com",
+            "iovip-na0.qbox.me"
+        );
+        return $Zone_na0;
+    }
+
+    //新加坡机房
+    public static function zoneAs0()
+    {
+        //新加坡机房
+        $Zone_as0 = new Zone(
+            array('up-as0.qiniup.com'),
+            array('upload-as0.qiniup.com'),
+            "rs-as0.qbox.me",
+            "rsf-as0.qbox.me",
+            "api-as0.qiniu.com",
+            "iovip-as0.qbox.me"
+        );
+        return $Zone_as0;
+    }
+
+    /*
+     * GET /v2/query?ak=<ak>&&bucket=<bucket>
+     **/
+    public static function queryZone($ak, $bucket)
+    {
+        $zone = new Zone();
+        $url = Config::UC_HOST . '/v2/query' . "?ak=$ak&bucket=$bucket";
+        $ret = Client::Get($url);
+        if (!$ret->ok()) {
+            return array(null, new Error($url, $ret));
+        }
+        $r = ($ret->body === null) ? array() : $ret->json();
+        //print_r($ret);
+        //parse zone;
+
+        $iovipHost = $r['io']['src']['main'][0];
+        $zone->iovipHost = $iovipHost;
+        $accMain = $r['up']['acc']['main'][0];
+        array_push($zone->cdnUpHosts, $accMain);
+        if (isset($r['up']['acc']['backup'])) {
+            foreach ($r['up']['acc']['backup'] as $key => $value) {
+                array_push($zone->cdnUpHosts, $value);
+            }
+        }
+        $srcMain = $r['up']['src']['main'][0];
+        array_push($zone->srcUpHosts, $srcMain);
+        if (isset($r['up']['src']['backup'])) {
+            foreach ($r['up']['src']['backup'] as $key => $value) {
+                array_push($zone->srcUpHosts, $value);
+            }
+        }
+
+        //set specific hosts
+        if (strstr($zone->iovipHost, "z1") !== false) {
+            $zone->rsHost = "rs-z1.qbox.me";
+            $zone->rsfHost = "rsf-z1.qbox.me";
+            $zone->apiHost = "api-z1.qiniu.com";
+        } elseif (strstr($zone->iovipHost, "z2") !== false) {
+            $zone->rsHost = "rs-z2.qbox.me";
+            $zone->rsfHost = "rsf-z2.qbox.me";
+            $zone->apiHost = "api-z2.qiniu.com";
+        } elseif (strstr($zone->iovipHost, "na0") !== false) {
+            $zone->rsHost = "rs-na0.qbox.me";
+            $zone->rsfHost = "rsf-na0.qbox.me";
+            $zone->apiHost = "api-na0.qiniu.com";
+        } elseif (strstr($zone->iovipHost, "as0") !== false) {
+            $zone->rsHost = "rs-as0.qbox.me";
+            $zone->rsfHost = "rsf-as0.qbox.me";
+            $zone->apiHost = "api-as0.qiniu.com";
+        } else {
+            $zone->rsHost = "rs.qbox.me";
+            $zone->rsfHost = "rsf.qbox.me";
+            $zone->apiHost = "api.qiniu.com";
+        }
+
+        return $zone;
+    }
+}

+<?php
+
+namespace Qiniu;
+
+use Qiniu\Config;
+
+if (!defined('QINIU_FUNCTIONS_VERSION')) {
+    define('QINIU_FUNCTIONS_VERSION', Config::SDK_VER);
+
+    /**
+     * 计算文件的crc32检验码:
+     *
+     * @param $file string  待计算校验码的文件路径
+     *
+     * @return string 文件内容的crc32校验码
+     */
+    function crc32_file($file)
+    {
+        $hash = hash_file('crc32b', $file);
+        $array = unpack('N', pack('H*', $hash));
+        return sprintf('%u', $array[1]);
+    }
+
+    /**
+     * 计算输入流的crc32检验码
+     *
+     * @param $data 待计算校验码的字符串
+     *
+     * @return string 输入字符串的crc32校验码
+     */
+    function crc32_data($data)
+    {
+        $hash = hash('crc32b', $data);
+        $array = unpack('N', pack('H*', $hash));
+        return sprintf('%u', $array[1]);
+    }
+
+    /**
+     * 对提供的数据进行urlsafe的base64编码。
+     *
+     * @param string $data 待编码的数据，一般为字符串
+     *
+     * @return string 编码后的字符串
+     * @link http://developer.qiniu.com/docs/v6/api/overview/appendix.html#urlsafe-base64
+     */
+    function base64_urlSafeEncode($data)
+    {
+        $find = array('+', '/');
+        $replace = array('-', '_');
+        return str_replace($find, $replace, base64_encode($data));
+    }
+
+    /**
+     * 对提供的urlsafe的base64编码的数据进行解码
+     *
+     * @param string $str 待解码的数据，一般为字符串
+     *
+     * @return string 解码后的字符串
+     */
+    function base64_urlSafeDecode($str)
+    {
+        $find = array('-', '_');
+        $replace = array('+', '/');
+        return base64_decode(str_replace($find, $replace, $str));
+    }
+
+    /**
+     * Wrapper for JSON decode that implements error detection with helpful
+     * error messages.
+     *
+     * @param string $json JSON data to parse
+     * @param bool $assoc When true, returned objects will be converted
+     *                        into associative arrays.
+     * @param int $depth User specified recursion depth.
+     *
+     * @return mixed
+     * @throws \InvalidArgumentException if the JSON cannot be parsed.
+     * @link http://www.php.net/manual/en/function.json-decode.php
+     */
+    function json_decode($json, $assoc = false, $depth = 512)
+    {
+        static $jsonErrors = array(
+            JSON_ERROR_DEPTH => 'JSON_ERROR_DEPTH - Maximum stack depth exceeded',
+            JSON_ERROR_STATE_MISMATCH => 'JSON_ERROR_STATE_MISMATCH - Underflow or the modes mismatch',
+            JSON_ERROR_CTRL_CHAR => 'JSON_ERROR_CTRL_CHAR - Unexpected control character found',
+            JSON_ERROR_SYNTAX => 'JSON_ERROR_SYNTAX - Syntax error, malformed JSON',
+            JSON_ERROR_UTF8 => 'JSON_ERROR_UTF8 - Malformed UTF-8 characters, possibly incorrectly encoded'
+        );
+
+        if (empty($json)) {
+            return null;
+        }
+        $data = \json_decode($json, $assoc, $depth);
+
+        if (JSON_ERROR_NONE !== json_last_error()) {
+            $last = json_last_error();
+            throw new \InvalidArgumentException(
+                'Unable to parse JSON data: '
+                . (isset($jsonErrors[$last])
+                    ? $jsonErrors[$last]
+                    : 'Unknown error')
+            );
+        }
+
+        return $data;
+    }
+
+    /**
+     * 计算七牛API中的数据格式
+     *
+     * @param $bucket 待操作的空间名
+     * @param $key 待操作的文件名
+     *
+     * @return string  符合七牛API规格的数据格式
+     * @link http://developer.qiniu.com/docs/v6/api/reference/data-formats.html
+     */
+    function entry($bucket, $key)
+    {
+        $en = $bucket;
+        if (!empty($key)) {
+            $en = $bucket . ':' . $key;
+        }
+        return base64_urlSafeEncode($en);
+    }
+
+    /**
+     * array 辅助方法，无值时不set
+     *
+     * @param $array 待操作array
+     * @param $key key
+     * @param $value value 为null时 不设置
+     *
+     * @return array 原来的array，便于连续操作
+     */
+    function setWithoutEmpty(&$array, $key, $value)
+    {
+        if (!empty($value)) {
+            $array[$key] = $value;
+        }
+        return $array;
+    }
+
+    /**
+     * 缩略图链接拼接
+     *
+     * @param  string $url 图片链接
+     * @param  int $mode 缩略模式
+     * @param  int $width 宽度
+     * @param  int $height 长度
+     * @param  string $format 输出类型
+     * @param  int $quality 图片质量
+     * @param  int $interlace 是否支持渐进显示
+     * @param  int $ignoreError 忽略结果
+     * @return string
+     * @link http://developer.qiniu.com/code/v6/api/kodo-api/image/imageview2.html
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    function thumbnail(
+        $url,
+        $mode,
+        $width,
+        $height,
+        $format = null,
+        $quality = null,
+        $interlace = null,
+        $ignoreError = 1
+    ) {
+
+        static $imageUrlBuilder = null;
+        if (is_null($imageUrlBuilder)) {
+            $imageUrlBuilder = new \Qiniu\Processing\ImageUrlBuilder;
+        }
+
+        return call_user_func_array(array($imageUrlBuilder, 'thumbnail'), func_get_args());
+    }
+
+    /**
+     * 图片水印
+     *
+     * @param  string $url 图片链接
+     * @param  string $image 水印图片链接
+     * @param  numeric $dissolve 透明度
+     * @param  string $gravity 水印位置
+     * @param  numeric $dx 横轴边距
+     * @param  numeric $dy 纵轴边距
+     * @param  numeric $watermarkScale 自适应原图的短边比例
+     * @link   http://developer.qiniu.com/code/v6/api/kodo-api/image/watermark.html
+     * @return string
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    function waterImg(
+        $url,
+        $image,
+        $dissolve = 100,
+        $gravity = 'SouthEast',
+        $dx = null,
+        $dy = null,
+        $watermarkScale = null
+    ) {
+
+        static $imageUrlBuilder = null;
+        if (is_null($imageUrlBuilder)) {
+            $imageUrlBuilder = new \Qiniu\Processing\ImageUrlBuilder;
+        }
+
+        return call_user_func_array(array($imageUrlBuilder, 'waterImg'), func_get_args());
+    }
+
+    /**
+     * 文字水印
+     *
+     * @param  string $url 图片链接
+     * @param  string $text 文字
+     * @param  string $font 文字字体
+     * @param  string $fontSize 文字字号
+     * @param  string $fontColor 文字颜色
+     * @param  numeric $dissolve 透明度
+     * @param  string $gravity 水印位置
+     * @param  numeric $dx 横轴边距
+     * @param  numeric $dy 纵轴边距
+     * @link   http://developer.qiniu.com/code/v6/api/kodo-api/image/watermark.html#text-watermark
+     * @return string
+     * @author Sherlock Ren <sherlock_ren@icloud.com>
+     */
+    function waterText(
+        $url,
+        $text,
+        $font = '黑体',
+        $fontSize = 0,
+        $fontColor = null,
+        $dissolve = 100,
+        $gravity = 'SouthEast',
+        $dx = null,
+        $dy = null
+    ) {
+
+        static $imageUrlBuilder = null;
+        if (is_null($imageUrlBuilder)) {
+            $imageUrlBuilder = new \Qiniu\Processing\ImageUrlBuilder;
+        }
+
+        return call_user_func_array(array($imageUrlBuilder, 'waterText'), func_get_args());
+    }
+
+    /**
+     *  从uptoken解析accessKey和bucket
+     *
+     * @param $upToken
+     * @return array(ak,bucket,err=null)
+     */
+    function explodeUpToken($upToken)
+    {
+        $items = explode(':', $upToken);
+        if (count($items) != 3) {
+            return array(null, null, "invalid uptoken");
+        }
+        $accessKey = $items[0];
+        $putPolicy = json_decode(base64_decode($items[2]));
+        $scope = $putPolicy->scope;
+        $scopeItems = explode(':', $scope);
+        $bucket = $scopeItems[0];
+        return array($accessKey, $bucket, null);
+    }
+}