| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | var reqBody Request |
|---|
| | | var ri *Reply |
|---|
| | | err := json.Unmarshal(msgR.Body, &reqBody) |
|---|
| | | if err != nil { |
|---|
| | | ms.printLog("serve unmarshal msgR.Body err:", err) |
|---|
| | | return |
|---|
| | | ri = &Reply { |
|---|
| | | Msg: err.Error(), |
|---|
| | | } |
|---|
| | | |
|---|
| | | } else { |
|---|
| | | ms.printLog("reqBody:", reqBody, "to key: ", p) |
|---|
| | | var ri *Reply |
|---|
| | | |
|---|
| | | if f,ok := ms.handlers[reqBody.Path];ok { |
|---|
| | | reqBody.SrcProc = msgR.SrcProc |
|---|
| | | ri = f(&reqBody) |
|---|
| | | ms.printLog("call funcMap f,reply:", *ri) |
|---|
| | | } else { |
|---|
| | |
|---|
| | | Data: "请求的接口不存在，请检查url", |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | retErr := ms.handle.Reply(p, ri) |
|---|
| | | if retErr != nil { |
|---|
| | | ms.printLog("retErr:", retErr) |
|---|
