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 -

相关文章
|
10月前
|
Linux Go iOS开发
Go语言100个实战案例-进阶与部署篇:使用Go打包生成可执行文件
本文详解Go语言打包与跨平台编译技巧,涵盖`go build`命令、多平台构建、二进制优化及资源嵌入(embed),助你将项目编译为无依赖的独立可执行文件,轻松实现高效分发与部署。
1535 162
|
10月前
|
存储 前端开发 JavaScript
Go语言实战案例-项目实战篇:编写一个轻量级在线聊天室
本文介绍如何用Go语言从零实现一个轻量级在线聊天室,基于WebSocket实现实时通信,支持多人消息广播。涵盖前后端开发、技术选型与功能扩展,助你掌握Go高并发与实时通信核心技术。
998 158
|
11月前
|
数据采集 数据挖掘 测试技术
Go与Python爬虫实战对比:从开发效率到性能瓶颈的深度解析
本文对比了Python与Go在爬虫开发中的特点。Python凭借Scrapy等框架在开发效率和易用性上占优,适合快速开发与中小型项目;而Go凭借高并发和高性能优势,适用于大规模、长期运行的爬虫服务。文章通过代码示例和性能测试,分析了两者在并发能力、错误处理、部署维护等方面的差异,并探讨了未来融合发展的趋势。
1162 0
|
11月前
|
数据采集 Go API
Go语言实战案例:使用context控制协程取消
本文详解 Go 语言中 `context` 包的使用,通过实际案例演示如何利用 `context` 控制协程的生命周期,实现任务取消、超时控制及优雅退出,提升并发程序的稳定性与资源管理能力。
574 152
|
11月前
|
负载均衡 监控 Java
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
在微服务架构中,高可用与稳定性至关重要。本文详解熔断、限流与负载均衡三大关键技术,结合API网关与Hystrix-Go实战,帮助构建健壮、弹性的微服务系统。
1002 1
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
|
11月前
|
安全 Go 开发者
Go语言实战案例:使用sync.Mutex实现资源加锁
在Go语言并发编程中,数据共享可能导致竞态条件,使用 `sync.Mutex` 可以有效避免这一问题。本文详细介绍了互斥锁的基本概念、加锁原理及实战应用,通过构建并发安全的计数器演示了加锁与未加锁的区别,并封装了一个线程安全的计数器结构。同时对比了Go中常见的同步机制,帮助开发者理解何时应使用 `Mutex` 及其注意事项。掌握 `Mutex` 是实现高效、安全并发编程的重要基础。
|
11月前
|
数据采集 Go API
Go语言实战案例:多协程并发下载网页内容
本文是《Go语言100个实战案例 · 网络与并发篇》第6篇,讲解如何使用 Goroutine 和 Channel 实现多协程并发抓取网页内容,提升网络请求效率。通过实战掌握高并发编程技巧,构建爬虫、内容聚合器等工具,涵盖 WaitGroup、超时控制、错误处理等核心知识点。
|
11月前
|
Go 开发者
Go语言实战案例:使用select监听多个channel
本文为《Go语言100个实战案例 · 网络与并发篇》第5篇,详解Go并发核心工具`select`的使用。通过实际案例讲解如何监听多个Channel、实现多任务处理、超时控制和非阻塞通信,帮助开发者掌握Go并发编程中的多路异步事件处理技巧。
|
11月前
|
数据采集 编解码 监控
Go语言实战案例:使用channel实现生产者消费者模型
本文是「Go语言100个实战案例 · 网络与并发篇」第4篇,通过实战案例详解使用 Channel 实现生产者-消费者模型,涵盖并发控制、任务调度及Go语言并发哲学,助你掌握优雅的并发编程技巧。
|
并行计算 安全 Go
Go语言中的并发编程:掌握goroutines和channels####
本文深入探讨了Go语言中并发编程的核心概念——goroutine和channel。不同于传统的线程模型,Go通过轻量级的goroutine和通信机制channel,实现了高效的并发处理。我们将从基础概念开始,逐步深入到实际应用案例,揭示如何在Go语言中优雅地实现并发控制和数据同步。 ####

热门文章

最新文章