as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Revert "改名"

Browse Source 
This reverts commit fdf58326
This commit is contained in:
向林
2022-01-07 14:38:36 +08:00
parent f867f4be9e
commit c9726e5778
3 changed files with 27 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kiri-websocket-server/Server.php
+1 -63
View File
@@ -56,10 +56,6 @@ class Server extends AbstractServer implements OnHandshakeInterface, OnMessageIn
return;
}
$this->callback = $handler->callback[0];
$this->server->on(Constant::HANDSHAKE, [$this, 'onHandshake']);
$this->server->on(Constant::MESSAGE, [$this, 'onMessage']);
$this->server->on(Constant::CLOSE, [$this, 'onClose']);
}
@@ -114,7 +110,7 @@ class Server extends AbstractServer implements OnHandshakeInterface, OnMessageIn
{
try {
if ($this->callback instanceof OnHandshakeInterface) {
$this->__handshake($request, $response);
$this->callback->onHandshake($request, $response);
} else {
$this->protocol($request, $response);
}
@@ -129,64 +125,6 @@ class Server extends AbstractServer implements OnHandshakeInterface, OnMessageIn
}
/**
* @param Request $request
* @param Response $response
* @return void
* @throws Exception
*/
private function __handshake(Request $request, Response $response)
{
$this->callback->onHandshake($request, $response);
$key = base64_encode(sha1($request->header['sec-websocket-key'] . self::SHA1_KEY, true));
if ($key != $response->header['Sec-Websocket-Accept']) {
throw new Exception('Protocol fail.');
}
$response->setStatusCode(101, 'connection success.');
$response->end();
}
/**
* @param Request $request
* @param Response $response
* @return void
*/
private function _coroutine_server(Request $request, Response $response)
{
if ($this->server instanceof \Swoole\Coroutine\Http\Server) {
$response->upgrade();
$this->afterHandshake($request);
while (true) {
$data = $response->recv();
if ($data === '' || $data === false || $data instanceof CloseFrame) {
if (!($this->callback instanceof OnCloseInterface)) {
break;
}
$this->callback->onClose($this->server, $response->fd);
break;
}
if (!($this->callback instanceof OnMessageInterface)) {
continue;
}
$this->callback->onMessage($this->server, $data);
}
}
}
/**
* @param $request
*/
public function afterHandshake($request)
{
if (!($this->callback instanceof OnOpenInterface)) {
return;
}
$this->callback->onOpen($this->server, $request);
}
/**
* @param \Swoole\Server $server
* @param Frame $frame