82 lines
2.4 KiB
Go
82 lines
2.4 KiB
Go
package plain
|
||
|
||
import (
|
||
"bytes"
|
||
"crypto/tls"
|
||
"encoding/json"
|
||
"fmt"
|
||
"io"
|
||
"net/http"
|
||
)
|
||
|
||
type NadNotifier struct {
|
||
Address string `json:"address"` // http://host:port/path
|
||
SkipSSLVerify bool `json:"skip_ssl_verify"`
|
||
AccessToken string `json:"access_token"`
|
||
}
|
||
|
||
// Notify 方法将传入的 Notify 信息序列化为 JSON，
|
||
// 然后通过 HTTP POST 请求发送到 NadNotifier.Address 指定的地址。
|
||
// 如果启用 SkipSSLVerify，将跳过对服务端证书的校验（仅在测试或内部环境使用）。
|
||
// 若需要授权令牌（AccessToken），则会在请求头中设置相应的 Bearer Token。
|
||
func (receiver NadNotifier) Notify(notify *Notify) error {
|
||
// 将 Notify 序列化为 JSON
|
||
bodyData, err := json.Marshal(notify)
|
||
if err != nil {
|
||
return fmt.Errorf("json marshal error: %v", err)
|
||
}
|
||
|
||
// 创建一个可选的自定义 Transport，用于跳过 SSL 证书验证
|
||
transport := http.DefaultTransport.(*http.Transport).Clone()
|
||
if receiver.SkipSSLVerify {
|
||
// 不建议在生产环境中使用此选项
|
||
transport.TLSClientConfig = &tls.Config{InsecureSkipVerify: true}
|
||
}
|
||
|
||
// 使用自定义 Transport 创建 http.Client
|
||
client := &http.Client{Transport: transport}
|
||
|
||
// 构造 HTTP 请求
|
||
req, err := http.NewRequest(http.MethodPost, receiver.Address, bytes.NewReader(bodyData))
|
||
if err != nil {
|
||
return fmt.Errorf("create request error: %v", err)
|
||
}
|
||
|
||
// 设置请求头
|
||
req.Header.Set("Content-Type", "application/json")
|
||
req.Header.Set("access_token", receiver.AccessToken)
|
||
|
||
// 发送请求
|
||
resp, err := client.Do(req)
|
||
if err != nil {
|
||
return fmt.Errorf("http post error: %v", err)
|
||
}
|
||
|
||
fmt.Println("status code:", resp.StatusCode)
|
||
fmt.Println("status message:", resp.Status)
|
||
|
||
defer func(Body io.ReadCloser) {
|
||
err := Body.Close()
|
||
if err != nil {
|
||
_ = fmt.Errorf("close body error: %v", err)
|
||
}
|
||
}(resp.Body)
|
||
|
||
// 可选：读取响应体进行日志或错误判断
|
||
respBody, err := io.ReadAll(resp.Body)
|
||
if err != nil {
|
||
return fmt.Errorf("read response error: %v", err)
|
||
} else {
|
||
fmt.Println("response body:", string(respBody))
|
||
}
|
||
|
||
// 根据返回的状态码做相应处理，这里简单返回非 2xx 状态码为错误
|
||
if resp.StatusCode < 200 || resp.StatusCode >= 300 {
|
||
return fmt.Errorf("unexpected status code: %d, response: %s", resp.StatusCode, string(respBody))
|
||
}
|
||
|
||
// 如果需要，你可以在这里解析服务端返回的 JSON 或作其他逻辑处理
|
||
|
||
return nil
|
||
}
|