2019獨角獸企業重金招聘Python工程師標準>>>

封裝 xserver.php:? 優化將cookie或者session去掉

<?phpif (!class_exists('swoole_http_server')) {if (!class_exists('Swoole\Http\Server')) {echo "請確認是否已安裝Swoole\n";}else{echo "請編輯php.ini中:\n swoole.use_namespace=off\n";} }class XServer extends swoole_http_server {public $_GLOBAL_SESSION = [];public $route = ['get'=>[],'post'=>[],'put'=>[],'head'=>[],'delete'=>[]];/*** start* @param string $action* @param closure $callback*/public function start() {parent::on('request', function($req, $res){$do = $this->initRequest($req, $res, $this); $req = $do['req']; $res = $do['res'];if( isset($this->route[strtolower($req->server['request_method'])][$req->server['request_uri']]) )return call_user_func_array($this->route[strtolower($req->server['request_method'])][$req->server['request_uri']],[$req, $res, $do['get'], $do['post'], $do['server'], $do['session'], $this->_GLOBAL_SESSION, $ip ]);else return call_user_func_array($this->route['error']['404'],[$req, $res, $do['get'], $do['post'], $do['server'], $do['session'], $this->_GLOBAL_SESSION, $ip ]);});parent::start();}/*** all,get,post,put,head,delete通過本函數綁定路由* @param string $method* @param string $path* @param closure $callback*/public function path($method, $path, $callback){$this->route[$method][$path] = $callback;}/*** 綁定所有路由* @param string $path* @param closure $callback*/public function all($path, $callback){foreach (['get','post','head','put','delete'] as $method)$this->path($method, $path, $callback);}/*** GET路由* @param string $path* @param closure $callback*/public function get($path, $callback){$this->path('get', $path, $callback);}/*** POST路由* @param string $path* @param closure $callback*/public function post($path, $callback){$this->path('post', $path, $callback);}/*** PUT路由* @param string $path* @param closure $callback*/public function put($path, $callback){$this->path('put', $path, $callback);}/*** HEAD路由* @param string $path* @param closure $callback*/public function head($path, $callback){$this->path('head', $path, $callback);}/*** DELETE路由* @param string $path* @param closure $callback*/public function delete($path, $callback){$this->path('delete', $path, $callback);}/*** ERROR路由* @param string $path* @param closure $callback*/public function error($path, $callback){$this->path('error', $path, $callback);}public function initRequest($req, $res) {if (!isset($req->server)) $req->server = [];if (!isset($req->get)) $req->get = [];if (!isset($req->post)) $req->post = [];if (isset($req->server['accept-encoding']) && stripos($req->server['accept-encoding'], 'gzip')) {$res->gzip(5);}if (!isset($req->cookie) || !isset($req->cookie['sid']) || !$req->cookie['sid']) {$req->cookie['sid'] = md5(password_hash(time() . mt_rand(100000, 999999), 1));@$res->cookie('sid', $req->cookie['sid'], time() + 60 * 60 * 24 * 365 * 10, '/', '', false, true);}$_SESS_ID = $req->cookie['sid'];if (!isset($this->_GLOBAL_SESSION[$_SESS_ID]) || !is_array($this->_GLOBAL_SESSION[$_SESS_ID])) {$this->_GLOBAL_SESSION[$_SESS_ID] = [];}$_SESSION = &$this->_GLOBAL_SESSION[$_SESS_ID];if (isset($req->header)) {isset($req->header['if-none-match']) ? $req->server['if-none-match'] = $req->header['if-none-match'] : false;isset($req->header['if-modified-since']) ? $req->server['if-modified-since'] = $req->header['if-modified-since'] : false;isset($req->header['connection']) ? $req->server['connection'] = $req->header['connection'] : false;isset($req->header['accept']) ? $req->server['accept'] = $req->header['accept'] : false;isset($req->header['accept-encoding']) ? $req->server['accept-encoding'] = $req->header['accept-encoding'] : false;isset($req->header['accept-language']) ? $req->server['accept-language'] = $req->header['accept-language'] : false;isset($req->header['upgrade-insecure-requests']) ? $req->server['upgrade-insecure-requests'] = $req->header['upgrade-insecure-requests'] : false;isset($req->header['cache-control']) ? $req->server['cache-control'] = $req->header['cache-control'] : false;isset($req->header['pragma']) ? $req->server['pragma'] = $req->header['pragma'] : false;isset($req->header['referer']) ? $req->server['referer'] = $req->header['referer'] : false;isset($req->header['x-forwarded-for']) ? $req->server['remote_addr'] = $req->header['x-forwarded-for'] : false;stripos($req->server['remote_addr'], ',') ? $req->server['remote_addr'] = stripos($req->server['remote_addr'],',')[0] : false;}return ['req'=>$req, 'res'=>$res, 'session'=>$_SESSION, 'server'=>$req->server, 'get'=>$req->get, 'post'=>$req->post];} }class BaseException extends \Exception {var $data = [];function __construct($message, $code, $data = []) {if ($data == []) {$data = new \stdClass();}$this->data = $data;parent::__construct($message, $code);return $this;}function getData() {return $this->data;} }class QueueException extends BaseException {} class ApiException extends BaseException {}

使用: app.php

define('APP_PATH', dirname(__FILE__) . '/'); require_once APP_PATH.'xserver.php'; $server = new XServer("0.0.0.0", 3155); $server->get('/test/', function ($req, $res, $_X_GET, $_X_POST, $_X_SERVER, $_X_SESSION, $_X_GLOBAL, $ip) use ($server) {try {$res->end('TEST get');return;} catch (\ApiException $e) {} }); $server->post('/test/', function ($req, $res, $_X_GET, $_X_POST, $_X_SERVER, $_X_SESSION, $_X_GLOBAL, $ip) use ($server) {try {$res->end('TEST post');return;} catch (\ApiException $e) {} }); $server->all('/test/all/', function ($req, $res, $_X_GET, $_X_POST, $_X_SERVER, $_X_SESSION, $_X_GLOBAL, $ip) use ($server) {try {$res->end('TEST all');return;} catch (\ApiException $e) {} }); $server->start();

轉載于:https://my.oschina.net/mickelfeng/blog/1550467

總結

以上是生活随笔為你收集整理的Swoole 实现简单的路由的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。