aa

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))
+}

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
 	})
 }