-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
7 changed files
with
91 additions
and
157 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,54 @@ | ||
| //nolint:all | ||
| package request | ||
|
|
||
| import ( | ||
| "crypto/tls" | ||
| "time" | ||
|
|
||
| "github.com/go-resty/resty/v2" | ||
| "go.uber.org/zap" | ||
| ) | ||
|
|
||
| // Client 包装 Resty 客户端 | ||
| type Client struct { | ||
| *resty.Client | ||
| } | ||
|
|
||
| // New 初始化一个 Resty 客户端 | ||
| func New() Client { | ||
| s := Client{ | ||
| Client: resty.New(). | ||
| SetTimeout(10 * time.Second). | ||
| SetRetryCount(3). | ||
| SetRetryWaitTime(2 * time.Second), | ||
| } | ||
| // 利用中间件实现请求日志 | ||
| s.OnAfterResponse(RestyLogMiddleware) | ||
| return s | ||
| } | ||
|
|
||
| // NewUnSafe 初始化一个 Resty 客户端并跳过 TLS 证书验证 | ||
| func NewUnSafe() Client { | ||
| s := New() | ||
| s.SetTLSClientConfig(&tls.Config{InsecureSkipVerify: true}) | ||
| return s | ||
| } | ||
|
|
||
| // Request 获取一个新的请求实例 | ||
| func (s Client) Request() *resty.Request { | ||
| return s.R().EnableTrace() | ||
| } | ||
|
|
||
| // RestyLogMiddleware Resty日志中间件 | ||
| func RestyLogMiddleware(_ *resty.Client, resp *resty.Response) error { | ||
| if resp.IsError() { | ||
| method := resp.Request.Method | ||
| url := resp.Request.URL | ||
| zap.L().Warn("请求出现错误", | ||
| zap.String("method", method), | ||
| zap.String("url", url), | ||
| zap.Float64("time_spent", resp.Time().Seconds()), | ||
| ) | ||
| } | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters