From cf0f6560324758a4d0bc13dba1633a53511d13be Mon Sep 17 00:00:00 2001 From: junleea <354425203@qq.com> Date: Thu, 12 Jun 2025 20:20:38 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=AF=B7=E6=B1=82client?= =?UTF-8?q?=E7=9A=84=E8=AF=81=E4=B9=A6=E8=AE=A4=E8=AF=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- worker/req.go | 34 ++++++++++++++++++++++++++-------- 1 file changed, 26 insertions(+), 8 deletions(-) diff --git a/worker/req.go b/worker/req.go index bff6bc9..f0df094 100644 --- a/worker/req.go +++ b/worker/req.go @@ -2,6 +2,7 @@ package worker import ( "bytes" + "crypto/tls" "encoding/json" "fmt" "io" @@ -20,7 +21,23 @@ var client *http.Client // 初始化 func InitReq() { - client = &http.Client{} + client = &http.Client{ + Transport: &http.Transport{ + TLSClientConfig: &tls.Config{ + InsecureSkipVerify: true, // 设置为true将跳过证书验证 + }, + }, + } +} + +func InitReqClient() { + client = &http.Client{ + Transport: &http.Transport{ + TLSClientConfig: &tls.Config{ + InsecureSkipVerify: true, // 设置为true将跳过证书验证 + }, + }, + } } // 发起post请求 @@ -104,9 +121,8 @@ func SyncDataFromMasterReq(url string, token string) proto.UserSync { m["device"] = "" if client == nil { - client = &http.Client{} + InitReqClient() } - client = &http.Client{} //获取数据 resp, err := client.Do(req) if err != nil { @@ -173,7 +189,7 @@ func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) (proto.UserSync, req.Header.Set("Content-Type", "application/json") //传输数据 if client == nil { - client = &http.Client{} + InitReqClient() } //获取数据 resp, err := client.Do(req) @@ -218,7 +234,7 @@ func SyncDataFromMasterShellReq2(url string, data proto.SyncUserShellReq) ([]dao req.Header.Set("token", data.Token) //传输数据 if client == nil { - client = &http.Client{} + InitReqClient() } //获取数据 resp, err := client.Do(req) @@ -262,7 +278,7 @@ func SyncDataFromMasterShellReq3(url string, data proto.SyncUserShellResp) ([]pr req.Header.Set("token", data.Token) //传输数据 if client == nil { - client = &http.Client{} + InitReqClient() } //获取数据 resp, err := client.Do(req) @@ -305,7 +321,8 @@ func DoPostRequestJSON(url string, jsonData []byte, headers map[string]string) ( } //传输数据 if httpClient == nil { - httpClient = &http.Client{} + InitReqClient() + httpClient = client } //获取数据 resp, err := httpClient.Do(req) @@ -484,7 +501,8 @@ func DoGetRequest(url string, headers map[string]string) (error, []byte) { } //传输数据 if httpClient == nil { - httpClient = &http.Client{} + InitReqClient() + httpClient = client } //获取数据 resp, err := httpClient.Do(req)