简单示例，格式化输出：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
package main
import (
“go.uber.org/zap”
“time”
)
func main() {
// zap.NewDevelopment 格式化输出
logger, _ := zap.NewDevelopment()
defer logger.Sync()
logger.Info(“无法获取网址”,
zap.String(“url”, “http://www.baidu.com”),
zap.Int(“attempt”, 3),
zap.Duration(“backoff”, time.Second),
)
}
#输出结果
#2019-01-02T15:01:13.923+0800 INFO spikeProxy/main.go:17 failed to fetch URL {“url”: “http://www.baidu.com”, “attempt”: 3, “backoff”: “1s”}
|
json序列化输出：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
package main
import (
“go.uber.org/zap”
“time”
)
func main() {
// zap.NewProduction json序列化输出
logger, _ := zap.NewProduction()
defer logger.Sync()
logger.Info(“无法获取网址”,
zap.String(“url”, “http://www.baidu.com”),
zap.Int(“attempt”, 3),
zap.Duration(“backoff”, time.Second),
)
}
#输出结果
#{“level”:”info”,”ts”:1546413239.1466308,”caller”:”spikeProxy/main.go:16″,”msg”:”无法获取网址”,”url”:”http://www.baidu.com”,”attempt”:3,”backoff”:1}
|
自定义示例：
选择一个日志库除了高性能是考量的一个标准，高扩展也非常重要，例如：json key 自定义、时间格式化、日志级别等。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
package main
import (
“go.uber.org/zap”
“go.uber.org/zap/zapcore”
“fmt”
“time”
)
func main() {
encoderConfig := zapcore.EncoderConfig{
TimeKey: “time”,
LevelKey: “level”,
NameKey: “logger”,
CallerKey: “caller”,
MessageKey: “msg”,
StacktraceKey: “stacktrace”,
LineEnding: zapcore.DefaultLineEnding,
EncodeLevel: zapcore.LowercaseLevelEncoder, // 小写编码器
EncodeTime: zapcore.ISO8601TimeEncoder, // ISO8601 UTC 时间格式
EncodeDuration: zapcore.SecondsDurationEncoder,
EncodeCaller: zapcore.FullCallerEncoder, // 全路径编码器
}
// 设置日志级别
atom := zap.NewAtomicLevelAt(zap.DebugLevel)
config := zap.Config{
Level: atom, // 日志级别
Development: true, // 开发模式，堆栈跟踪
Encoding: “json”, // 输出格式 console 或 json
EncoderConfig: encoderConfig, // 编码器配置
InitialFields: map[string]interface{}{“serviceName”: “spikeProxy”}, // 初始化字段，如：添加一个服务器名称
OutputPaths: []string{“stdout”, “./logs/spikeProxy.log”}, // 输出到指定文件 stdout（标准输出，正常颜色） stderr（错误输出，红色）
ErrorOutputPaths: []string{“stderr”},
}
// 构建日志
logger, err := config.Build()
if err != nil {
panic(fmt.Sprintf(“log 初始化失败: %v”, err))
}
logger.Info(“log 初始化成功”)
logger.Info(“无法获取网址”,
zap.String(“url”, “http://www.baidu.com”),
zap.Int(“attempt”, 3),
zap.Duration(“backoff”, time.Second),
)
}
#输出结果
#{“level”:”info”,”time”:”2019-01-02T15:38:33.778+0800″,”caller”:”/Users/lcl/go/src/spikeProxy/main.go:54″,”msg”:”log 初始化成功”,”serviceName”:”spikeProxy”}
#{“level”:”info”,”time”:”2019-01-02T15:38:33.778+0800″,”caller”:”/Users/lcl/go/src/spikeProxy/main.go:56″,”msg”:”无法获取网址”,”serviceName”:”spikeProxy”,”url”:”http://www.baidu.com”,”attempt”:3,”backoff”:1}
|
写入归档文件示例：
安装包：gopkg.in/natefinch/lumberjack.v2，Lumberjack是一个Go包，用于将日志写入滚动文件。
zap 不支持文件归档，如果要支持文件按大小或者时间归档，需要使用lumberjack，lumberjack也是zap官方推荐的
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
package main
import (
“go.uber.org/zap”
“go.uber.org/zap/zapcore”
“time”
“gopkg.in/natefinch/lumberjack.v2”
“os”
)
func main() {
hook := lumberjack.Logger{
Filename: “./logs/spikeProxy1.log”, // 日志文件路径
MaxSize: 128, // 每个日志文件保存的最大尺寸 单位：M
MaxBackups: 30, // 日志文件最多保存多少个备份
MaxAge: 7, // 文件最多保存多少天
Compress: true, // 是否压缩
}
encoderConfig := zapcore.EncoderConfig{
TimeKey: “time”,
LevelKey: “level”,
NameKey: “logger”,
CallerKey: “linenum”,
MessageKey: “msg”,
StacktraceKey: “stacktrace”,
LineEnding: zapcore.DefaultLineEnding,
EncodeLevel: zapcore.LowercaseLevelEncoder, // 小写编码器
EncodeTime: zapcore.ISO8601TimeEncoder, // ISO8601 UTC 时间格式
EncodeDuration: zapcore.SecondsDurationEncoder, //
EncodeCaller: zapcore.FullCallerEncoder, // 全路径编码器
EncodeName: zapcore.FullNameEncoder,
}
// 设置日志级别
atomicLevel := zap.NewAtomicLevel()
atomicLevel.SetLevel(zap.InfoLevel)
core := zapcore.NewCore(
zapcore.NewJSONEncoder(encoderConfig), // 编码器配置
zapcore.NewMultiWriteSyncer(zapcore.AddSync(os.Stdout), zapcore.AddSync(&hook)), // 打印到控制台和文件
atomicLevel, // 日志级别
)
// 开启开发模式，堆栈跟踪
caller := zap.AddCaller()
// 开启文件及行号
development := zap.Development()
// 设置初始化字段
filed := zap.Fields(zap.String(“serviceName”, “serviceName”))
// 构造日志
logger := zap.New(core, caller, development, filed)
logger.Info(“log 初始化成功”)
logger.Info(“无法获取网址”,
zap.String(“url”, “http://www.baidu.com”),
zap.Int(“attempt”, 3),
zap.Duration(“backoff”, time.Second))
}
# 控制台输出结果
# {“level”:”info”,”time”:”2019-01-02T16:14:43.608+0800″,”linenum”:”/Users/lcl/go/src/spikeProxy/main.go:56″,”msg”:”log 初始化成功”,”serviceName”:”serviceName”}
# {“level”:”info”,”time”:”2019-01-02T16:14:43.608+0800″,”linenum”:”/Users/lcl/go/src/spikeProxy/main.go:57″,”msg”:”无法获取网址”,”serviceName”:”serviceName”,”url”:”http://www.baidu.com”,”attempt”:3,”backoff”:1}
# 文件输出结果
# {“level”:”info”,”time”:”2019-01-02T16:14:43.608+0800″,”linenum”:”/Users/lcl/go/src/spikeProxy/main.go:56″,”msg”:”log 初始化成功”,”serviceName”:”serviceName”}
# {“level”:”info”,”time”:”2019-01-02T16:14:43.608+0800″,”linenum”:”/Users/lcl/go/src/spikeProxy/main.go:57″,”msg”:”无法获取网址”,”serviceName”:”serviceName”,”url”:”http://www.baidu.com”,”attempt”:3,”backoff”:1}
|
原文链接是简书，可惜链接失效了。。。2333333.
© 版权声明
1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！邮箱：cxysz1@tom.com
2. 分享目的仅供大家学习和交流，您必须在下载后24小时内删除！
3. 不得使用于非法商业用途，不得违反国家法律。否则后果自负！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系管理员处理！
6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，请使用WINRAR解压,如遇到无法解压的请联系管理员！
8. 精力有限，不少源码未能详细测试（解密），不能分辨部分源码是病毒还是误报，所以没有进行任何修改，大家使用前请进行甄别
丞旭猿论坛
2. 分享目的仅供大家学习和交流，您必须在下载后24小时内删除！
3. 不得使用于非法商业用途，不得违反国家法律。否则后果自负！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系管理员处理！
6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，请使用WINRAR解压,如遇到无法解压的请联系管理员！
8. 精力有限，不少源码未能详细测试（解密），不能分辨部分源码是病毒还是误报，所以没有进行任何修改，大家使用前请进行甄别
丞旭猿论坛
THE END
暂无评论内容