当前位置：Gxlcms > PHP教程 > PHP-CLIWeb服务器

PHP-CLIWeb服务器

时间：2021-07-01 10:21:17 帮助过：76人阅读

需要 pthreads 扩展
php 命令行模式运行

写的比较急，没时间优化，有时间我会抽空优化一下

来自源地址: http://www.haowei.me/archives/1009.html
  2. ini_set('display_errors', false);
  3. error_reporting(0);
  5. if(!class_exists('thread')) {
  6. logs('PHP runtime environment not support multi thread');
  7. exit(0);
  8. }
  10. if(!function_exists('mime_content_type')) {
  11. logs('PHP runtime environment not support function mime_content_type()');
  12. exit(0);
  13. }
  15. class pthread extends thread {
  17. protected $socket = null;
  18. protected $arguments = null;
  19. protected $connections = 0;
  20. protected $octet_stream = false;
  22. public function __construct($socket, $arguments = array()) {
  24. $this->socket = $socket;
  25. $this->arguments = $arguments;
  26. if(!isset($this->arguments['ServerTokens']))
  27. $this->arguments['ServerTokens'] = 'off';
  30. }
  32. public function run() {
  34. date_default_timezone_set('UTC');
  36. $clients = 1;
  37. $maxRequests = !isset($this->arguments['MaxRequests'])?
  38. intval($this->arguments['MaxRequests']):
  39. 100;
  40. $timeout = 5;
  42. $connfd = socket_accept($this->socket);
  43. socket_set_option($connfd, SOL_SOCKET, SO_RCVTIMEO, array('sec' => $timeout, 'usec' => 0));
  45. $session = 1;
  47. while($session) {
  49. $buffer = '';
  50. while (( $buffer .= socket_read($connfd, 1024, PHP_BINARY_READ) ))
  51. if(strpos($buffer, "\r\n\r\n") !== false) break;
  53. if($buffer == '') {
  54. socket_close($connfd);
  55. $session = 0;
  56. }else{
  58. $availableRequests = $maxRequests - $clients;
  59. $clients++;
  61. $i = 0;
  62. $headers = array();
  63. array_push($headers, 'HTTP/1.1 200 OK');
  64. array_push($headers, 'Date: '. gmtdate());
  65. array_push($headers, 'Server: PHP-CLI/1.0');
  66. array_push($headers, 'Content-Type: text/html; charset=utf-8');
  67. array_push($headers, 'Connection: close');
  69. if($this->arguments['ServerTokens'] == 'on')
  70. $headers[2] = 'Server: PHP-CLI';
  72. $buffer = explode("\r\n", $buffer);
  74. $http_user_agent = '';
  75. $http_request_method = '';
  76. $http_request_file = '';
  77. $http_protocol = '';
  78. $extension = '';
  79. $mime_types = '';
  80. $this->octet_stream = false;
  82. foreach($buffer as $line) {
  83. $pattern = '/(GET|POST)\s\/(.*)\s(HTTP\/1\.[0-1])$/';
  84. if(preg_match($pattern, $line)) {
  85. $http_request_method = preg_replace($pattern, '\\1', $line);
  86. $http_request_file = preg_replace($pattern, '\\2', $line);
  87. $http_protocol = preg_replace($pattern, '\\3', $line);
  88. }
  89. $pattern = '/^User\-Agent: (.+)$/';
  90. if(preg_match($pattern, $line)) {
  91. $http_user_agent = preg_replace($pattern, '\\1', $line);
  92. }
  93. }
  95. $local_request_file = $this->arguments['DocumentRoot'].'/'. $http_request_file;
  96. if(file_exists($local_request_file) && is_file($local_request_file))
  97. $extension = pathinfo($local_request_file, PATHINFO_EXTENSION);
  99. if(file_exists($local_request_file)) {
  100. $array_key_exists = array_key_exists($extension, $this->arguments['MimeTypes']);
  102. if(is_file($local_request_file)) {
  103. if($array_key_exists) {
  104. $mime_types = $this->arguments['MimeTypes'][$extension];
  105. $headers[3] = sprintf('Content-Type: %s; charset=%s', $mime_types, 'utf-8');
  106. }else{
  107. $this->octet_stream = true;
  108. $headers[3] = sprintf('Content-Type: application/octet-stream');
  109. array_push($headers, 'Accept-Ranges: bytes');
  110. array_push($headers, 'Accept-Length: '.filesize($local_request_file));
  111. array_push($headers, 'Content-Disposition: attachment; filename='.basename($local_request_file));
  112. }
  113. }
  115. }
  117. $html = '';
  118. $code = '';
  119. $this->HttpStatusCode($local_request_file, $headers, $html, $code);
  121. if($availableRequests > 0) {
  122. $headers[4] = "Connection: keep-alive";
  123. $headers[5] = 'Keep-Alive: timeout='.$timeout.', max='.$maxRequests;
  124. }
  127. $headers[6] = 'Content-Length: '. strlen($html);
  129. $response = array(
  130. 'header'=> implode("\r\n", $headers) . "\r\n",
  131. 'html'=> $html);
  133. socket_write($connfd, implode("\r\n", $response));
  135. if($availableRequests <= 0) {
  136. socket_close($connfd);
  137. $session = 0;
  138. }
  140. $length = strlen($html);
  142. socket_getpeername($connfd, $address, $port);
  143. logs(sprintf('%s:%.0f -- "%s %s %s" %s %.0f "-" "%s"',
  144. $address,
  145. $port,
  146. $http_request_method,
  147. '/'.$http_request_file,
  148. $http_protocol,
  149. $code,
  150. $length,
  151. $http_user_agent));
  152. //logs('times '. intval($clients - 1), false);
  153. }
  154. }
  156. }
  158. public function error_page($statusCode, $ServerTokens) {
  160. $httpStatus = array('403'=> '403 Forbidden', '404'=> '404 Not Found');
  161. $string = "
  163. %s

  166. %s

  168. %s
  170. ";
  172. if(!in_array($ServerTokens, array('on', 'off')))
  173. $ServerTokens = 'off';
  175. return (string) sprintf($string,
  176. $httpStatus[$statusCode],
  177. $httpStatus[$statusCode],
  178. $ServerTokens == 'off' ? 'PHP-CLI/1.0' : 'PHP-CLI');
  180. }
  182. public function HttpStatusCode($file, &$headers, &$html, &$code) {
  184. $code = '200';
  185. if(!file_exists($file)) {
  186. $headers[0] = 'HTTP/1.1 404 Not Found';
  187. $html = $this->error_page('404', $this->arguments['ServerTokens']);
  188. $code = '404';
  189. return 0;
  190. }
  192. if(is_dir($file)){
  193. $find = false;
  194. $directoryIndex = $this->arguments['DirectoryIndex'];
  195. if(empty($directoryIndex)) {
  196. $headers[0] = 'HTTP/1.1 403 Forbidden';
  197. $code = '403';
  198. }else{
  199. $list = explode(' ', $directoryIndex);
  200. foreach($list as $index) {
  201. if(file_exists($file .'/'. $index)) {
  202. $file .= '/'. $index;
  203. if(file_exists($file) && is_file($file))
  204. $extension = pathinfo($file, PATHINFO_EXTENSION);
  205. $array_key_exists = array_key_exists($extension, $this->arguments['MimeTypes']);
  206. if($array_key_exists) {
  207. $mime_types = $this->arguments['MimeTypes'][$extension];
  208. }else{
  209. $this->otect_stream = true;
  210. $headers[3] = sprintf('Content-Type: application/octet-stream');
  211. array_push($headers, 'Accept-Ranges: bytes');
  212. array_push($headers, 'Accept-Length: '.filesize($local_request_file));
  213. array_push($headers, 'Content-Disposition: attachment; filename='.basename($local_request_file));
  214. }
  215. $find = true;
  216. break;
  217. }
  218. }
  219. }
  221. if(!$find) {
  222. $html = $this->error_page('403', $this->arguments['ServerTokens']);
  223. }else{
  224. if(!$this->octet_stream)
  225. $headers[3] = sprintf('Content-Type: %s; charset=%s', $mime_types, 'utf-8');
  226. $html = $this->get_local_handle_buffer($file);
  227. }
  229. return -1;
  231. }else{
  233. $html = $this->get_local_handle_buffer($file);
  235. }
  237. return 1;
  238. }
  240. public function get_local_handle_buffer($file) {
  241. $handle = fopen($file, 'rb');
  242. return $this->get_buffer($handle);
  243. }
  245. public function get_buffer($handle) {
  246. $buffer = '';
  247. if(!is_resource($handle)) return null;
  248. while(!feof($handle))
  249. $buffer .= fgets($handle, 1024);
  250. fclose($handle);
  251. return $buffer;
  252. }
  254. }
  256. function gmtdate() {
  257. return (string) date('D, d M Y H:i:s'). ' GMT';
  258. }
  260. function logs($string, $perfix = true) {
  261. ob_start();
  262. echo $perfix ?
  263. sprintf("[ %s ] %s\n", date('d-M-Y H:i:s'), $string) :
  264. sprintf("\0\0[ %s ]\n", $string);
  266. ob_end_flush();
  268. }
  270. $mime_types = array(
  271. 'htm'=> 'text/html',
  272. 'html'=> 'text/html',
  273. 'jpg'=> 'image/jpeg',
  274. 'jpeg'=> 'image/jpeg',
  275. 'png'=> 'image/png',
  276. 'js'=> 'text/javascript',
  277. 'css'=> 'text/css',
  278. 'xml'=> 'text/xml');
  280. $conf = array(
  281. 'MimeTypes'=> $mime_types,
  282. 'ServerTokens'=> 'on',
  283. 'MaxRequests'=> 100,
  284. 'Timeout'=> 15,
  285. 'Listen'=> 8080,
  286. 'DocumentRoot'=> '/home/www',
  287. 'DirectoryIndex'=> 'index.htm index.html');
  289. error_reporting(E_ALL);
  290. logs('Initializing the operating environment');
  291. sleep(1);
  293. set_time_limit(0);
  294. logs('Initializing PHP-CLI execution timeout');
  295. sleep(1);
  297. $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  298. logs('Initializing the socket');
  299. sleep(1);
  301. logs('Initialization bind local address any ip address');
  302. sleep(1);
  304. $int = socket_bind($socket, '0.0.0.0', $conf['Listen']);
  305. logs('Initialization bind local port '.$conf['Listen']);
  306. if(!$int){
  307. logs($conf['Listen'].' Port is occupied by other services'."\n");
  308. exit(0);
  309. }
  310. sleep(1);
  312. socket_listen($socket, 1024);
  313. logs('Opening a socket listening');
  314. sleep(1);
  316. logs('Waiting for clients to access');
  317. echo "\n";
  318. $i = 0;
  320. while(1) {
  321. $pthread[$i] = new pthread($socket, $conf);
  322. $pthread[$i]->start();
  323. $pthread[$i]->join();
  324. }

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！