Go 并发实战核心编程【二】异常传递

简介: Go 并发实战核心编程【二】异常传递

Go 并发实战核心编程【二】异常传递



1. 需求


  • 异常传递处理
  • 对用户展示友好信息
  • 对技术人员展示堆栈信息


2. 思路


  • 底层异常逻辑处理只是包装,不会增加额外信息
  • 中间层可以在底层异常逻辑之上增加对用户自定义友好信息
  • 上层调用者可以根据断言来识别是否是结构良好的异常或者bug


3. 编码


package main
import (
 "fmt"
 "log"
 "os"
 "os/exec"
 "runtime/debug"
)
// MyError 自定义异常
type MyError struct {
 Inner      error // 最底层的异常 以便在需要时可以查看发生的异常
 Message    string //用户友好信息
 StackTrace string // 堆栈轨迹信息
 Misc       map[string]interface{} // 其他一些自定义信息
}
// 打包错误
func wrapError(err error, messagef string, msgArgs ...interface{}) MyError {
 return MyError{
  Inner:      err,
  Message:    fmt.Sprintf(messagef, msgArgs...),
  StackTrace: string(debug.Stack()),
  Misc:       make(map[string]interface{}),
 }
}
// 实现error接口
func (err MyError) Error() string {
 return err.Message
}
// LowLevelErr 底层error封装
type LowLevelErr struct {
 error
}
func isGloballyExec(path string) (bool, error) {
 info, err := os.Stat(path)
 if err != nil {
  //对最底层的error只是封装,向上层直接传递就行了,这是最基础的错误,不要过多干涉
  return false, LowLevelErr{wrapError(err, err.Error())} 
 }
 return info.Mode().Perm()&0100 == 0100, nil
}
// IntermediateErr 中间层error封装
type IntermediateErr struct {
 error
}
func runJob(id string) error {
 const jobBinPath = "/bad/job/binary"
 isExecutable, err := isGloballyExec(jobBinPath)
 if err != nil {
  // 中间层获取到底层错误之后,再次封装,把底层的error当作内部err处理,但是msg已经是当前中间层的msg了
  return IntermediateErr{wrapError(
   err,
   "cannot run job %q: requisite binaries not available",
   id,
  )}
 } else if isExecutable == false {
  // 如果不是底层异常,那么封装异常的时候err=nil就行,但是因为程序已知的业务逻辑判断
  // 没办法继续执行,那么在封装错误的时候只需要提供msg就可以了
  return wrapError(
   nil,
   "cannot run job %q: requisite binaries are not executable",
   id,
  )
 }
 return exec.Command(jobBinPath, "--id="+id).Run()
}
func handleError(key int, err error, message string) {
 log.SetPrefix(fmt.Sprintf("[logID: %v]: ", key))
 log.Printf("%#v", err) // 处理异常
 fmt.Printf("[%v] %v", key, message) // 用户展示的友好异常信息
}
func main() {
 log.SetOutput(os.Stdout)
 log.SetFlags(log.Ltime | log.LUTC)
 err := runJob("1")
 if err != nil {
  msg := "There was an unexpected issue; please report this as a bug."
  // 在上层调用者这里可以断言是否是我们自定义结构良好的异常,不是的话就是bug
  if _, ok := err.(IntermediateErr); ok {
   msg = err.Error()
  }
  // 处理error
  handleError(1, err, msg)
 }
}


4. 打印


异常信息:
[logID: 1]: 04:20:20 main.IntermediateErr{error:main.MyError{Inner:main.LowLevelErr{error:main.MyError{Inner:(*fs.PathError)(0xc00006c180), Message:"stat /bad/job/binary: no such file or directory", StackTrace:"goroutine 1 [running]:\nruntime/debug.Stack(0xc0000161e0, 0x2f, 0x0)\n\t/Users/jamlee/sdk/go1.16.8/src/runtime/debug/stack.go:24 +0x9f\nmain.wrapError(0x11021d0, 0xc00006c180, 0xc0000161e0, 0x2f, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)\n\t/Users/jamlee/go/src/awesomeProject/at_scale/main.go:24 +0xb4\nmain.isGloballyExec(0x10e0c86, 0xf, 0x0, 0x0, 0x1012c1b)\n\t/Users/jamlee/go/src/awesomeProject/at_scale/main.go:44 +0xc5\nmain.runJob(0x10df348, 0x1, 0x1018301, 0x0)\n\t/Users/jamlee/go/src/awesomeProject/at_scale/main.go:56 +0x48\nmain.main()\n\t/Users/jamlee/go/src/awesomeProject/at_scale/main.go:87 +0x70\n", Misc:map[string]interface {}{}}}, Message:"cannot run job \"1\": requisite binaries not available", StackTrace:"goroutine 1 [running]:\nruntime/debug.Stack(0x10e6a6c, 0x33, 0xc000068ed8)\n\t/Users/jamlee/sdk/go1.16.8/src/runtime/debug/stack.go:24 +0x9f\nmain.wrapError(0x11022f0, 0xc0000102a0, 0x10e6a6c, 0x33, 0xc000068ed8, 0x1, 0x1, 0x0, 0x0, 0x0, ...)\n\t/Users/jamlee/go/src/awesomeProject/at_scale/main.go:24 +0xb4\nmain.runJob(0x10df348, 0x1, 0x1018301, 0x0)\n\t/Users/jamlee/go/src/awesomeProject/at_scale/main.go:59 +0x2dc\nmain.main()\n\t/Users/jamlee/go/src/awesomeProject/at_scale/main.go:87 +0x70\n", Misc:map[string]interface {}{}}}
//给用户展示的信息
[1] cannot run job "1": requisite binaries not available


