Zap(
https://Github.com/uber-go/zap)是一個功能非常豐富、易于使用的 Golang日志庫。記錄日志時,一般會選擇輸出到控制臺(stdout和stderr)或者輸出到文件或者同時輸出到兩者。zap 庫也提供了對應的選項。
指定日志輸出目標
zap 配置項中(zap.Config), 使用 OutputPaths 和 ErrorOutputPaths 可以指定日志輸出目標,首先看下這個配置項的定義和說明:
// OutputPaths is a list of URLs or file paths to write logging output to.
// See Open for detAIls.
OutputPaths []string `json:"outputPaths" yaml:"outputPaths"`
// ErrorOutputPaths is a list of URLs to write internal logger errors to.
// The default is standard error.
//
// Note that this setting only affects internal errors; for sample code that
// sends error-level logs to a different location from info- and debug-level
// logs, see the package-level AdvancedConfiguration example.
ErrorOutputPaths []string `json:"errorOutputPaths" yaml:"errorOutputPaths"`
OutputPaths:是一個字符串類型的切片,可以指定URL、文件路徑或者 stdout,默認是stdout
ErrorOutputPaths:也是一個字符串類型的切片,和 OutputPaths 類似,默認是stderr。
看個例子
package main
import (
"go.uber.org/zap"
"go.uber.org/zap/zapcore"
)
func main() {
cfg := zap.NewProductionConfig()
cfg.OutputPaths = []string{"stdout"}
cfg.ErrorOutputPaths = []string{"stderr"}
cfg.EncoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
logger, err := cfg.Build()
if err != nil {
panic("init logger error")
}
sugar := Logger.Sugar()
sugar.Info("這是一條測試日志")
}
這個例子是將日志輸出到控制臺,如果想也把日志輸出到文件一份,修改下第 10 和 11 行,代碼如下:
cfg.OutputPaths = []string{"stdout", "./test.log"}
cfg.ErrorOutputPaths = []string{"stderr", "./test.log"}
如果只想輸出到文件,代碼如下:
cfg.OutputPaths = []string{"./test.log"}
cfg.ErrorOutputPaths = []string{"./test.log"}
自定義日志輸出方式
可以使用 zap.RegisterSink 函數來注冊自定義的的輸出方式,該函數第二個參數為一個自定義的工廠函數, 接收一個 *url.URL 類型的指針, 返回一個 Sink 類型和一個 error,所以需要實現 Sink 接口。看一個具體的示例,自定義了一個通過 http 協議輸出到指定接口的輸出方式:
package main
import (
"bytes"
"errors"
"fmt"
"go.uber.org/zap"
"go.uber.org/zap/zapcore"
".NET/http"
"net/url"
)
type Http struct {
Remote *url.URL
}
func (h Http) Sync() error {
return nil
}
func (h Http) Close() error {
return nil
}
func (h Http) Write(p []byte) (n int, err error) {
req, err := http.NewRequest("POST", h.Remote.String(), bytes.NewBuffer(p))
if err != nil {
return 0, nil
}
req.Header.Set("Content-Type", "Application/json")
client := &http.Client{}
resp, err := client.Do(req)
if err != nil {
return 0, nil
}
defer resp.Body.Close()
if resp.StatusCode != 200 {
return -1, errors.New("request failed")
}
return len(p), nil
}
// 實現工廠函數
func httpSink(url *url.URL) (sink zap.Sink, err error) {
h := Http{Remote: url}
return h, nil
}
func main() {
// 注冊自定義方法
if err := zap.RegisterSink("Http", httpSink); err != nil {
fmt.Println(err)
return
}
cfg := zap.NewProductionConfig()
cfg.OutputPaths = []string{"stdout", "http://127.0.0.1/log"}
cfg.ErrorOutputPaths = []string{"stderr", "http://127.0.0.1/log"}
cfg.EncoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
logger, err := cfg.Build()
if err != nil {
panic(err)
}
logger.Sugar().Info("這是一條測試日志")
}
然后啟動一個服務端,代碼如下:
package main
import (
"bytes"
"io/ioutil"
"log"
"net/http"
)
func main() {
http.HandleFunc("/log", func(w http.ResponseWriter, r *http.Request) {
body, _ := ioutil.ReadAll(r.Body)
log.Println("日志內容內容: ", bytes.NewBuffer(body).String())
})
log.Fatal(http.ListenAndServe(":80", nil))
}
然后運行打印日志的代碼,可以看到服務端接收到了日志。