首页 > 其他分享 >golang 异常捕获和处理(panic/recover)

golang 异常捕获和处理(panic/recover)

时间:2023-03-23 10:45:27浏览次数:43  
标签:defer err golang func error recover panic

1.异常处理

Golang 没有结构化异常,使用 panic 抛出错误,recover 捕获错误。

异常的使用场景简单描述:Go中可以抛出一个panic的异常,然后在defer中通过recover捕获这个异常,然后正常处理。

1.1. panic

内置函数
假如函数F中书写了panic语句,会终止其后要执行的代码,在panic所在函数F内如果存在要执行的defer函数列表,按照defer的逆序执行
返回函数F的调用者G,在G中,调用函数F语句之后的代码不会执行,假如函数G中存在要执行的defer函数列表,按照defer的逆序执行
直到goroutine整个退出,并报告错误

1.2.recover

内置函数
用来控制一个goroutine的panicking行为,捕获panic,从而影响应用的行为
一般的调用建议
a). 在defer函数中,通过recever来终止一个goroutine的panicking过程,从而恢复正常代码的执行
b). 可以获取通过panic传递的error

2.使用规则

  1. 利用recover处理panic指令,defer 必须放在 panic 之前定义,另外 recover 只有在 defer 调用的函数中才有效。否则当panic时,recover无法捕获到panic,无法防止panic扩散。
  2. recover 处理异常后,逻辑并不会恢复到 panic 那个点去
  3. 多个 defer 会形成 defer 栈,后定义的 defer 语句会被最先调用

3.使用案例

3.1.正常使用

func main() {
    test()
}

func test() {
    defer func() {
        if err := recover(); err != nil {
            println(err.(string)) // 将 interface{} 转型为具体类型。
        }
    }()

    panic("panic error!")
}
-------------------------------------
 panic error!

3.2.延迟调用中引发的错误,可被后续延迟调用捕获,但仅最后一个错误可被捕获。

func test() {
    defer func() {
        fmt.Println(recover())
    }()

    defer func() {
        panic("defer panic")
    }()

    panic("test panic")
}

func main() {
    test()
}
---------------------------------
defer panic

 

3.3.捕获函数 recover 只有在延迟调用内直接调用才会终止错误,否则总是返回 nil。任何未捕获的错误都会沿调用堆栈向外传递

func test() {
    defer func() {
        fmt.Println(recover()) //有效 打印正确异常
    }()
    defer recover()              //无效!
    defer fmt.Println(recover()) //无效! 打印nil
    defer func() {
        func() {
            println("defer inner") // 打印defer inner
            recover() //无效!
        }()
    }()

    panic("test panic")
}

func main() {
    test()
}
-------------------------------------
defer inner
<nil>
test panic

3.3.服务内某个函数捕获kafka连接错误

func DeviceChangedBroadcast(deviceIdArray ...int) {
	defer func() {
		if err := recover(); err != nil {
			web_kit.Error("err:", err)
		}
	}()

	var array protobuf.DeviceArray
	var kafkaWriter *kafka.Writer
	{
		brokers := strings.Split(kafka_config.URL, ",")
		kafkaWriter = kafka.NewWriter(kafka.WriterConfig{
			Brokers:  brokers,
			Topic:    kafka_config.DeviceTopic,
			Balancer: &kafka.LeastBytes{},
			Dialer:   &kafka.Dialer{SASLMechanism: plain.Mechanism{Username: kafka_config.UserName, Password: kafka_config.Password}},
		})
	}

	bytes, _ := proto.Marshal(&array)
	msg := kafka.Message{
		Key:   []byte("DeviceChangedBroadcast"),
		Value: bytes,
	}
	err := kafkaWriter.WriteMessages(context.Background(), msg)
	if err != nil {
		panic(err)
	}
}
------------------------------------------------------------------------------
level=error ts=2023-03-23T02:23:53.291242Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:28.853231Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:29.351762Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:30.13596Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:34.856285Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:35.715459Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:38.148007Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:41.439562Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:43.850959Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"
level=error ts=2023-03-23T02:24:45.962146Z caller=logger.go:149 err:="dial tcp 10.0.22.111:9092: i/o timeout"

这样服务还能正常提供服务,不会因为kafka出问题了而影响其他业务 

标签:defer,err,golang,func,error,recover,panic
From: https://www.cnblogs.com/zhanchenjin/p/17246551.html

相关文章

  • wails 基于golang 的跨平台开发解决方案
    wails是可以使用golang进行跨平台开发的框架参考使用依赖需要go18+,node15+安装 goinstallgithub.com/wailsapp/wails/v2/cmd/wails@latest......
  • golang解决kafka消息重复发送和重复消费
    1、解决消息重复发送当使用Kafka生产者发送消息时,可以设置消息的Key,使用Key来保证相同Key的消息不会被重复发送。在发送消息时,可以使用带Key的消息发送方式,如下所示:msg......
  • SERVICE_UNAVAILABLE/1/state not recovered / initialized
    #情境首先,我在本地虚拟机中,成功启动了elasticsearch服务,具体没有细看启动日志不过在关闭防火墙和修改访问IP之后,可以通过浏览器访问es服务:http://IP:9200后来通过elasticse......
  • golang 版本管理(windows版本)
    golang版本管理(windows版本) 一、下载版本管理器使用的开源项目地址:https://github.com/voidint/g下载release安装包https://github.com/voidint/g/releases/tag/v1.......
  • golang导出docker镜像
    1.下载镜像//downloadDockerImageimageTagName:="k8s.gcr.io/etcd:3.5.0-0"funcdownloadDockerImage(imageTagNamestring)(string,error){//要执行的命......
  • golang面试题单向链表和双向链表
    甲流难受中,简单发一个链表 1.单项列表packagemainimport( "fmt" "strconv")typeNodestruct{ valueint next*Node}typeLinkliststruct{ leni......
  • 小心golang中的无类型常量
    对于无类型常量,可能大家是第一次听说,但这篇我就不放进拾遗系列里了。因为虽然名字很陌生,但我们每天都在用,每天都有无数潜在的坑被埋下。包括我本人也犯过同样的错误,当时代......
  • golang grpc编译工具的安装
    本次安装前提是已经安装go环境,我的环境是ubuntu20.04。安装环境主要是:protocprotoc-gen-goprotoc-gen-go-grpc1.编译器:protoc的安装参考官方安装方式,方式一如果......
  • 使用 GVM 搭建可维护的 Golang 开发环境
    当你想完成Golang开发环境的便捷安装以及随时更新和保障多个版本的Golang共存的时候,就需要使用到Golang的专门版本管理工具——gvm本篇随笔记录了在Ubunt......
  • Golang之Ginkgo、Gomega测试框架
    命令:BootstrappingaSuite(cdpath/to/books ginkgobootstrap)AddingSpecstoaSuite(ginkgogeneratebook)ExecuteTest(gotest或ginkgo)介绍:导入Ginkgo和Gomega包时......