refactor: Use global http client to share the connection pool (#16276)

refactor: Use global request client to share the connection pool

Signed-off-by: Xuanwo <github@xuanwo.io>

Author: Xuanwo

src/common/storage/src/operator.rs

@@ -63,6 +63,12 @@ use crate::StorageConfig;
 static GLOBAL_HICKORY_RESOLVER: LazyLock<Arc<HickoryResolver>> =
     LazyLock::new(|| Arc::new(HickoryResolver::default()));
 
+static GLOBAL_HTTP_CLIENT: LazyLock<HttpClient> = LazyLock::new(|| {
+    new_storage_http_client().unwrap_or_else(|err| {
+        panic!("http client must be created successfully, but failed for {err}")
+    })
+});
+
 /// init_operator will init an opendal operator based on storage config.
 pub fn init_operator(cfg: &StorageParams) -> Result<Operator> {
     let op = match &cfg {
@@ -162,7 +168,7 @@ pub fn init_azblob_operator(cfg: &StorageAzblobConfig) -> Result<impl Builder> {
         // Credential
         .account_name(&cfg.account_name)
         .account_key(&cfg.account_key)
-        .http_client(new_storage_http_client()?);
+        .http_client(GLOBAL_HTTP_CLIENT.clone());
 
     Ok(builder)
 }
@@ -187,7 +193,7 @@ fn init_gcs_operator(cfg: &StorageGcsConfig) -> Result<impl Builder> {
         .bucket(&cfg.bucket)
         .root(&cfg.root)
         .credential(&cfg.credential)
-        .http_client(new_storage_http_client()?);
+        .http_client(GLOBAL_HTTP_CLIENT.clone());
 
     Ok(builder)
 }
@@ -284,7 +290,7 @@ fn init_s3_operator(cfg: &StorageS3Config) -> Result<impl Builder> {
         builder = builder.enable_virtual_host_style();
     }
 
-    builder = builder.http_client(new_storage_http_client()?);
+    builder = builder.http_client(GLOBAL_HTTP_CLIENT.clone());
 
     Ok(builder)
 }
@@ -301,7 +307,7 @@ fn init_obs_operator(cfg: &StorageObsConfig) -> Result<impl Builder> {
         // Credential
         .access_key_id(&cfg.access_key_id)
         .secret_access_key(&cfg.secret_access_key)
-        .http_client(new_storage_http_client()?);
+        .http_client(GLOBAL_HTTP_CLIENT.clone());
 
     Ok(builder)
 }
@@ -317,7 +323,7 @@ fn init_oss_operator(cfg: &StorageOssConfig) -> Result<impl Builder> {
         .root(&cfg.root)
         .server_side_encryption(&cfg.server_side_encryption)
         .server_side_encryption_key_id(&cfg.server_side_encryption_key_id)
-        .http_client(new_storage_http_client()?);
+        .http_client(GLOBAL_HTTP_CLIENT.clone());
 
     Ok(builder)
 }
@@ -350,7 +356,7 @@ fn init_cos_operator(cfg: &StorageCosConfig) -> Result<impl Builder> {
         .secret_key(&cfg.secret_key)
         .bucket(&cfg.bucket)
         .root(&cfg.root)
-        .http_client(new_storage_http_client()?);
+        .http_client(GLOBAL_HTTP_CLIENT.clone());
 
     Ok(builder)
 }