Support KeepAlive to avoid duplicate connections

Author: tw2066

src/Transport/CurlerRequest.php

@@ -106,7 +106,7 @@ class CurlerRequest
     /**
      * @param bool $id
      */
-    public function __construct($id = false)
+    public function __construct($id = false, $handle = null)
     {
         $this->id = $id;
 
@@ -128,23 +128,7 @@ public function __construct($id = false)
             CURLOPT_RETURNTRANSFER => TRUE,
             CURLOPT_USERAGENT => 'smi2/PHPClickHouse/client',
         );
-    }
-
-    /**
-     *
-     */
-    public function __destruct()
-    {
-        $this->close();
-    }
-
-
-    public function close()
-    {
-        if ($this->handle) {
-            curl_close($this->handle);
-        }
-        $this->handle = null;
+        $this->handle = $handle;
     }
 
     /**
@@ -375,10 +359,7 @@ public function isPersistent()
      */
     public function keepAlive(int $sec = 60)
     {
-        $this->options[CURLOPT_FORBID_REUSE] = TRUE;
-        $this->headers['Connection'] = 'Keep-Alive';
-        $this->headers['Keep-Alive'] = $sec;
-
+        $this->headers['Connection'] = 'keep-alive';
         return $this;
     }
 

src/Transport/Http.php

@@ -95,6 +95,12 @@ class Http
      * @var null|resource
      */
     private $stdErrOut = null;
+
+    /**
+     * @var null|resource
+     */
+    private $handle = null;
+
     /**
      * Http constructor.
      * @param string $host
@@ -235,7 +241,7 @@ private function getUrl($params = []): string
      */
     private function newRequest($extendinfo): CurlerRequest
     {
-        $new = new CurlerRequest();
+        $new = new CurlerRequest(false, $this->getHandle());
 
         switch ($this->_authMethod) {
             case self::AUTH_METHOD_QUERY_STRING:
@@ -266,7 +272,8 @@ private function newRequest($extendinfo): CurlerRequest
         }
 
         $new->timeOut($this->settings()->getTimeOut());
-        $new->connectTimeOut($this->_connectTimeOut);//->keepAlive(); // one sec
+        $new->connectTimeOut($this->_connectTimeOut);
+        $new->keepAlive();
         $new->verbose(boolval($this->_verbose));
 
         return $new;
@@ -569,7 +576,7 @@ public function getRequestWrite(Query $query): CurlerRequest
      */
     public function ping(): bool
     {
-        $request = new CurlerRequest();
+        $request = new CurlerRequest(false, $this->getHandle());
         $request->url($this->getUri())->verbose(false)->GET()->connectTimeOut($this->getConnectTimeOut());
         $this->_curler->execOne($request);
 
@@ -802,4 +809,22 @@ public function streamWrite(Stream $streamWrite, $sql, $bindings = []): Statemen
         $request = $this->writeStreamData($sql);
         return $this->streaming($streamWrite, $request);
     }
+
+    public function __destruct()
+    {
+        if ($this->handle) {
+            curl_close($this->handle);
+        }
+    }
+
+
+    public function getHandle()
+    {
+        if (!$this->handle) {
+            $this->handle = curl_init();
+        }
+
+        return $this->handle;
+    }
+
 }