Closed lzr1994 closed 2 years ago
我的代码: drvRedis, _ := redis.NewDriver(&redis.Conf{ Addr: conf.RedisSetting.RedisHost, Password: conf.RedisSetting.RedisPassword, //Wait: true, }) if err := drvRedis.Ping(); err != nil { log.Fatal(err.Error()) return } log.Println("init redis ======") dCronEngine := dcron.NewDcron("cron_server1", drvRedis, cron.WithSeconds())
tg := new(product_platform.TaskGroup) //每小时执行一次 //dcr.AddFunc("TestTask", "0 0 * * * *", tg.TestTask) dCronEngine.AddFunc("GetBipData", "0 0 * * * *", tg.GetBipData) dCronEngine.AddFunc("GetTeaData", "0 0 * * * *", tg.GetTeaData) dCronEngine.Start()
返回的错误日志: 2022-05-27 20:55:06.386 INFO runtime/proc.go:255 init redis ====== [dcron] 2022/05/27 20:55:06 INFO: addJob 'GetBipData' : 0 0 [dcron] 2022/05/27 20:55:06 INFO: addJob 'GetTeaData' : 0 0 [dcron] 2022/05/27 20:55:06 ERR: dcron start node pool error ERR unkown command or protocal error
部署到linux服务器上就出现错误了,本地没有什么事,请问这是什么问题,执行到start方法的时候就出错了?
看错误信息应该是 redis 命令执行异常,检查下 redis 服务。
我的代码:
drvRedis, _ := redis.NewDriver(&redis.Conf{ Addr: conf.RedisSetting.RedisHost, Password: conf.RedisSetting.RedisPassword, //Wait: true, }) if err := drvRedis.Ping(); err != nil { log.Fatal(err.Error()) return } log.Println("init redis ======") dCronEngine := dcron.NewDcron("cron_server1", drvRedis, cron.WithSeconds())
返回的错误日志: 2022-05-27 20:55:06.386 INFO runtime/proc.go:255 init redis ====== [dcron] 2022/05/27 20:55:06 INFO: addJob 'GetBipData' : 0 0 [dcron] 2022/05/27 20:55:06 INFO: addJob 'GetTeaData' : 0 0 [dcron] 2022/05/27 20:55:06 ERR: dcron start node pool error ERR unkown command or protocal error
部署到linux服务器上就出现错误了,本地没有什么事,请问这是什么问题,执行到start方法的时候就出错了?