server_common/f5
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add post

Browse Source
This commit is contained in:
aozhiwei 2024-06-05 17:03:52 +08:00
parent bf1664b48b
commit dcd28f7e45
1 changed files with 104 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

123
httpclimgr.go
View File

@ -80,27 +80,66 @@ func (this *httpCliMgr) SendGoStyleRequest(
cb)
}
func (this *httpCliMgr) SyncSendGoStyleRequest(
func (this *httpCliMgr) SendGoStylePost(
url string, params map[string]string,
cb func(HttpCliResponse)) {
chDone := make(chan bool)
this.internalSendRequest(
contentType string, body string,
cb func(HttpCliResponse)) HttpCliRequestHandle {
return this.internalSendPost(
GO_STYLE_REQUEST,
NORMAL_CHANNEL,
url,
params,
nil,
func(rsp HttpCliResponse) {
cb(rsp)
chDone <- true
})
for {
select {
case <-chDone:
close(chDone)
return
}
}
contentType,
body,
cb)
}
func (this *httpCliMgr) SendGoStyleJsonRspPost(
url string, params map[string]string,
jsonRspObj interface{},
contentType string, body string,
cb func(HttpCliResponse)) HttpCliRequestHandle {
return this.internalSendPost(
GO_STYLE_REQUEST,
NORMAL_CHANNEL,
url,
params,
jsonRspObj,
contentType,
body,
cb)
}
func (this *httpCliMgr) SendJsStylePost(
url string, params map[string]string,
contentType string, body string,
cb func(HttpCliResponse)) HttpCliRequestHandle {
return this.internalSendPost(
JS_STYLE_REQUEST,
NORMAL_CHANNEL,
url,
params,
nil,
contentType,
body,
cb)
}
func (this *httpCliMgr) SendJsStyleJsonRspPost(
url string, params map[string]string,
jsonRspObj interface{},
contentType string, body string,
cb func(HttpCliResponse)) HttpCliRequestHandle {
return this.internalSendPost(
JS_STYLE_REQUEST,
NORMAL_CHANNEL,
url,
params,
jsonRspObj,
contentType,
body,
cb)
}
func (this *httpCliMgr) SendJsStyleRequest(
@ -176,6 +215,43 @@ func (this *httpCliMgr) internalSendRequest(
url string, params map[string]string,
jsonRspObj interface{},
cb func(HttpCliResponse)) HttpCliRequestHandle {
return this.internalSendGetOrPost(
true,
style,
channel,
url,
params,
jsonRspObj,
"",
"",
cb)
}
func (this *httpCliMgr) internalSendPost(
style int32, channel int32,
url string, params map[string]string,
jsonRspObj interface{},
contentType string, body string,
cb func(HttpCliResponse)) HttpCliRequestHandle {
return this.internalSendGetOrPost(
false,
style,
channel,
url,
params,
jsonRspObj,
contentType,
body,
cb)
}
func (this *httpCliMgr) internalSendGetOrPost(
isGet bool,
style int32, channel int32,
url string, params map[string]string,
jsonRspObj interface{},
contentType string, body string,
cb func(HttpCliResponse)) HttpCliRequestHandle {
if !(style == GO_STYLE_REQUEST || style == JS_STYLE_REQUEST) {
panic("httpCliMgr sytel error")
}
@ -185,9 +261,18 @@ func (this *httpCliMgr) internalSendRequest(
handle := &httpCliRequestHandleImpl{}
doFunc := func() {
if atomic.CompareAndSwapInt32(&handle.state, 0, 1) {
data, err := q5.HttpGet(url, params)
if cb == nil {
return
var data string
var err error
if isGet {
data, err = q5.HttpGet(url, params)
if cb == nil {
return
}
} else {
data, err = q5.HttpPost(url, params, contentType, body)
if cb == nil {
return
}
}
rsp := new(httpCliResponse)
rsp.init(data, err)
@ -196,7 +281,7 @@ func (this *httpCliMgr) internalSendRequest(
if parseErr == nil {
rsp.jsonParseOk = true
} else {
GetSysLog().Warning("f5.httpclimgr.internalSendRequest json error:%s url:%s params:%s",
GetSysLog().Warning("f5.httpclimgr.internalSendGetOrPost json error:%s url:%s params:%s",
parseErr,
url,
q5.EncodeJson(&params))