对于日志输出即时性要求不高的内容,可以通过异步的方式输出日志,异步输出使得日志打印调用可立即返回,因此效率较高。glog当然支持异步输出特性,并且内部使用了goroutine池来管理异步日志打印任务,可以充分的降低对资源的占用率。

异步输出可以通过日志对象的SetAsync/SetFlags方法,或者通过链式操作Async方法实现。但是需要注意的是,如果通过对象设置方法设置异步输出,那么后续所有的日志输出都将是异步的;如果是通过链式操作输出,那么仅对当前日志输出为异步。

如果对于同一个文件日志输出既采用了同步打印,也采用了异步打印,注意日志文件的内容可能会出现乱序问题,这种情况应当尽量避免。

SetAsync

我们来看一个使用SetAsync方法实现异步打印的示例。

package main

import (
	"context"
	"time"

	"github.com/gogf/gf/v2/frame/g"
)

func main() {
	ctx := context.TODO()
	g.Log().SetAsync(true)
	for i := 0; i < 10; i++ {
		g.Log().Print(ctx, "async log", i)
	}
}

执行后,可以发现终端什么内容也没有输出,因为日志输出的异步的,该示例在日志内容还没有输出之前就退出了。因此,我们可以稍做改进如下:

package main

import (
	"context"
	"time"

	"github.com/gogf/gf/v2/frame/g"
)

func main() {
	ctx := context.TODO()
	g.Log().SetAsync(true)
	for i := 0; i < 10; i++ {
		g.Log().Print(ctx, "async log", i)
	}
	time.Sleep(time.Second)
}

执行后,终端输出结果为:

2019-06-02 15:44:21.399 async log 0
2019-06-02 15:44:21.399 async log 1
2019-06-02 15:44:21.399 async log 2
2019-06-02 15:44:21.399 async log 3
2019-06-02 15:44:21.399 async log 4
2019-06-02 15:44:21.399 async log 5
2019-06-02 15:44:21.399 async log 6
2019-06-02 15:44:21.399 async log 7
2019-06-02 15:44:21.399 async log 8
2019-06-02 15:44:21.399 async log 9

Async链式操作

使用链式操作比较简单。

package main

import (
	"context"
	"time"

	"github.com/gogf/gf/v2/frame/g"
)

func main() {
	ctx := context.TODO()
	for i := 0; i < 10; i++ {
		g.Log().Async().Print(ctx, "async log", i)
	}
	g.Log().Print(ctx, "normal log")
	g.Log().Print(ctx, "normal log")
	g.Log().Print(ctx, "normal log")
	time.Sleep(time.Second)
}

执行后,终端输出结果为:

2022-01-05 15:00:44.101 normal log
2022-01-05 15:00:44.101 async log 0
2022-01-05 15:00:44.101 async log 1
2022-01-05 15:00:44.101 async log 2
2022-01-05 15:00:44.101 async log 3
2022-01-05 15:00:44.101 async log 4
2022-01-05 15:00:44.101 async log 5
2022-01-05 15:00:44.101 async log 6
2022-01-05 15:00:44.101 async log 7
2022-01-05 15:00:44.101 async log 8
2022-01-05 15:00:44.101 async log 9
2022-01-05 15:00:44.101 normal log
2022-01-05 15:00:44.103 normal log



Content Menu

  • No labels

4 Comments

  1. 异步日志的写入耗时是未知的(虽然正常情况下它应该很快),所以在无法确定耗时的情况下使用time.Sleep很难设定一个合适的等待时间。

    那么异步的日志写入是否可以提供一个类似WriteGroup的机制,避免服务关闭时无法保证日志被写入到文件;或者g.Log().Flush()


    1. 好建议,这个等社区来PR吧

  2. Async链式操作  的代码写错了吧,压根就没用到async方法啊

  3. eos

    Async日志模式可以尽快安排上,设置时间来做的异步看起来很鸡肋,建议支持同步、异步(TCP、UDP)模式。