5. 小结


  • bug是原生异常或者未在你系统中定义的异常
  • 已知异常就是我们定义的异常或者网络断连,瓷盘写入失败等常见异常
  • 一般情况下对用户展示友好信息,对内提供一个ID,可以查询具体堆栈信息
  • 堆栈信息一般会展示异常发生的时间和位置
  • 异常传递切记在调用的过程中忽略错误,这对于上层调用者来说是灾难的

- END -

目录
打赏
0
0
0
0
5
分享
相关文章
Go 语言中的 Sync.Map 详解:并发安全的 Map 实现
`sync.Map` 是 Go 语言中用于并发安全操作的 Map 实现,适用于读多写少的场景。它通过两个底层 Map(`read` 和 `dirty`)实现读写分离,提供高效的读性能。主要方法包括 `Store`、`Load`、`Delete` 等。在大量写入时性能可能下降,需谨慎选择使用场景。
Go语言实战:错误处理和panic_recover之自定义错误类型
本文深入探讨了Go语言中的错误处理和panic/recover机制,涵盖错误处理的基本概念、自定义错误类型的定义、panic和recover的工作原理及应用场景。通过具体代码示例介绍了如何定义自定义错误类型、检查和处理错误值,并使用panic和recover处理运行时错误。文章还讨论了错误处理在实际开发中的应用,如网络编程、文件操作和并发编程,并推荐了一些学习资源。最后展望了未来Go语言在错误处理方面的优化方向。
如何利用Go语言的高效性、并发支持、简洁性和跨平台性等优势,通过合理设计架构、实现负载均衡、构建容错机制、建立监控体系、优化数据存储及实施服务治理等步骤,打造稳定可靠的服务架构。
在数字化时代,构建高可靠性服务架构至关重要。本文探讨了如何利用Go语言的高效性、并发支持、简洁性和跨平台性等优势,通过合理设计架构、实现负载均衡、构建容错机制、建立监控体系、优化数据存储及实施服务治理等步骤,打造稳定可靠的服务架构。
105 1
Go语言中的错误注入与防御编程。错误注入通过模拟网络故障、数据库错误等,测试系统稳定性
本文探讨了Go语言中的错误注入与防御编程。错误注入通过模拟网络故障、数据库错误等,测试系统稳定性;防御编程则强调在编码时考虑各种错误情况,确保程序健壮性。文章详细介绍了这两种技术在Go语言中的实现方法及其重要性,旨在提升软件质量和可靠性。
82 1
go语言编程学习
【11月更文挑战第3天】
68 7
探索Go语言中的并发模式:goroutine与channel
在本文中,我们将深入探讨Go语言中的核心并发特性——goroutine和channel。不同于传统的并发模型,Go语言的并发机制以其简洁性和高效性著称。本文将通过实际代码示例,展示如何利用goroutine实现轻量级的并发执行,以及如何通过channel安全地在goroutine之间传递数据。摘要部分将概述这些概念,并提示读者本文将提供哪些具体的技术洞见。
go进阶编程:Golang中的文件与文件夹操作指南
本文详细介绍了Golang中文件与文件夹的基本操作,包括读取、写入、创建、删除和遍历等。通过示例代码展示了如何使用`os`和`io/ioutil`包进行文件操作,并强调了错误处理、权限控制和路径问题的重要性。适合初学者和有经验的开发者参考。
Go语言:高效并发的编程新星
【10月更文挑战第21】Go语言:高效并发的编程新星
99 7
Go语言的并发特性
【10月更文挑战第26天】Go语言的并发特性
47 1
探索Go语言的并发模式:协程与通道的协同作用
Go语言以其并发能力闻名于世,而协程(goroutine)和通道(channel)是实现并发的两大利器。本文将深入了解Go语言中协程的轻量级特性,探讨如何利用通道进行协程间的安全通信,并通过实际案例演示如何将这两者结合起来,构建高效且可靠的并发系统。
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等