Client.php 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156
  1. <?php
  2. namespace Qiniu\Http;
  3. use Qiniu\Config;
  4. use Qiniu\Http\Request;
  5. use Qiniu\Http\Response;
  6. final class Client
  7. {
  8. public static function get($url, array $headers = array())
  9. {
  10. $request = new Request('GET', $url, $headers);
  11. return self::sendRequest($request);
  12. }
  13. public static function delete($url, array $headers = array())
  14. {
  15. $request = new Request('DELETE', $url, $headers);
  16. return self::sendRequest($request);
  17. }
  18. public static function post($url, $body, array $headers = array())
  19. {
  20. $request = new Request('POST', $url, $headers, $body);
  21. return self::sendRequest($request);
  22. }
  23. public static function multipartPost(
  24. $url,
  25. $fields,
  26. $name,
  27. $fileName,
  28. $fileBody,
  29. $mimeType = null,
  30. array $headers = array()
  31. ) {
  32. $data = array();
  33. $mimeBoundary = md5(microtime());
  34. foreach ($fields as $key => $val) {
  35. array_push($data, '--' . $mimeBoundary);
  36. array_push($data, "Content-Disposition: form-data; name=\"$key\"");
  37. array_push($data, '');
  38. array_push($data, $val);
  39. }
  40. array_push($data, '--' . $mimeBoundary);
  41. $finalMimeType = empty($mimeType) ? 'application/octet-stream' : $mimeType;
  42. $finalFileName = self::escapeQuotes($fileName);
  43. array_push($data, "Content-Disposition: form-data; name=\"$name\"; filename=\"$finalFileName\"");
  44. array_push($data, "Content-Type: $finalMimeType");
  45. array_push($data, '');
  46. array_push($data, $fileBody);
  47. array_push($data, '--' . $mimeBoundary . '--');
  48. array_push($data, '');
  49. $body = implode("\r\n", $data);
  50. $contentType = 'multipart/form-data; boundary=' . $mimeBoundary;
  51. $headers['Content-Type'] = $contentType;
  52. $request = new Request('POST', $url, $headers, $body);
  53. return self::sendRequest($request);
  54. }
  55. private static function userAgent()
  56. {
  57. $sdkInfo = "QiniuPHP/" . Config::SDK_VER;
  58. $systemInfo = php_uname("s");
  59. $machineInfo = php_uname("m");
  60. $envInfo = "($systemInfo/$machineInfo)";
  61. $phpVer = phpversion();
  62. $ua = "$sdkInfo $envInfo PHP/$phpVer";
  63. return $ua;
  64. }
  65. public static function sendRequest($request)
  66. {
  67. $t1 = microtime(true);
  68. $ch = curl_init();
  69. $options = array(
  70. CURLOPT_USERAGENT => self::userAgent(),
  71. CURLOPT_RETURNTRANSFER => true,
  72. CURLOPT_SSL_VERIFYPEER => false,
  73. CURLOPT_SSL_VERIFYHOST => false,
  74. CURLOPT_HEADER => true,
  75. CURLOPT_NOBODY => false,
  76. CURLOPT_CUSTOMREQUEST => $request->method,
  77. CURLOPT_URL => $request->url,
  78. );
  79. // Handle open_basedir & safe mode
  80. if (!ini_get('safe_mode') && !ini_get('open_basedir')) {
  81. $options[CURLOPT_FOLLOWLOCATION] = true;
  82. }
  83. if (!empty($request->headers)) {
  84. $headers = array();
  85. foreach ($request->headers as $key => $val) {
  86. array_push($headers, "$key: $val");
  87. }
  88. $options[CURLOPT_HTTPHEADER] = $headers;
  89. }
  90. curl_setopt($ch, CURLOPT_HTTPHEADER, array('Expect:'));
  91. if (!empty($request->body)) {
  92. $options[CURLOPT_POSTFIELDS] = $request->body;
  93. }
  94. curl_setopt_array($ch, $options);
  95. $result = curl_exec($ch);
  96. $t2 = microtime(true);
  97. $duration = round($t2 - $t1, 3);
  98. $ret = curl_errno($ch);
  99. if ($ret !== 0) {
  100. $r = new Response(-1, $duration, array(), null, curl_error($ch));
  101. curl_close($ch);
  102. return $r;
  103. }
  104. $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  105. $header_size = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
  106. $headers = self::parseHeaders(substr($result, 0, $header_size));
  107. $body = substr($result, $header_size);
  108. curl_close($ch);
  109. return new Response($code, $duration, $headers, $body, null);
  110. }
  111. private static function parseHeaders($raw)
  112. {
  113. $headers = array();
  114. $headerLines = explode("\r\n", $raw);
  115. foreach ($headerLines as $line) {
  116. $headerLine = trim($line);
  117. $kv = explode(':', $headerLine);
  118. if (count($kv) > 1) {
  119. $kv[0] =self::ucwordsHyphen($kv[0]);
  120. $headers[$kv[0]] = trim($kv[1]);
  121. }
  122. }
  123. return $headers;
  124. }
  125. private static function escapeQuotes($str)
  126. {
  127. $find = array("\\", "\"");
  128. $replace = array("\\\\", "\\\"");
  129. return str_replace($find, $replace, $str);
  130. }
  131. private static function ucwordsHyphen($str)
  132. {
  133. return str_replace('- ', '-', ucwords(str_replace('-', '- ', $str)));
  134. }
  135. }