From e3a135f3379d9273b7b612a4abb0111952ef87f2 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Tue, 15 Jun 2021 16:11:41 +0800 Subject: [PATCH] aa --- business/jxstore/cms/temp.go | 36 +++++++++++++++++++++++++++++++++++ controllers/job_controller.go | 3 ++- 2 files changed, 38 insertions(+), 1 deletion(-) create mode 100644 business/jxstore/cms/temp.go diff --git a/business/jxstore/cms/temp.go b/business/jxstore/cms/temp.go new file mode 100644 index 000000000..adb872ac1 --- /dev/null +++ b/business/jxstore/cms/temp.go @@ -0,0 +1,36 @@ +package cms + +import ( + "fmt" + "io/ioutil" + "net" + "net/http" + "time" +) + +func TestTemp() { + var HTTPTransport = &http.Transport{ + DialContext: (&net.Dialer{ + Timeout: 30 * time.Second, // 连接超时时间 + KeepAlive: 60 * time.Second, // 保持长连接的时间 + }).DialContext, // 设置连接的参数 + MaxIdleConns: 500, // 最大空闲连接 + IdleConnTimeout: 60 * time.Second, // 空闲连接的超时时间 + ExpectContinueTimeout: 30 * time.Second, // 等待服务第一个响应的超时时间 + MaxIdleConnsPerHost: 100, // 每个host保持的空闲连接数 + } + uri := "print.jxcs.net:8000" + start2 := time.Now() + client2 := http.Client{Transport: HTTPTransport} // 初始化一个带有transport的http的client + req, err := http.NewRequest(http.MethodGet, uri, nil) + if err != nil { + panic("Http Req Failed " + err.Error()) + } + resp, err := client2.Do(req) + if err != nil { + panic("Http Request Failed " + err.Error()) + } + defer resp.Body.Close() + ioutil.ReadAll(resp.Body) // 如果不及时从请求中获取结果,此连接会占用,其他请求服务复用连接 + fmt.Println("Orig GoNet Long Link", time.Since(start2)) +} diff --git a/controllers/job_controller.go b/controllers/job_controller.go index 711dd4c46..8e4dc2dfe 100644 --- a/controllers/job_controller.go +++ b/controllers/job_controller.go @@ -546,7 +546,8 @@ func (c *JobController) RefreshJdDelivery() { // @router /TempJob [post] func (c *JobController) TempJob() { c.callTempJob(func(params *tJobTempJobParams) (retVal interface{}, errCode string, err error) { - cms.TempJob() + //cms.TempJob() + cms.TestTemp() return retVal, "", err }) }