eee

function.php

@@ -28,14 +28,14 @@ interface Arrayable
 }
 
 
-if (!function_exists('json_validator')) {
+if (!function_exists('json_validate')) {
 
 
     /**
      * @param string $data
      * @return bool
      */
-    function json_validator(string $data): bool
+    function json_validate(string $data): bool
     {
         return is_array(json_decode($data, true));
     }

kiri-actor/Actor.php

@@ -1,238 +0,0 @@
-<?php
-declare(strict_types=1);
-
-namespace Kiri\Actor;
-
-use Exception;
-use JsonSerializable;
-use Swoole\Coroutine;
-use Swoole\Coroutine\Channel;
-
-
-/**
- * @Actor
- */
-abstract class Actor implements ActorInterface, JsonSerializable
-{
-
-
-	/**
-	 * @var Channel
-	 */
-	private Channel $channel;
-
-
-	/**
-	 * @var bool
-	 */
-	private bool $isShutdown = false;
-
-
-	/**
-	 * @var int
-	 */
-	private int $messageId = -1;
-
-
-	/**
-	 * @var int
-	 */
-	private int $coroutineId = -1;
-
-
-	/**
-	 * @var ActorState
-	 */
-	private ActorState $state;
-
-
-	/**
-	 * @var float
-	 */
-	private float $startTime = 0;
-
-
-	/**
-	 * @var int
-	 */
-	private int $refreshInterval = 0;
-
-
-	/**
-	 * @return ActorState
-	 */
-	public function getState(): ActorState
-	{
-		return $this->state;
-	}
-
-
-	/**
-	 * @param ActorState $state
-	 */
-	public function setState(ActorState $state): void
-	{
-		$this->state = $state;
-	}
-
-
-	/**
-	 * @return float
-	 */
-	public function getRunTime(): float
-	{
-		return microtime(true) - $this->startTime;
-	}
-
-
-	/**
-	 * @param string $uniqueId
-	 */
-	private function __construct(readonly public string $uniqueId)
-	{
-		$this->channel = new Channel(99);
-		$this->startTime = microtime(true);
-	}
-
-
-	/**
-	 * @return void
-	 */
-	public function init(): void
-	{
-
-	}
-
-
-	/**
-	 * @return bool
-	 */
-	public function isShutdown(): bool
-	{
-		return $this->isShutdown;
-	}
-
-
-	/**
-	 * @param $id
-	 * @return static
-	 */
-	public static function newActor($id): static
-	{
-		$actor = new static($id);
-		$actor->listen();
-		return $actor;
-	}
-
-
-	/**
-	 * @return void
-	 */
-	private function listen(): void
-	{
-		Coroutine::create(function (Actor $actor) {
-			$actor->coroutineId = Coroutine::getCid();
-			$this->run();
-		}, $this);
-	}
-
-
-	/**
-	 * @return string
-	 */
-	public function getName(): string
-	{
-		return $this->uniqueId;
-	}
-
-
-	/**
-	 * @param mixed $response
-	 * @return bool
-	 */
-	public function write(mixed $response): bool
-	{
-		return $this->channel->push($response);
-	}
-
-
-	/**
-	 * @return void
-	 */
-	public function shutdown(): void
-	{
-		$this->isShutdown = true;
-		Coroutine::cancel($this->coroutineId);
-		if ($this->messageId > -1) {
-			Coroutine::cancel($this->messageId);
-		}
-		$this->channel->close();
-	}
-
-
-	/**
-	 * @return void
-	 */
-	public function onUpdate(): void
-	{
-	}
-
-
-	/**
-	 * @return void
-	 * @throws Exception
-	 */
-	public function run(): void
-	{
-		if ($this->refreshInterval < 1) {
-			throw new Exception('Refresh interval must be greater than 1');
-		}
-		$this->setState(ActorState::BUSY);
-		$this->init();
-		$this->messageId = Coroutine::create(fn() => $this->loop());
-		$this->interval();
-		$this->setState(ActorState::IDLE);
-	}
-
-
-	/**
-	 * @return void
-	 */
-	private function interval(): void
-	{
-		if ($this->isShutdown()) {
-			return;
-		}
-
-		try {
-			$this->onUpdate();
-		} catch (\Throwable $exception) {
-			error($exception);
-		}
-
-		Coroutine::sleep($this->refreshInterval / 1000);
-
-		$this->interval();
-	}
-
-
-	/**
-	 * @return bool
-	 */
-	private function loop(): bool
-	{
-		if ($this->messageId == -1) {
-			$this->messageId = Coroutine::getCid();
-		}
-		if ($this->channel->errCode == SWOOLE_CHANNEL_CLOSED) {
-			$this->channel = new Channel(99);
-		}
-		$message = $this->channel->pop();
-		$this->process($message);
-		if ($this->isShutdown()) {
-			return true;
-		}
-		return $this->loop();
-	}
-
-}

kiri-actor/ActorInterface.php

@@ -1,15 +0,0 @@
-<?php
-declare(strict_types=1);
-
-namespace Kiri\Actor;
-
-interface ActorInterface
-{
-
-	/**
-	 * @param ActorMessage $message
-	 * @return void
-	 */
-	public function process(ActorMessage $message): void;
-
-}

kiri-actor/ActorManager.php

@@ -1,110 +0,0 @@
-<?php
-declare(strict_types=1);
-
-namespace Kiri\Actor;
-
-use Swoole\Coroutine;
-
-class ActorManager
-{
-
-    /** @var array<string, ActorInterface> */
-    private array $nodes = [];
-
-
-    /**
-     * @param Actor $actor
-     * @return void
-     */
-    public function addActor(ActorInterface $actor): void
-    {
-        $this->nodes[$actor->uniqueId] = $actor;
-        Coroutine::create(function (Actor $actor) {
-            $actor->run();
-        }, $actor);
-    }
-
-
-    /**
-     * @param $name
-     * @return void
-     */
-    public function closeActor($name): void
-    {
-        $node = $this->nodes[$name] ?? null;
-        if (is_null($node)) {
-            return;
-        }
-        foreach ($node as $actor) {
-            $actor->shutdown();
-        }
-    }
-
-
-    /**
-     * @param $name
-     * @param $message
-     * @return bool
-     */
-    public function write($name, $message): bool
-    {
-        $actor = $this->nodes[$name] ?? null;
-        if (is_null($actor)) {
-            return false;
-        }
-        return $actor->write($message);
-    }
-
-
-    /**
-     * @param $name
-     * @return array
-     */
-    public function lists($name): array
-    {
-        $array = [];
-        foreach ($this->nodes[$name] as $actor) {
-            $array[] = [
-                'id'      => $actor->getName(),
-                'state'   => $actor->getState()->name,
-                'runTime' => $actor->getRunTime()
-            ];
-        }
-        return $array;
-    }
-
-
-    /**
-     * @param string $uniqueId
-     * @return bool
-     */
-    public function hasActor(string $uniqueId): bool
-    {
-        return isset($this->nodes[$uniqueId]) && $this->nodes[$uniqueId] instanceof ActorInterface;
-    }
-
-
-    /**
-     * @param array|null $data
-     * @return void
-     */
-    public static function exec(?array $data): void
-    {
-        if (is_null($data)) {
-            return;
-        }
-    }
-
-
-    /**
-     * @return void
-     */
-    public function clean(): void
-    {
-        foreach ($this->nodes as $actor) {
-            $actor->shutdown();
-        }
-        $this->nodes = [];
-    }
-
-}

kiri-actor/ActorMessage.php

@@ -1,78 +0,0 @@
-<?php
-declare(strict_types=1);
-
-namespace Kiri\Actor;
-
-use JetBrains\PhpStorm\ArrayShape;
-
-class ActorMessage implements \JsonSerializable
-{
-
-	/**
-	 * @var int
-	 */
-	private int $userId;
-
-
-	/**
-	 * @var string
-	 */
-	private string $event;
-
-
-	/**
-	 * @var array
-	 */
-	private array $body;
-
-	/**
-	 * @param int $userId
-	 * @param string $event
-	 * @param array $body
-	 */
-	public function __construct(int $userId, string $event, array $body)
-	{
-		$this->userId = $userId;
-		$this->event = $event;
-		$this->body = $body;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getUserId(): int
-	{
-		return $this->userId;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getEvent(): string
-	{
-		return $this->event;
-	}
-
-	/**
-	 * @return array
-	 */
-	public function getBody(): array
-	{
-		return $this->body;
-	}
-
-
-	/**
-	 * @return array
-	 */
-	#[ArrayShape(['userId' => "int", 'event' => "string", 'body' => "array"])]
-    public function jsonSerialize(): array
-	{
-		return [
-			'userId' => $this->userId,
-			'event'  => $this->event,
-			'body'   => $this->body
-		];
-	}
-
-}

kiri-actor/ActorProcess.php

@@ -1,47 +0,0 @@
-<?php
-
-namespace Kiri\Actor;
-
-use Kiri\Server\Processes\AbstractProcess;
-use Swoole\Coroutine;
-use Swoole\Process;
-
-class ActorProcess extends AbstractProcess
-{
-
-    /**
-     * @var bool
-     */
-    protected bool $enable_coroutine = true;
-
-
-    /**
-     * @return string
-     */
-    public function getName(): string
-    {
-        // TODO: Change the autogenerated stub
-        return 'Actor Manager';
-    }
-
-
-    public function process(?Process $process): void
-    {
-        // TODO: Implement process() method.
-        while ($this->isStop() === false) {
-            $read = $process->read();
-
-            ActorManager::exec(json_decode($read, true));
-
-            Coroutine::sleep(1000 / 120);
-        }
-    }
-
-
-    /**
-     * @return void
-     */
-    public function onSigterm(): void
-    {
-    }
-}

kiri-actor/ActorState.php

@@ -1,18 +0,0 @@
-<?php
-
-namespace Kiri\Actor;
-
-enum ActorState
-{
-	case IDLE;
-	case BUSY;
-
-	/**
-	 *
-	 */
-	case CREATE;
-	case MESSAGE;
-	case SHUTDOWN;
-
-}
-

kiri-engine/Application.php

@@ -10,17 +10,12 @@ declare(strict_types=1);
 namespace Kiri;
 
 
-use Exception;
 use Kiri;
 use Kiri\Abstracts\{BaseApplication, Kernel};
 use Kiri\Di\Scanner;
 use Kiri\Error\ErrorHandler;
 use Kiri\Events\{OnAfterCommandExecute, OnBeforeCommandExecute};
-use Psr\Container\ContainerExceptionInterface;
-use Psr\Container\NotFoundExceptionInterface;
-use ReflectionException;
 use Symfony\Component\Console\{Application as ConsoleApplication,
-    Exception\ExceptionInterface,
     Input\ArgvInput,
     Output\ConsoleOutput,
     Output\OutputInterface

kiri-engine/Coordinator.php

@@ -9,7 +9,7 @@ class Coordinator
 
 	const string WORKER_START = 'worker:start';
 
-	private bool $waite = false;
+	private bool $waite = true;
 
 
 	/**
@@ -17,10 +17,9 @@ class Coordinator
 	 */
 	public function yield(): void
 	{
-		if ($this->waite === false) {
-			return;
-		}
-		$this->yield();
+		while ($this->waite) {
+            usleep(1000);
+        }
 	}
 
 

p.php

@@ -1 +1,25 @@
 <?php
+
+
+use Swoole\Timer;
+use Swoole\WebSocket\Server;
+
+$client = new Server("0.0.0.0", 9511);
+$client->addProcess(new Swoole\Process(function (\Swoole\Process $server) use ($client) {
+    while (true) {
+        echo json_encode($client->stats(), JSON_UNESCAPED_UNICODE) . PHP_EOL;
+        sleep(1);
+    }
+}));
+$client->on('open', function (Server $server) {
+
+});
+
+$client->on('message', function (Server $server, $frame) {
+
+});
+
+$client->on('close', function (Server $server, $fd) {
+
+});
+$client->start();

test.php

@@ -1 +1,51 @@
 <?php
+
+ini_set('memory_limit','64GB');
+
+use Swoole\Coroutine;
+use Swoole\Coroutine\Http\Client;
+use function Swoole\Coroutine\run;
+
+function faker($page = 0)
+{
+    $client = new Client('openapi.stupideyes.com', 443, true);
+    $client->get('/faker?offset=' . $page);
+    $client->close();
+
+    return json_decode($client->getBody(), true);
+}
+
+run(function () {
+    $offset = 1;
+
+    $success = 0;
+    for ($i = 1; $i <= 10000; $i++) {
+        $faker = faker($offset);
+        $offset++;
+        go(function () use ($faker, $offset, &$success) {
+            $socket = new Swoole\Coroutine\Http\Client('43.248.128.57', 14101);
+            $socket->upgrade("/ws?access_token=" . $faker['params']['token']);
+            if ($socket->connected) {
+                $success += 1;
+
+                while (true) {
+                    $socket->recv();
+//                    $socket->push('hello');
+//                    var_dump($socket->recv());
+
+                    Coroutine::sleep(0.1);
+                }
+            } else {
+                $success -= 1;
+
+                echo 'websocket fail: ' . socket_strerror($socket->errCode) . PHP_EOL;
+            }
+        });
+
+        Coroutine::sleep(0.1);
+
+        var_dump($success);
+    }
+
+
+});