温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Go Web编程添加服务器错误和访问日志的方法

发布时间:2022-07-08 14:16:44 来源:亿速云 阅读:160 作者:iii 栏目:开发技术

这篇文章主要介绍了Go Web编程添加服务器错误和访问日志的方法的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Go Web编程添加服务器错误和访问日志的方法文章都会有所收获,下面我们一起来看看吧。

初始化日志记录器

我们先来做一下初始化工作,在项目里初始化记录错误日志和访问日志的记录器Logger

// ./utils/vlog
package vlog
import (
    "github.com/sirupsen/logrus"
    "os"
)
var ErrorLog *logrus.Logger
var AccessLog *logrus.Logger
var errorLogFile = "./tmp/log/error.log"
var accessLogFile = "./tmp/log/access.log"
func init () {
    initErrorLog()
    initAccessLog()
}
func initErrorLog() {
    ErrorLog = logrus.New()
    ErrorLog.SetFormatter(&logrus.JSONFormatter{})
    file , err := os.OpenFile(errorLogFile, os.O_RDWR | os.O_CREATE | os.O_APPEND, 0755)
    if err != nil {
        panic(err)
    }
    ErrorLog.SetOutput(file)
}
func initAccessLog() {
    AccessLog = logrus.New()
    AccessLog.SetFormatter(&logrus.JSONFormatter{})
    file , err := os.OpenFile(accessLogFile, os.O_RDWR | os.O_CREATE | os.O_APPEND, 0755)
    if err != nil {
        panic(err)
    }
    AccessLog.SetOutput(file)
}
  • 我们新定义一个packageinit函数中来初始化记录器,这样服务器成功启动前就会初始化好记录器。

  • /tmp/log这个目录要提前创建好,执行init函数时会自动创建好access.logerror.log

添加错误日志

我们创建服务器使用的net/http包的Server类型中,有一个ErrorLog字段供开发者设置记录错误日志用的记录器Logger,默认使用的是log包默认的记录器(应该是系统的标准错误):

type Server struct {
   Addr    string  // TCP address to listen on, ":http" if empty
   Handler Handler // handler to invoke, http.DefaultServeMux if nil
   ...
   // ErrorLog specifies an optional logger for errors accepting
   // connections, unexpected behavior from handlers, and
   // underlying FileSystem errors.
   // If nil, logging is done via the log package's standard logger.
   ErrorLog *log.Logger
     ...
}

我们之前在创建服务器的时候自己实现了Server类型的对象,那么现在要做的就是将上面初始化好的错误日志的记录器指定给ServerErrorLog字段。

func main() {
  ...
    // 将logrus的Logger转换为io.Writer
    errorWriter := vlog.ErrorLog.Writer()
    // 记得关闭io.Writer
    defer errorWriter.Close()
    server := &http.Server{
        Addr:    ":8080",
        Handler: muxRouter,
        // 用记录器转换成的io.Writer创建log.Logger
        ErrorLog: log.New(vlog.ErrorLog.Writer(), "", 0),
    }
    ...
}

添加好错误日志的记录器后,我们找个路由处理函数,在里面故意制造运行时错误验证一下是否能记录到错误。

func (*HelloHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
   ints := []int{0, 1, 2}
   fmt.Fprintf(w, "%v", ints[0:5])
}

在上面处理函数中,通过切片表达式越界故意制造了一个运行时错误,打开error.log后能看到文件里已经记录到这个运行时错误及其Stack trace

Go Web编程添加服务器错误和访问日志的方法

添加访问日志

Server对象可以设置错误日志的记录器不一样,访问日志只能是我们通过自己编写中间件的方式来实现了。在记录访问日志的中间件里我们会记录ipmethodpathqueryrequest_bodystatusresponse_body这些个字段的内容。

statusresponse_body两个字段来自请求对应的响应。响应在net/http包里是用http.ResponseWriter接口表示的

type ResponseWriter interface {
    Header() Header
    Write([]byte) (int, error)
    WriteHeader(statusCode int)
}

接口本身以及net/http提供的实现都没有让我们进行读取的方法,所以在编写的用于记录访问日志的中间件里需要对net/http库本身实现的ResponseWriter做一层包装。

利用Go语言结构体类型嵌套匿名类型后,结构体拥有了被嵌套类型的所有导出字段和方法的特性,我们可以很方便地对原来的ResponseWriter做一层包装,然后只重新实现需要更改的方法即可:

type ResponseWithRecorder struct {
   http.ResponseWriter
   statusCode int
   body bytes.Buffer
}
func (rec *ResponseWithRecorder) WriteHeader(statusCode int) {
   rec.ResponseWriter.WriteHeader(statusCode)
   rec.statusCode = statusCode
}
func (rec *ResponseWithRecorder) Write(d []byte) (n int, err error) {
   n, err = rec.ResponseWriter.Write(d)
   if err != nil {
      return
   }
   rec.body.Write(d)
   return
}

定义好新的类型后我们重新实现了WriteHeaderWrite方法,在向原来的ReponseWriter中写入后也会向ResponseWriteRecoder.statusCode和ResponseWriteRecoder.body写入对应的数据。这样我们就可以在中间件里通过这两个字段访问响应码和响应数据了。

记录访问日志的中间件定义如下:

func AccessLogging (f http.Handler) http.Handler {
    // 创建一个新的handler包装http.HandlerFunc
    return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
        buf := new(bytes.Buffer)
        buf.ReadFrom(r.Body)
        logEntry := vlog.AccessLog.WithFields(logrus.Fields{
            "ip": r.RemoteAddr,
            "method": r.Method,
            "path": r.RequestURI,
            "query": r.URL.RawQuery,
            "request_body": buf.String(),
        })
        wc := &ResponseWithRecorder{
            ResponseWriter: w,
            statusCode: http.StatusOK,
            body: bytes.Buffer{},
        }
        // 调用下一个中间件或者最终的handler处理程序
        f.ServeHTTP(wc, r)
        defer logEntry.WithFields(logrus.Fields{
            "status": wc.statusCode,
            "response_body": wc.body.String(),
        }).Info()
    })
}

Router上应用创建好的AccessLogging中间件后,就可以正常的记录服务器的访问日志了。

// router/router.go
func RegisterRoutes(r *mux.Router) {
    ...
    // apply Logging middleware
    r.Use(middleware.Logging(), middleware.AccessLogging)
    ...
}

不过有两点需要注意一下

  • 这里为了演示获取响应数据记录了response_body字段,如果是接口响应内容记录下还可以,但是如果是HTML还是不记录的为好。

  • 初始化ResponseWithRecorder时默认设置了statusCode是因为,服务器正确返回响应时不会显式调用WriteHeader方法,只有在返回NOT_FOUND之类的错误的时候才会调用WriteHeader方法,针对这种情况需要在初始化的时候把statusCode的默认值设置为200

现在再访问服务器后打开access.log会看到刚刚的访问日志,就能看到刚刚请求的urlmethod,客户端IP等信息了。

{"ip":"......","level":"info","method":"GET","msg":"","path":"/index/","query":"","request_body":"","response_body":"Hello World1","status":200,"time":"2020-03-26T04:21:46Z"}

注意:文章只为说明演示方便,获取IP的方法无法获取代理后的真实IP,请悉知。

关于“Go Web编程添加服务器错误和访问日志的方法”这篇文章的内容就介绍到这里,感谢各位的阅读!相信大家对“Go Web编程添加服务器错误和访问日志的方法”知识都有一定的了解,大家如果还想学习更多知识,欢迎关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI