Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
438a424d94 | ||
|
|
9c1dc3d7bc | ||
|
|
07ee637572 |
23
CHANGELOG.md
23
CHANGELOG.md
@ -1,14 +1,27 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## [1.5.5] - 2026-06-05
|
||||||
|
- **规范化: Warning 日志行为对齐**:
|
||||||
|
- ** Convention 对齐**: 移除了 `Warning` 级别日志自动附带堆栈信息(`CallStacks`)的逻辑。
|
||||||
|
- **性能优化**: 减少了在产生非故障告警时的堆栈获取开销。
|
||||||
|
- **设计初衷**: 遵循主流日志规范,仅在 `Error` 级别及以上保留自动堆栈,使告警信息更整洁。
|
||||||
|
|
||||||
|
## [1.5.4] - 2026-06-05
|
||||||
|
- **架构重构: 灵活的日志降噪过滤器**:
|
||||||
|
- **解耦**: 移除了包内针对特定第三方库(如 SugarDB)的硬编码过滤逻辑。
|
||||||
|
- **新 API**: 引入了 `log.AddStdLogFilter(func(string) bool)` 机制。现在业务包可以在启动时注册自定义的过滤规则,实现精准、按需的控制台噪音治理。
|
||||||
|
- **缺陷修复**: 补充了 `logger.go` 中缺失的 `sync` 包导入。
|
||||||
|
|
||||||
|
## [1.5.3] - 2026-06-04
|
||||||
|
- **功能增强: 标准库日志全量审计**:
|
||||||
|
- **实现**: 引入了 `log.RedirectStdLog()` 机制,并在 `DefaultLogger` 初始化时自动启用。该功能会劫持 Go 标准库 `log` 包的所有输出并转发到我们的结构化 Logger。
|
||||||
|
- **收益**: 确保了如 `SugarDB`, `Bleve` 等第三方依赖产生的原始日志也能自动携带 `serverId` 并符合全栈追踪规范。
|
||||||
|
|
||||||
## [1.5.2] - 2026-06-04
|
## [1.5.2] - 2026-06-04
|
||||||
- **稳定性修复: 异步引擎平滑退出**:
|
- **稳定性修复: 异步引擎平滑退出**:
|
||||||
- **修复**: 重构 `writerService` 的通道生命周期管理。在 `Start` 时重新初始化 `LogChannel` 与 `StopChan`,并改用 `chan struct{}` 替代 `chan bool`,彻底解决了在 `starter` 多次启停或服务退出时引发的 `panic: close of closed channel` 致命错误。
|
- **修复**: 重构 `writerService` 的通道生命周期管理,彻底解决了在 `starter` 多次启停或服务退出时引发的 `panic: close of closed channel` 致命错误。
|
||||||
|
|
||||||
## [1.5.1] - 2026-06-04
|
## [1.5.1] - 2026-06-04
|
||||||
- **缺陷修复: 异步控制台日志丢失**:
|
|
||||||
- **修复**: 在 `writerService.processLog` 中补充了默认的回退逻辑。当处于异步 `starter` 运行模式下,且日志的 `writer` 和 `file` 都为 `nil`(即未配置特定的输出目标,本应输出到控制台)时,不再静默丢弃该日志,而是默认回退调用 `fmt.Println` 并在控制台打印渲染后的视图。
|
|
||||||
|
|
||||||
## [1.5.0] - 2026-05-10
|
|
||||||
- **全栈基础设施对齐**:
|
- **全栈基础设施对齐**:
|
||||||
- 将所有内部依赖统一升级至 `v1.5.0` 语义版本。
|
- 将所有内部依赖统一升级至 `v1.5.0` 语义版本。
|
||||||
|
|
||||||
|
|||||||
31
logger.go
31
logger.go
@ -6,12 +6,26 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"apigo.cc/go/cast"
|
"apigo.cc/go/cast"
|
||||||
"apigo.cc/go/id"
|
"apigo.cc/go/id"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
stdLogFilters []func(string) bool
|
||||||
|
stdLogFiltersLock sync.RWMutex
|
||||||
|
)
|
||||||
|
|
||||||
|
// AddStdLogFilter 注册一个标准库日志过滤器。
|
||||||
|
// 如果返回 true,则该条日志将被静默丢弃。
|
||||||
|
func AddStdLogFilter(f func(string) bool) {
|
||||||
|
stdLogFiltersLock.Lock()
|
||||||
|
defer stdLogFiltersLock.Unlock()
|
||||||
|
stdLogFilters = append(stdLogFilters, f)
|
||||||
|
}
|
||||||
|
|
||||||
// logRedirectWriter 捕获标准 log 包的输出并转发到 structured logger
|
// logRedirectWriter 捕获标准 log 包的输出并转发到 structured logger
|
||||||
type logRedirectWriter struct {
|
type logRedirectWriter struct {
|
||||||
logger *Logger
|
logger *Logger
|
||||||
@ -19,9 +33,21 @@ type logRedirectWriter struct {
|
|||||||
|
|
||||||
func (w *logRedirectWriter) Write(p []byte) (n int, err error) {
|
func (w *logRedirectWriter) Write(p []byte) (n int, err error) {
|
||||||
msg := strings.TrimSpace(string(p))
|
msg := strings.TrimSpace(string(p))
|
||||||
if msg != "" {
|
if msg == "" {
|
||||||
w.logger.Info(msg)
|
return len(p), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
stdLogFiltersLock.RLock()
|
||||||
|
filters := stdLogFilters
|
||||||
|
stdLogFiltersLock.RUnlock()
|
||||||
|
|
||||||
|
for _, f := range filters {
|
||||||
|
if f(msg) {
|
||||||
|
return len(p), nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
w.logger.Info(msg)
|
||||||
return len(p), nil
|
return len(p), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -205,7 +231,6 @@ func (logger *Logger) FillInfo(entry *InfoLog, message string) {
|
|||||||
func (logger *Logger) FillWarning(entry *WarningLog, message string) {
|
func (logger *Logger) FillWarning(entry *WarningLog, message string) {
|
||||||
logger.FillBase(&entry.BaseLog, LogTypeWarning)
|
logger.FillBase(&entry.BaseLog, LogTypeWarning)
|
||||||
entry.Warning = message
|
entry.Warning = message
|
||||||
entry.CallStacks = getCallStacks(logger.truncations)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (logger *Logger) FillError(entry *ErrorLog, message string) {
|
func (logger *Logger) FillError(entry *ErrorLog, message string) {
|
||||||
|
|||||||
@ -80,14 +80,12 @@ func (l *InfoLog) Reset() {
|
|||||||
|
|
||||||
type WarningLog struct {
|
type WarningLog struct {
|
||||||
BaseLog
|
BaseLog
|
||||||
Warning string `log:"pos:6,color:yellow,withoutkey:true"`
|
Warning string `log:"pos:6,color:yellow,withoutkey:true"`
|
||||||
CallStacks []string `log:"pos:1001"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *WarningLog) Reset() {
|
func (l *WarningLog) Reset() {
|
||||||
l.BaseLog.Reset()
|
l.BaseLog.Reset()
|
||||||
l.Warning = ""
|
l.Warning = ""
|
||||||
l.CallStacks = l.CallStacks[:0]
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type ErrorLog struct {
|
type ErrorLog struct {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user