ljydlv
/
videoplayer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改请求client的证书认证

This commit is contained in:
junleea 2025-06-12 20:20:38 +08:00
parent 13086e55ae
commit cf0f656032
1 changed files with 26 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
worker/req.go
View File

@ -2,6 +2,7 @@ package worker
import ( import (
"bytes" "bytes"
"crypto/tls"
"encoding/json" "encoding/json"
"fmt" "fmt"
"io" "io"
@ -20,7 +21,23 @@ var client *http.Client
// 初始化 // 初始化
func InitReq() { 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请求 // 发起post请求
@ -104,9 +121,8 @@ func SyncDataFromMasterReq(url string, token string) proto.UserSync {
m["device"] = "" m["device"] = ""
if client == nil { if client == nil {
client = &http.Client{} InitReqClient()
} }
client = &http.Client{}
//获取数据 //获取数据
resp, err := client.Do(req) resp, err := client.Do(req)
if err != nil { if err != nil {
@ -173,7 +189,7 @@ func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) (proto.UserSync,
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")
//传输数据 //传输数据
if client == nil { if client == nil {
client = &http.Client{} InitReqClient()
} }
//获取数据 //获取数据
resp, err := client.Do(req) resp, err := client.Do(req)
@ -218,7 +234,7 @@ func SyncDataFromMasterShellReq2(url string, data proto.SyncUserShellReq) ([]dao
req.Header.Set("token", data.Token) req.Header.Set("token", data.Token)
//传输数据 //传输数据
if client == nil { if client == nil {
client = &http.Client{} InitReqClient()
} }
//获取数据 //获取数据
resp, err := client.Do(req) resp, err := client.Do(req)
@ -262,7 +278,7 @@ func SyncDataFromMasterShellReq3(url string, data proto.SyncUserShellResp) ([]pr
req.Header.Set("token", data.Token) req.Header.Set("token", data.Token)
//传输数据 //传输数据
if client == nil { if client == nil {
client = &http.Client{} InitReqClient()
} }
//获取数据 //获取数据
resp, err := client.Do(req) resp, err := client.Do(req)
@ -305,7 +321,8 @@ func DoPostRequestJSON(url string, jsonData []byte, headers map[string]string) (
} }
//传输数据 //传输数据
if httpClient == nil { if httpClient == nil {
httpClient = &http.Client{} InitReqClient()
httpClient = client
} }
//获取数据 //获取数据
resp, err := httpClient.Do(req) resp, err := httpClient.Do(req)
@ -484,7 +501,8 @@ func DoGetRequest(url string, headers map[string]string) (error, []byte) {
} }
//传输数据 //传输数据
if httpClient == nil { if httpClient == nil {
httpClient = &http.Client{} InitReqClient()
httpClient = client
} }
//获取数据 //获取数据
resp, err := httpClient.Do(req) resp, err := httpClient.Do(req)