save

composer.json

@@ -34,7 +34,8 @@
 		"symfony/var-dumper": "^6.0"
 	},
 	"suggest": {
-		"ext-uuid": "For unique socket id. "
+		"ext-uuid": "For unique socket id. ",
+		"workerman/redis": "Used instead of \"workerman/channel\" to improve performance"
 	},
 	"autoload": {
 		"psr-4": {

src/ChannelClient.php

@@ -6,6 +6,39 @@
 
 class ChannelClient extends \Channel\Client
 {
+    /**
+     *
+     * @return bool
+     */
+    public static function isChannelEnv(): bool
+    {
+        return !class_exists("\Workerman\Redis\Client", false);
+    }
+
+    /**
+     * @param $ip
+     * @param $port
+     * @return void
+     * @throws Exception
+     */
+    public static function connect($ip = '127.0.0.1', $port = 2206): void
+    {
+        if (self::isChannelEnv()) {
+            parent::connect($ip, $port);
+        } else {
+
+        }
+    }
+
+    public static function on($event, $callback): void
+    {
+        if (self::isChannelEnv()) {
+            parent::on($event, $callback);
+        } else {
+            // todo redis pub sub
+        }
+    }
+
     /**
      * @param $events
      * @param $data
@@ -29,7 +62,10 @@ protected static function sendAnyway($data): ?bool
         self::connect(self::$_remoteIp, self::$_remotePort);
         $body = serialize($data);
         if (self::$_isWorkermanEnv) {
-            return self::$_remoteConnection->send($body);
+            if (self::isChannelEnv()) {
+                return self::$_remoteConnection->send($body);
+            }
+            // todo redis pub sub
         } else {
             throw new Exception('Not workerman env. ');
         }

src/Events/ClientEvent.php

@@ -53,7 +53,7 @@ public function response(Server $pushServer, TcpConnection $connection, array $r
             return;
         }
         // 事件必须以client-为前缀
-        if (strpos($this->getEvent(), 'client-') !== 0) {
+        if (!str_starts_with($this->getEvent(), 'client-')) {
             $pushServer->error($connection, null, 'Client event rejected - client events must be prefixed by \'client-\'');
             return;
         }