Revert "改名"

This reverts commit fdf58326

Abstracts/BaseProcess.php

@@ -4,6 +4,7 @@ namespace Kiri\Server\Abstracts;
 
 
 use Kiri\Context;
+use Kiri\Server\Broadcast\OnBroadcastInterface;
 use Kiri\Server\Contract\OnProcessInterface;
 use Swoole\Coroutine;
 use Swoole\Process;
@@ -80,9 +81,6 @@ abstract class BaseProcess implements OnProcessInterface
 	}
 
 
-	abstract public function onBroadcast($message);
-
-
 	/**
 	 *
 	 */

Broadcast/Message.php

@@ -7,7 +7,11 @@ use Kiri\Kiri;
 use Kiri\Server\Contract\OnPipeMessageInterface;
 use Psr\Log\LoggerInterface;
 
-class Message implements OnPipeMessageInterface
+
+/**
+ *
+ */
+class Message implements OnPipeMessageInterface, OnBroadcastInterface
 {
 
 	/**
@@ -24,8 +28,7 @@ class Message implements OnPipeMessageInterface
 	public function process(): void
 	{
 		$logger = Kiri::getDi()->get(LoggerInterface::class);
-		$logger->debug('workerId::' . env('environmental_workerId'));
+		$logger->debug(env('environmental') . '::' . env('environmental_workerId', 0) . '::' . $this->data);
-		$logger->debug($this->data . '::' . static::class);
 	}
 
 }

Broadcast/OnBroadcastInterface.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace Kiri\Server\Broadcast;
+
+interface OnBroadcastInterface
+{
+
+
+	/**
+	 * @return void
+	 */
+	public function process(): void;
+
+}

ProcessManager.php

@@ -57,6 +57,7 @@ class ProcessManager
 			if (Kiri::getPlatform()->isLinux()) {
 				$process->name($system . '(' . $customProcess->getName() . ')');
 			}
+			set_env('environmental', Kiri::PROCESS);
 			$channel = Coroutine::create(function () use ($process, $customProcess) {
 				while (!$customProcess->isStop()) {
 					$message = $process->read();