swoole http thrift

classes/fpf/http/SwooleHttpClient.php

@@ -125,7 +125,7 @@ class SwooleHttpClient
         register_shutdown_function([$this, 'closeCurlHandle']);
         $full_url = $this->full_url;
         $parts = parse_url($full_url);
-        $this->curl_handle = new Client($parts['host'], $parts['port'], 'http' === $parts['scheme'] ? false : true);
+        $this->curl_handle = new Client($parts['host'], ($parts['port'] ?? 80), 'http' === $parts['scheme'] ? false : true);
         $full_url = $this->full_url;
         $headers = [];
         foreach ($this->headers as $key => $value) {

classes/fpf/thrift/SwooleHttpClient.php

@@ -11,7 +11,7 @@ namespace fpf\thrift;
 
 use Thrift\Exception\TTransportException;
 use Thrift\Factory\TStringFuncFactory;
-use Swoft\HttpClient\Client;
+use Swoole\Coroutine\Http\Client;
 
 class SwooleHttpClient extends \Thrift\Transport\TTransport
 {
@@ -219,7 +219,9 @@ class SwooleHttpClient extends \Thrift\Transport\TTransport
         $this->request_ = '';
         $full_url = $this->scheme_ . "://" . $host . $this->uri_;
         $parts = parse_url($full_url);
-        $this->handle = new Client($parts['host'], $parts['port'], 'http' === $parts['scheme'] ? false : true);
+        $this->handle = new Client($parts['host'], ($parts['port'] ?? 80), 'http' === $parts['scheme'] ? false : true);
+        $this->handle->setHeaders($options['headers']);
+        $this->handle->set(['timeout' => $options['timeout']]);
         $this->handle->post($this->uri_, $options['body']);
         $this->response_ = $this->handle->body;
         // Connect failed?

classes/fpf/thrift/ThriftServiceFactoryProxy.php

@@ -88,7 +88,7 @@ class ThriftServiceFactoryProxy
     public function __call($name, $arguments)
     {
         if (defined('IS_SWOOLE_SERVICE') && IS_SWOOLE_SERVICE === true) {
-            $socket = new SwoftHttpClient(
+            $socket = new SwooleHttpClient(
                 $this->request_base_params['host'],
                 $this->request_base_params['port'],
                 $this->request_base_params['uri'],