轻量级定时任务 xasynctask

定义在服务里面,可以方便调用服务的方法。

用法:

func InitAsyncTask(service micro.Service) {
    xasynctask.InitRedisKey(service, "dsn")
    xasynctask.AddJob(&xasynctask.Job{
        Name:     "CheckConnector",
        Interval: 60,
        Callback: checkConnector,
    })
}

type Rsp struct {
    Code int  // 返回码,500会告警
    Response string // 响应的日志,默认:success
    UserID int64 // 仅仅用于记录跟某用户相关
    ReqID string // -1就不记录日志,默认自动生成
}

// 定时检查连接
func checkConnector(ctx context.Context, rsp *xasynctask.Rsp) error {
  xxxx // 业务逻辑
}

日志

分析异步任务是否成功、延时情况

image-20200727204642146

异步任务排查问题

image-20200727205055226

Copyright © xinyan all right reserved,powered by Gitbook该文件修订时间: 2020-07-29 10:10:36

results matching ""

    No results matching ""