Merge pull request #130 from PandaLIU-1111/ping

Added ping

src/redis-subscriber/src/CommandInvoker.php

@@ -33,6 +33,11 @@ class CommandInvoker
      */
     protected $messageChannel;
 
+    /**
+     * @var Channel
+     */
+    private $pingChannel;
+
     /**
      * CommandInvoker constructor.
      * @param Connection $connection
@@ -41,6 +46,7 @@ public function __construct(Connection $connection)
     {
         $this->connection     = $connection;
         $this->resultChannel  = new Channel();
+        $this->pingChannel  = new Channel();
         $this->messageChannel = new Channel(100);
         Coroutine::create(function () use ($connection) {
             $this->receive($connection);
@@ -106,6 +112,12 @@ public function receive(Connection $connection)
                 $buffer = null;
                 continue;
             }
+
+            if ($type == 'pong' && count($buffer) == 5) {
+                $this->pingChannel->push('pong');
+                $buffer = null;
+                continue;
+            }
         }
     }
 
@@ -153,6 +165,18 @@ public function interrupt()
         return true;
     }
 
+    /**
+     * Ping
+     * @param int $timeout
+     * @return string
+     * @throws \Swoole\Exception
+     */
+    public function ping(int $timeout = 1)
+    {
+        $this->connection->send(Resp::build('ping'));
+        return $this->pingChannel->pop($timeout);
+    }
+
     /**
      * Print error
      * @param \Throwable $ex

src/redis-subscriber/src/Subscriber.php

@@ -143,4 +143,14 @@ public function close()
         $this->commandInvoker->interrupt();
     }
 
+    /**
+     * Ping
+     * @param int $timeout
+     * @throws \Swoole\Exception
+     */
+    public function ping(int $timeout = 1)
+    {
+        return $this->commandInvoker->ping($timeout);
+    }
+
 }