From 2f48a7c54854caadcbe04c15738a2b84a6f6fb39 Mon Sep 17 00:00:00 2001 From: walkor Date: Mon, 9 Mar 2020 16:33:21 +0800 Subject: [PATCH] remove webserver --- Protocols/Http.php | 2 +- Protocols/Http/Request.php | 2 +- WebServer.php | 328 ------------------------------------- 3 files changed, 2 insertions(+), 330 deletions(-) delete mode 100644 WebServer.php diff --git a/Protocols/Http.php b/Protocols/Http.php index b903e4e79..841192b7f 100644 --- a/Protocols/Http.php +++ b/Protocols/Http.php @@ -210,7 +210,7 @@ public static function encode($response, TcpConnection $connection) $body_len = (int)\filesize($file); $response->header('Content-Length', $body_len); if ($body_len < 1024 * 1024) { - $connection->send((string)$response . file_get_contents($file, false, null, -1, $body_len), true); + $connection->send((string)$response . file_get_contents($file, false, null, 0, $body_len), true); return ''; } $handler = \fopen($file, 'r'); diff --git a/Protocols/Http/Request.php b/Protocols/Http/Request.php index 37728d7e3..21b8edd00 100644 --- a/Protocols/Http/Request.php +++ b/Protocols/Http/Request.php @@ -445,7 +445,7 @@ protected function parseGet() * * @return void */ - public function parsePost() + protected function parsePost() { $body_buffer = $this->rawBody(); $this->_data['post'] = $this->_data['files'] = array(); diff --git a/WebServer.php b/WebServer.php deleted file mode 100644 index a9a750ae0..000000000 --- a/WebServer.php +++ /dev/null @@ -1,328 +0,0 @@ - - * @copyright walkor - * @link http://www.workerman.net/ - * @license http://www.opensource.org/licenses/mit-license.php MIT License - */ -namespace Workerman; - -use Workerman\Protocols\Http; -use Workerman\Protocols\HttpCache; -use Workerman\Connection\TcpConnection; - -/** - * WebServer. - */ -class WebServer extends Worker -{ - /** - * Virtual host to path mapping. - * - * @var array ['workerman.net'=>'/home', 'www.workerman.net'=>'home/www'] - */ - protected $serverRoot = array(); - - /** - * Mime mapping. - * - * @var array - */ - protected static $mimeTypeMap = array(); - - - /** - * Used to save user OnWorkerStart callback settings. - * - * @var callable - */ - protected $_onWorkerStart = null; - - /** - * Add virtual host. - * - * @param string $domain - * @param string $config - * @return void - */ - public function addRoot($domain, $config) - { - if (\is_string($config)) { - $config = array('root' => $config); - } - $this->serverRoot[$domain] = $config; - } - - /** - * Construct. - * - * @param string $socket_name - * @param array $context_option - */ - public function __construct($socket_name, array $context_option = array()) - { - list(, $address) = \explode(':', $socket_name, 2); - parent::__construct('http:' . $address, $context_option); - $this->name = 'WebServer'; - } - - /** - * Run webserver instance. - * - * @see Workerman.Worker::run() - */ - public function run() - { - $this->_onWorkerStart = $this->onWorkerStart; - $this->onWorkerStart = array($this, 'onWorkerStart'); - $this->onMessage = array($this, 'onMessage'); - parent::run(); - } - - /** - * Emit when process start. - * - * @throws \Exception - */ - public function onWorkerStart() - { - if (empty($this->serverRoot)) { - Worker::safeEcho(new \Exception('server root not set, please use WebServer::addRoot($domain, $root_path) to set server root path')); - exit(250); - } - - // Init mimeMap. - $this->initMimeTypeMap(); - - // Try to emit onWorkerStart callback. - if ($this->_onWorkerStart) { - try { - \call_user_func($this->_onWorkerStart, $this); - } catch (\Exception $e) { - self::log($e); - exit(250); - } catch (\Error $e) { - self::log($e); - exit(250); - } - } - } - - /** - * Init mime map. - * - * @return void - */ - public function initMimeTypeMap() - { - $mime_file = Http::getMimeTypesFile(); - if (!\is_file($mime_file)) { - $this->log("$mime_file mime.type file not fond"); - return; - } - $items = \file($mime_file, \FILE_IGNORE_NEW_LINES | \FILE_SKIP_EMPTY_LINES); - if (!\is_array($items)) { - $this->log("get $mime_file mime.type content fail"); - return; - } - foreach ($items as $content) { - if (\preg_match("/\s*(\S+)\s+(\S.+)/", $content, $match)) { - $mime_type = $match[1]; - $workerman_file_extension_var = $match[2]; - $workerman_file_extension_array = \explode(' ', \substr($workerman_file_extension_var, 0, -1)); - foreach ($workerman_file_extension_array as $workerman_file_extension) { - self::$mimeTypeMap[$workerman_file_extension] = $mime_type; - } - } - } - } - - /** - * Emit when http message coming. - * - * @param TcpConnection $connection - * @return void - */ - public function onMessage(TcpConnection $connection) - { - // REQUEST_URI. - $workerman_url_info = \parse_url('http://'.$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI']); - if (!$workerman_url_info) { - Http::header('HTTP/1.1 400 Bad Request'); - if (\strtolower($_SERVER['HTTP_CONNECTION']) === "keep-alive") { - $connection->send('

400 Bad Request

'); - } else { - $connection->close('

400 Bad Request

'); - } - return; - } - - $workerman_path = isset($workerman_url_info['path']) ? $workerman_url_info['path'] : '/'; - - $workerman_path_info = \pathinfo($workerman_path); - $workerman_file_extension = isset($workerman_path_info['extension']) ? $workerman_path_info['extension'] : ''; - if ($workerman_file_extension === '') { - $workerman_path = ($len = \strlen($workerman_path)) && $workerman_path[$len - 1] === '/' ? $workerman_path . 'index.php' : $workerman_path . '/index.php'; - $workerman_file_extension = 'php'; - } - - $workerman_siteConfig = isset($this->serverRoot[$_SERVER['SERVER_NAME']]) ? $this->serverRoot[$_SERVER['SERVER_NAME']] : \current($this->serverRoot); - $workerman_root_dir = $workerman_siteConfig['root']; - $workerman_file = "$workerman_root_dir/$workerman_path"; - if(isset($workerman_siteConfig['additionHeader'])){ - Http::header($workerman_siteConfig['additionHeader']); - } - if ($workerman_file_extension === 'php' && !\is_file($workerman_file)) { - $workerman_file = "$workerman_root_dir/index.php"; - if (!\is_file($workerman_file)) { - $workerman_file = "$workerman_root_dir/index.html"; - $workerman_file_extension = 'html'; - } - } - - // File exsits. - if (\is_file($workerman_file)) { - // Security check. - if ((!($workerman_request_realpath = \realpath($workerman_file)) || !($workerman_root_dir_realpath = \realpath($workerman_root_dir))) || 0 !== \strpos($workerman_request_realpath, - $workerman_root_dir_realpath) - ) { - Http::header('HTTP/1.1 400 Bad Request'); - if (\strtolower($_SERVER['HTTP_CONNECTION']) === "keep-alive") { - $connection->send('

400 Bad Request

'); - } else { - $connection->close('

400 Bad Request

'); - } - return; - } - - $workerman_file = \realpath($workerman_file); - - // Request php file. - if ($workerman_file_extension === 'php') { - $workerman_cwd = \getcwd(); - \chdir($workerman_root_dir); - \ini_set('display_errors', 'off'); - \ob_start(); - // Try to include php file. - try { - // $_SERVER. - $_SERVER['REMOTE_ADDR'] = $connection->getRemoteIp(); - $_SERVER['REMOTE_PORT'] = $connection->getRemotePort(); - include $workerman_file; - } catch (\Exception $e) { - // Jump_exit? - if ($e->getMessage() !== 'jump_exit') { - Worker::safeEcho($e); - } - } - $content = \ob_get_clean(); - \ini_set('display_errors', 'on'); - if (\strtolower($_SERVER['HTTP_CONNECTION']) === "keep-alive") { - $connection->send($content); - } else { - $connection->close($content); - } - \chdir($workerman_cwd); - return; - } - - // Send file to client. - return self::sendFile($connection, $workerman_file); - } else { - // 404 - Http::header("HTTP/1.1 404 Not Found"); - if(isset($workerman_siteConfig['custom404']) && \file_exists($workerman_siteConfig['custom404'])){ - $html404 = \file_get_contents($workerman_siteConfig['custom404']); - }else{ - $html404 = '404 File not found

404 Not Found

'; - } - if (\strtolower($_SERVER['HTTP_CONNECTION']) === "keep-alive") { - $connection->send($html404); - } else { - $connection->close($html404); - } - return; - } - } - - public static function sendFile($connection, $file_path) - { - // Check 304. - $info = \stat($file_path); - $modified_time = $info ? \date('D, d M Y H:i:s', $info['mtime']) . ' ' . \date_default_timezone_get() : ''; - if (!empty($_SERVER['HTTP_IF_MODIFIED_SINCE']) && $info) { - // Http 304. - if ($modified_time === $_SERVER['HTTP_IF_MODIFIED_SINCE']) { - // 304 - Http::header('HTTP/1.1 304 Not Modified'); - // Send nothing but http headers.. - if (\strtolower($_SERVER['HTTP_CONNECTION']) === "keep-alive") { - $connection->send(''); - } else { - $connection->close(''); - } - return; - } - } - - // Http header. - if ($modified_time) { - $modified_time = "Last-Modified: $modified_time\r\n"; - } - $file_size = \filesize($file_path); - $file_info = \pathinfo($file_path); - $extension = isset($file_info['extension']) ? $file_info['extension'] : ''; - $file_name = isset($file_info['filename']) ? $file_info['filename'] : ''; - $header = "HTTP/1.1 200 OK\r\n"; - if (isset(self::$mimeTypeMap[$extension])) { - $header .= "Content-Type: " . self::$mimeTypeMap[$extension] . "\r\n"; - } else { - $header .= "Content-Type: application/octet-stream\r\n" - ."Content-Disposition: attachment; filename=\"$file_name\"\r\n"; - } - $header .= "Connection: keep-alive\r\n" - .$modified_time - ."Content-Length: $file_size\r\n\r\n"; - $trunk_limit_size = 1024*1024; - if ($file_size < $trunk_limit_size) { - return $connection->send($header.\file_get_contents($file_path), true); - } - $connection->send($header, true); - - // Read file content from disk piece by piece and send to client. - $connection->fileHandler = \fopen($file_path, 'r'); - $do_write = function()use($connection) - { - // Send buffer not full. - while(empty($connection->bufferFull)) - { - // Read from disk. - $buffer = \fread($connection->fileHandler, 8192); - // Read eof. - if($buffer === '' || $buffer === false) - { - return; - } - $connection->send($buffer, true); - } - }; - // Send buffer full. - $connection->onBufferFull = function($connection) - { - $connection->bufferFull = true; - }; - // Send buffer drain. - $connection->onBufferDrain = function($connection)use($do_write) - { - $connection->bufferFull = false; - $do_write(); - }; - $do_write(); - } -}