diff --git a/const.go b/const.go index 1cdad88..d19d14c 100644 --- a/const.go +++ b/const.go @@ -1,3 +1,3 @@ package gojobs -const Version = "1.0.45" +const Version = "1.0.46" diff --git a/jobs_gorm.go b/jobs_gorm.go index 40d1ebe..7a77b02 100644 --- a/jobs_gorm.go +++ b/jobs_gorm.go @@ -8,6 +8,7 @@ import ( "go.dtapp.net/goip" "go.dtapp.net/gojobs/jobs_gorm_model" "go.dtapp.net/golock" + "log" "runtime" ) @@ -114,5 +115,9 @@ func NewJobsGorm(config *JobsGormConfig) (*JobsGorm, error) { return nil, errors.New(fmt.Sprintf("没有配置 cornKeyChannels:%s", c.config.cornKeyChannels)) } + if c.config.debug == true { + log.Printf("配置:%+v\n", c.config) + } + return c, nil } diff --git a/jobs_gorm_redis_get.go b/jobs_gorm_redis_get.go index 41360c4..cc09e94 100644 --- a/jobs_gorm_redis_get.go +++ b/jobs_gorm_redis_get.go @@ -5,6 +5,7 @@ import ( "errors" "fmt" "go.dtapp.net/gojobs/jobs_gorm_model" + "log" "math/rand" "time" ) @@ -63,6 +64,12 @@ func (j *JobsGorm) GetIssueAddress(ctx context.Context, v *jobs_gorm_model.Task) // GetSubscribeClientList 获取在线的客户端 func (j *JobsGorm) GetSubscribeClientList(ctx context.Context) ([]string, error) { + + if j.config.debug == true { + log.Printf("获取在线的客户端:%s\n", j.config.cornPrefix+"_*") + } + + // 扫描 values, err := j.redisClient.Keys(ctx, j.config.cornPrefix+"_*").Result() if err != nil { return nil, errors.New(fmt.Sprintf("获取失败:%s", err.Error()))