128 lines
2.7 KiB
PHP
128 lines
2.7 KiB
PHP
<?php
|
|
|
|
|
|
namespace HttpServer;
|
|
|
|
use HttpServer\Events\Http;
|
|
use HttpServer\Events\Receive;
|
|
use HttpServer\Events\Packet;
|
|
use HttpServer\Events\WebSocket;
|
|
use Exception;
|
|
use Snowflake\Snowflake;
|
|
|
|
/**
|
|
* Class Server
|
|
* @package HttpServer
|
|
*
|
|
*
|
|
* @example [
|
|
* ['host'=> '127.0.0.1', 'port'=> 5775, 'mode'=> SWOOLE_TCP],
|
|
* ['host'=> '127.0.0.1', 'port'=> 5775, 'mode'=> SWOOLE_TCP],
|
|
* ['host'=> '127.0.0.1', 'port'=> 5775, 'mode'=> SWOOLE_TCP],
|
|
* ['host'=> '127.0.0.1', 'port'=> 5775, 'mode'=> SWOOLE_TCP],
|
|
* ['host'=> '127.0.0.1', 'port'=> 5775, 'mode'=> SWOOLE_UDP],
|
|
* ['host'=> '127.0.0.1', 'port'=> 5775, 'mode'=> SWOOLE_TCP]
|
|
* ]
|
|
*/
|
|
class Server extends Application
|
|
{
|
|
const HTTP = 'HTTP';
|
|
const TCP = 'TCP';
|
|
const PACKAGE = 'PACKAGE';
|
|
const WEBSOCKET = 'WEBSOCKET';
|
|
|
|
private $server = [
|
|
'HTTP' => [SWOOLE_TCP, Http::class],
|
|
'TCP' => [SWOOLE_TCP, Receive::class],
|
|
'PACKAGE' => [SWOOLE_UDP, Packet::class],
|
|
'WEBSOCKET' => [SWOOLE_SOCK_TCP, WebSocket::class],
|
|
];
|
|
|
|
/**
|
|
* @param array $configs
|
|
* @return array
|
|
* @throws Exception
|
|
*/
|
|
public function initCore(array $configs)
|
|
{
|
|
$response = [];
|
|
foreach ($configs as $server) {
|
|
$response[] = $this->create($server);
|
|
}
|
|
return $response;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $config
|
|
* @return mixed
|
|
* @throws Exception
|
|
*/
|
|
private function create($config)
|
|
{
|
|
$settings = $config['settings'] ?? [];
|
|
if (!isset($this->server[$config['type']])) {
|
|
throw new Exception('Unknown server type(' . $config['type'] . ').');
|
|
}
|
|
$server = $this->dispatchCreate($config, $settings);
|
|
if (isset($config['events'])) {
|
|
$this->createEventListen($config);
|
|
}
|
|
return $server;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $config
|
|
*/
|
|
protected function createEventListen($config)
|
|
{
|
|
if (!is_array($config['events'])) {
|
|
return;
|
|
}
|
|
$event = Snowflake::get()->event;
|
|
foreach ($config['events'] as $name => $_event) {
|
|
$event->on($name, $_event);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param $config
|
|
* @param $settings
|
|
* @return mixed
|
|
* @throws Exception
|
|
*/
|
|
private function dispatchCreate($config, $settings)
|
|
{
|
|
switch ($config['type']) {
|
|
case self::HTTP:
|
|
$handler = [
|
|
['request', [Http::class, 'onHandler']]
|
|
];
|
|
break;
|
|
case self::TCP:
|
|
$handler = [
|
|
['receive', [Receive::class, 'onReceive']]
|
|
];
|
|
break;
|
|
case self::PACKAGE:
|
|
$handler = [
|
|
['packet', [Packet::class, 'onHandler']]
|
|
];
|
|
break;
|
|
case self::WEBSOCKET:
|
|
$handler = [
|
|
['handshake', [WebSocket::class, 'onHandshake']],
|
|
['message', [WebSocket::class, 'onMessage']],
|
|
['close', [WebSocket::class, 'onClose']],
|
|
];
|
|
break;
|
|
default:
|
|
throw new Exception('Unknown server type(' . $config['type'] . ').');
|
|
}
|
|
return [$this->server[$config['type']], $config, $handler, $settings];
|
|
}
|
|
|
|
|
|
}
|