432 lines
10 KiB
PHP
432 lines
10 KiB
PHP
<?php
|
||
declare(strict_types=1);
|
||
|
||
use Nyholm\Psr7\Factory\Psr17Factory;
|
||
use Spiral\Goridge\RPC\RPC;
|
||
use Spiral\RoadRunner\Http\PSR7Worker;
|
||
use Spiral\RoadRunner\Jobs\Consumer;
|
||
use Spiral\RoadRunner\Jobs\Jobs;
|
||
use Spiral\RoadRunner\Jobs\Task\ReceivedTaskInterface;
|
||
use Spiral\RoadRunner\Worker;
|
||
|
||
include "vendor/autoload.php";
|
||
include 'response.class.php';
|
||
|
||
/**
|
||
* The zand router class file of ZenTaoPHP framework.
|
||
*
|
||
* The author disclaims copyright to this source code. In place of
|
||
* a legal notice, here is a blessing:
|
||
*
|
||
* May you do good and not evil.
|
||
* May you find forgiveness for yourself and forgive others.
|
||
* May you share freely, never taking more than you give.
|
||
*/
|
||
|
||
/**
|
||
* router类。
|
||
* The router class.
|
||
*
|
||
* @package framework
|
||
*/
|
||
include dirname(__DIR__) . '/router.class.php';
|
||
|
||
class zandRouter extends router
|
||
{
|
||
/**
|
||
* 全局变量的快照
|
||
* Snaps for global variables.
|
||
*
|
||
* @static
|
||
* @var array
|
||
* @access public
|
||
*/
|
||
static $snaps = array();
|
||
|
||
/**
|
||
* 构造方法, 设置路径，类，超级变量等。注意：
|
||
* 1.应该使用createApp()方法实例化router类；
|
||
* 2.如果$appRoot为空，框架会根据$appName计算应用路径。
|
||
*
|
||
* The construct function.
|
||
* Prepare all the paths, classes, super objects and so on.
|
||
* Notice:
|
||
* 1. You should use the createApp() method to get an instance of the router.
|
||
* 2. If the $appRoot is empty, the framework will compute the appRoot according the $appName
|
||
*
|
||
* @param string $appName the name of the app
|
||
* @param string $appRoot the root path of the app
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function __construct(string $appName = 'demo', string $appRoot = '')
|
||
{
|
||
$_SERVER['HTTP_USER_AGENT'] = '';
|
||
$_SERVER['SCRIPT_NAME'] = '/index.php';
|
||
$_SERVER['SCRIPT_FILENAME'] = dirname(__DIR__, 2) . '/www/index.php';
|
||
|
||
$this->worker = new zandWorker();
|
||
$this->consumer = new Consumer();
|
||
|
||
parent::__construct($appName, $appRoot);
|
||
|
||
/* Snap. */
|
||
global $filter;
|
||
|
||
self::$snaps['config'] = clone $this->config;
|
||
self::$snaps['lang'] = clone $this->lang;
|
||
self::$snaps['filter'] = clone $filter;
|
||
}
|
||
|
||
/**
|
||
* 初始化全局变量和客户端信息。
|
||
* Init global variables and client.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function initRequest(): void
|
||
{
|
||
global $config, $lang, $filter, $loadedTargets;
|
||
|
||
$config = clone self::$snaps['config'];
|
||
$lang = clone self::$snaps['lang'];
|
||
$filter = clone self::$snaps['filter'];
|
||
$loadedTargets = array();
|
||
|
||
$this->config = $config;
|
||
$this->lang = $lang;
|
||
$this->moduleName = NULL;
|
||
$this->methodName = NULL;
|
||
$this->rawModule = NULL;
|
||
$this->rawMethod = NULL;
|
||
$this->params = NULL;
|
||
$this->user = NULL;
|
||
|
||
self::$loadedConfigs = array();
|
||
self::$loadedLangs = array();
|
||
|
||
$this->setClient();
|
||
}
|
||
|
||
/**
|
||
* 关闭请求会话
|
||
* Close request.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function closeRequest()
|
||
{
|
||
$obLevel = ob_get_level();
|
||
for($i = 0; $i < $obLevel; $i++) ob_end_clean();
|
||
|
||
session_write_close();
|
||
}
|
||
|
||
/**
|
||
* 开启session。
|
||
* Start session.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function startSession(): void
|
||
{
|
||
$sessionName = $this->config->sessionVar;
|
||
|
||
if(!defined('SESSION_STARTED'))
|
||
{
|
||
global $config;
|
||
|
||
$driver = $config->db->driver;
|
||
if(!class_exists($driver))
|
||
{
|
||
$classFile = $this->coreLibRoot . 'dao' . DS . $driver . '.class.php';
|
||
include($classFile);
|
||
}
|
||
$dao = new $driver();
|
||
|
||
$ztSessionHandler = new zandSession($dao);
|
||
session_set_save_handler(
|
||
$ztSessionHandler->open(...),
|
||
$ztSessionHandler->close(...),
|
||
$ztSessionHandler->read(...),
|
||
$ztSessionHandler->write(...),
|
||
$ztSessionHandler->destroy(...),
|
||
$ztSessionHandler->gc(...)
|
||
);
|
||
|
||
session_name($sessionName);
|
||
session_set_cookie_params(0, $this->config->webRoot, '', $this->config->cookieSecure, true);
|
||
|
||
define('SESSION_STARTED', true);
|
||
}
|
||
else
|
||
{
|
||
$this->sessionID = isset($_COOKIE[$sessionName]) ? $_COOKIE[$sessionName] : session_create_id();
|
||
session_id($this->sessionID);
|
||
session_start();
|
||
|
||
$this->worker->response->setCookie($sessionName, $this->sessionID, 0);
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 消息队列的消息类型。
|
||
* Message in queue.
|
||
*
|
||
* @package zand
|
||
*/
|
||
class zandMessage
|
||
{
|
||
public $id;
|
||
public $type;
|
||
public $command;
|
||
}
|
||
|
||
/**
|
||
* 消息队列。
|
||
* Message queue.
|
||
*
|
||
* @package zand
|
||
*/
|
||
class zandQueue
|
||
{
|
||
private $mq;
|
||
|
||
public function __construct($queueName)
|
||
{
|
||
$jobs = new Jobs(RPC::create('tcp://127.0.0.1:6001'));
|
||
|
||
$this->mq = $jobs->connect('crons');
|
||
}
|
||
|
||
public function push($message)
|
||
{
|
||
$task = $this->mq->create(zandMessage::class, $message);
|
||
$this->mq->dispatch($task);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* HTTP worker.
|
||
*
|
||
* @package zand
|
||
*/
|
||
class zandWorker
|
||
{
|
||
/**
|
||
* RoadRunner PSR7 worker.
|
||
*
|
||
* @var object
|
||
* @access private
|
||
*/
|
||
private $psr7;
|
||
|
||
/**
|
||
* response.
|
||
*
|
||
* @var object
|
||
* @access public
|
||
*/
|
||
public $response;
|
||
|
||
/**
|
||
* Constructor.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function __construct()
|
||
{
|
||
$worker = Worker::create();
|
||
$factory = new Psr17Factory();
|
||
$this->psr7 = new PSR7Worker($worker, $factory, $factory, $factory);
|
||
$this->response = new zandResponse();
|
||
}
|
||
|
||
/**
|
||
* Wait request to run.
|
||
*
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function waitRequest()
|
||
{
|
||
$request = $this->psr7->waitRequest();
|
||
$this->initGlobal($request);
|
||
$this->response = new zandResponse();
|
||
}
|
||
|
||
/**
|
||
* Init global variables.
|
||
*
|
||
* @param object $request
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function initGlobal($request)
|
||
{
|
||
$_SERVER = $request->getServerParams();
|
||
$_SERVER['REQUEST_TIME'] = time();
|
||
$_SERVER['REQUEST_TIME_FLOAT'] = microtime(true);
|
||
$_SERVER['SERVER_PROTOCOL'] = $request->getUri()->getScheme();
|
||
$_SERVER['REQUEST_METHOD'] = $request->getMethod();
|
||
$_SERVER['SERVER_NAME'] = $request->getUri()->getHost();
|
||
$_SERVER['SERVER_PORT'] = $request->getUri()->getPort();
|
||
$_SERVER['REQUEST_URI'] = $request->getUri()->getPath();
|
||
$_SERVER['SCRIPT_NAME'] = '/index.php';
|
||
$_SERVER['PHP_SELF'] = 'index.php';
|
||
$_SERVER['PATH_TRANSLATED'] = 'index.php';
|
||
$_SERVER['HTTP_HOST'] = $_SERVER['SERVER_NAME'] . (in_array($_SERVER['SERVER_PORT'], array(80, 443)) ? '' : ':' . $_SERVER['SERVER_PORT']);
|
||
|
||
$query = $request->getUri()->getQuery();
|
||
if(!empty($query))
|
||
{
|
||
$_SERVER['REQUEST_URI'] .= '?' . $query;
|
||
$_SERVER['QUERY_STRING'] = $query;
|
||
}
|
||
|
||
$_GET = $request->getQueryParams();
|
||
$_POST = $request->getParsedBody();
|
||
$_COOKIE = $request->getCookieParams();
|
||
$_FILE = $request->getUploadedFiles();
|
||
}
|
||
|
||
/**
|
||
* Send response.
|
||
*
|
||
* @param string $body
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function respond(string $body)
|
||
{
|
||
$this->response->setBody($body);
|
||
$this->psr7->respond($this->response);
|
||
}
|
||
|
||
/**
|
||
* Send error.
|
||
*
|
||
* @param Exception $e
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function error(Exception $e)
|
||
{
|
||
$this->psr7->getWorker()->error((string)$e);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* MySQL实现的Session管理.
|
||
* Session handler implements by MySQL.
|
||
*
|
||
* @package zand
|
||
*/
|
||
class zandSession
|
||
{
|
||
/**
|
||
* DAO for database.
|
||
*
|
||
* @var object
|
||
* @access private
|
||
*/
|
||
private $dao;
|
||
|
||
/**
|
||
* Constructor.
|
||
*
|
||
* @param object $dao
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function __construct($dao)
|
||
{
|
||
$this->dao = $dao;
|
||
}
|
||
|
||
/**
|
||
* Open session.
|
||
*
|
||
* @param string $savePath
|
||
* @param string $sessionName
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function open($savePath, $sessionName)
|
||
{
|
||
$this->savePath = $savePath;
|
||
$this->sessionName = $sessionName;
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* Close session.
|
||
*
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function close()
|
||
{
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* Read session.
|
||
*
|
||
* @param string $id
|
||
* @access public
|
||
* @return string
|
||
*/
|
||
public function read($id)
|
||
{
|
||
$result = $this->dao->select('data')->from(TABLE_SESSION)->where('id')->eq($id)->fetch();
|
||
return $result ? $result->data : '';
|
||
}
|
||
|
||
/**
|
||
* Write session.
|
||
*
|
||
* @param string $id
|
||
* @param string $data
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function write($id, $data)
|
||
{
|
||
$data = array('id' => $id, 'data' => $data, 'timestamp' => time());
|
||
$this->dao->replace(TABLE_SESSION)->data($data)->exec();
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* Destroy session.
|
||
*
|
||
* @param string $id
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function destroy($id)
|
||
{
|
||
$this->dao->delete()->from(TABLE_SESSION)->where('id')->eq($id)->exec();
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* GC for session.
|
||
*
|
||
* @param int $maxlifetime
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function gc($maxlifetime)
|
||
{
|
||
$this->dao->delete()->from(TABLE_SESSION)->where('timestamp')->lt(time() - intval($maxlifetime))->exec();
|
||
return true;
|
||
}
|
||
}
|