r

2023-08-28 12:01:30 +08:00
parent 4a607a5687
commit 9b4f5d59dc
7 changed files with 234 additions and 192 deletions
@@ -8,91 +8,103 @@ use Swoole\Coroutine;
 class ActorManager
 {

-	/** @var array<string, ActorInterface> */
-	private array $nodes = [];
+    /** @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 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
+     * @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
+     * @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 $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 string $uniqueId
+     * @return bool
+     */
+    public function hasActor(string $uniqueId): bool
+    {
+        return isset($this->nodes[$uniqueId]) && $this->nodes[$uniqueId] instanceof ActorInterface;
+    }


-	/**
-	 * @return void
-	 */
-	public function clean(): void
-	{
-		foreach ($this->nodes as $actor) {
-			$actor->shutdown();
-		}
-		$this->nodes = [];
-	}
+    /**
+     * @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 = [];
+    }

 }
@@ -3,6 +3,8 @@ declare(strict_types=1);

 namespace Kiri\Actor;

+use JetBrains\PhpStorm\ArrayShape;
+
 class ActorMessage implements \JsonSerializable
 {

@@ -63,7 +65,8 @@ class ActorMessage implements \JsonSerializable
 	/**
 	 * @return array
 	 */
-	public function jsonSerialize(): array
+	#[ArrayShape(['userId' => "int", 'event' => "string", 'body' => "array"])]
+    public function jsonSerialize(): array
 	{
 		return [
 			'userId' => $this->userId,
@@ -0,0 +1,55 @@
+<?php
+
+namespace Kiri\Actor;
+
+use Kiri\Server\Abstracts\BaseProcess;
+use Swoole\Coroutine;
+use Swoole\Process;
+
+class ActorProcess extends BaseProcess
+{
+
+    /**
+     * @var bool
+     */
+    protected bool $enable_coroutine = true;
+
+
+    /**
+     * @return string
+     */
+    public function getName(): string
+    {
+        // TODO: Change the autogenerated stub
+        return '[' . \config('id', 'system-service') . '].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 $this
+     */
+    public function onSigterm(): static
+    {
+        // TODO: Implement onSigterm() method.
+        Coroutine::create(function () {
+            $sign = Coroutine::waitSignal(SIGINT | SIGTERM);
+            if ($sign) {
+                $this->onShutdown(true);
+            }
+        });
+        return $this;
+    }
+}