解决问题:当redis服务端断开的时候`进程会崩溃(转载6哥笔记)

1 package main 2 3 import ( 4 "fmt" 5 "github.com/astaxie/beego/logs" 6 "github.com/garyburd/redigo/redis" 7 "ha666/initial" 8 _ "ha666/initial" 9 "strconv" 10 "time" 11 ) 12 13 func main() { 14 defer func() { 15 if err := recover(); err != nil { 16 logs.Error("【main】ex:%v", err) 17 time.Sleep(time.Second) 18 } 19 }() 20 logs.Info("开始") 21 rc := initial.RedisClient.Get() 22 defer rc.Close() 23 for { 24 bytesresult, err := redis.ByteSlices(rc.Do("TIME")) 25 if err != nil { 26 fmt.Println(err.Error()) 27 return 28 } 29 for _, v := range bytesresult { 30 _, err = strconv.ParseInt(string(v), 10, 64) 31 if err != nil { 32 fmt.Println(err.Error()) 33 return 34 } 35 //fmt.Println(il) 36 } 37 time.Sleep(10 * time.Millisecond) 38 } 39 }

上面犯了两个错误：

1、defer使用错误 2、redis客户端从pool取出来以后要判断错误 修正后的代码是这样的： 1 package main 2 3 import ( 4 "fmt" 5 "github.com/astaxie/beego/logs" 6 "github.com/garyburd/redigo/redis" 7 "github.com/pkg/errors" 8 "ha666/initial" 9 _ "ha666/initial" 10 "strconv" 11 "time" 12 ) 13 14 func main() { 15 for { 16 bytesresult, err := get_redis() 17 if err != nil { 18 fmt.Println(err.Error()) 19 continue 20 } 21 for _, v := range bytesresult { 22 il, err := strconv.ParseInt(string(v), 10, 64) 23 if err != nil { 24 fmt.Println(err.Error()) 25 continue 26 } 27 fmt.Println(il) 28 } 29 time.Sleep(1000 * time.Millisecond) 30 } 31 } 32 33 func get_redis() ([][]byte, error) { 34 rc := initial.RedisClient.Get() 35 if rc.Err() != nil { 36 return nil, rc.Err() 37 } 38 defer rc.Close() 39 bytesresult, err := redis.ByteSlices(rc.Do("TIME")) 40 return bytesresult, err 41 }

 

转载于:https://www.cnblogs.com/Zmoli775/p/8183678.html