1.gotimeԴ?源码????
2.Go 语言一次性定时器使用方式和实现原理
3.client-go 源码分析（4） - ClientSet客户端 和 DynamicClient客户端
4.go源码分析——类型
5.go源码解析之TCP连接（二）——Accept
6.Go的执行原理以及Go的命令

gotimeԴ?????

       哈喽，大家好，分析我是源码asong，今天与大家来聊一聊go语言中的分析"throw、try.....catch{ }"。源码如果你之前是分析hbase region源码解析一名java程序员，我相信你一定吐槽过go语言错误处理方式，源码但是分析这篇文章不是来讨论好坏的，我们本文的源码重点是带着大家看一看panic与recover是如何实现的。上一文我们讲解了defer是分析如何实现的，但是源码没有讲解与defer紧密相连的recover，想搞懂panic与recover的分析实现也没那么简单，就放到这一篇来讲解了。源码废话不多说，分析直接开整。源码

       Go 语言中panic 关键字主要用于主动抛出异常，类似 java 等语言中的 throw 关键字。panic 能够改变程序的控制流，调用 panic 后会立刻停止执行当前函数的剩余代码，并在当前 Goroutine 中递归执行调用方的 defer；

       Go 语言中recover 关键字主要用于捕获异常，让程序回到正常状态，类似 java 等语言中的 try ... catch 。recover 可以中止 panic 造成的程序崩溃。它是一个只能在 defer 中发挥作用的函数，在其他作用域中调用不会发挥作用；

       recover只能在defer中使用这个在标准库的注释中已经写明白了，我们可以看一下：

       这里有一个要注意的点就是recover必须要要在defer函数中使用，否则无法阻止panic。最好的验证方法是先写两个例子：

       运行我们会发现example2()方法的panic是没有被recover住的，导致整个程序直接crash了。这里大家肯定会有疑问，为什么直接写recover()就不能阻止panic了呢。我们在 详解defer实现机制(附上三道面试题，我不信你们都能做对)讲解了defer实现原理，一个重要的知识点**defer将语句放入到栈中时，也会将相关的值拷贝同时入栈。**所以defer recover()这种写法在放入defer栈中时就已经被执行过了，panic是发生在之后，所以根本无法阻止住panic。

       通过运行结果可以看出panic不会影响defer函数的使用，所以他是安全的。

       这里我开了两个协程，一个协程会发生panic，导致程序崩溃，但是只会执行自己所在Goroutine的延迟函数，所以正好验证了多个 Goroutine 之间没有太多的关联，一个 Goroutine 在 panic 时也不应该执行其他 Goroutine 的延迟函数。

       其实我们在实际项目开发中，经常会遇到panic问题， Go 的 runtime 代码中很多地方都调用了 panic 函数，对于不了解 Go 底层实现的新人来说，这无疑是挖了一堆深坑。我们在实际生产环境中总会出现panic，济南溯源码燕窝一盒多少钱但是我们的程序仍能正常运行，这是因为我们的框架已经做了recover，他已经为我们兜住底，比如gin，我们看一看他是怎么做的。

       我们先来写个简单的代码，看看他的汇编调用：执行go tool compile -N -l -S main.go就可以看到对应的汇编码了，我们截取部分片段分析：

       上面重点部分就是画红线的三处，第一步调用runtime.deferprocStack创建defer对象，这一步大家可能会有疑惑，我上一文忘记讲个这个了，这里先简单概括一下，defer总共有三种模型，编译一个函数里只会有一种defer模式。在讲defer实现机制时，我们一起看过defer的结构，其中有一个字段就是_panic，是触发defer的作用，我们来看看的panic的结构：

       简单介绍一下上面的字段：

       上面的pc、sp、goexit我们单独讲一下，runtime包中有一个Goexit方法，Goext能够终止调用它的goroutine，其他的goroutine是不受影响的，goexit也会在终止goroutine之前运行所有延迟调用函数，Goexit不是一个panic，所以这些延迟函数中的任何recover调用都将返回nil。如果我们在主函数中调用了Goexit会终止该goroutine但不会返回func main。由于func main没有返回，因此程序将继续执行其他gorountine，直到所有其他goroutine退出，程序才会crash。

       下面就开始我们的重点吧～。

       在讲defer实现机制时，我们一起看过defer的结构，其中有一个字段就是_panic，是触发defer的作用，我们来看看的panic的结构：简单介绍一下上面的字段：上面的pc、sp、goexit我们单独讲一下，runtime包中有一个Goexit方法，Goext能够终止调用它的goroutine，其他的goroutine是不受影响的，goexit也会在终止goroutine之前运行所有延迟调用函数，Goexit不是一个panic，所以这些延迟函数中的任何recover调用都将返回nil。如果我们在主函数中调用了Goexit会终止该goroutine但不会返回func main。由于func main没有返回，因此程序将继续执行其他gorountine，直到所有其他goroutine退出，程序才会crash。孕妇溯源码燕窝多少钱一盒写个简单的例子：运行上面的例子你就会发现，即使在主goroutine中调用了runtime.Goexit，其他goroutine是没有任何影响的。所以结构中的pc、sp、goexit三个字段都是为了修复runtime.Goexit，这三个字段就是为了保证该函数的一定会生效，因为如果在defer中发生panic，那么goexit函数就会被取消，所以才有了这三个字段做保护。看这个例子：

       英语好的可以看一看这个： github.com/golang/go/is...，这就是上面的一个例子，这里就不过多解释了，了解就好。

       接下来我们再来看一看gopanic方法。

       gopanic的代码有点长，我们一点一点来分析：

       根据不同的类型判断当前发生panic错误，这里没什么多说的，接着往下看。

       上面的代码都是截段，这些部分都是为了判断当前defer是否可以使用开发编码模式，具体怎么操作的就不展开了。

       在第三部分进行defer内联优化选择时会执行调用延迟函数(reflectcall就是这个作用)，也就是会调用runtime.gorecover把recoverd = true，具体这个函数的操作留在下面讲，因为runtime.gorecover函数并不包含恢复程序的逻辑，程序的恢复是在gopanic中执行的。先看一下代码：

       这段代码有点长，主要就是分为两部分：

       第一部分主要是这个判断if gp._panic != nil && gp._panic.goexit && gp._panic.aborted { ... }，正常recover是会绕过Goexit的，所以为了解决这个，添加了这个判断，这样就可以保证Goexit也会被recover住，这里是通过从runtime._panic中取出了程序计数器pc和栈指针sp并且调用runtime.recovery函数触发goroutine的调度，调度之前会准备好 sp、pc 以及函数的返回值。

       第二部分主要是做panic的recover，这也与上面的流程基本差不多，他是从runtime._defer中取出了程序计数器pc和栈指针sp并调用recovery函数触发Goroutine，跳转到recovery函数是通过runtime.call进行的，我们看一下其源码(src/runtime/asm_amd.s 行)：

       因为go语言中的runtime环境是有自己的堆栈和goroutine，recovery函数也是在runtime环境执行的，所以要调度到m->g0来执行recovery函数，我们在看一下recovery函数：

       在recovery 函数中，利用 g 中的两个状态码回溯栈指针 sp 并恢复程序计数器 pc 到调度器中，并调用 gogo 重新调度 g ， goroutine 继续执行，recovery在调度过程中会将函数的返回值设置为1。这个有什么作用呢？ 在deferproc函数中找到了答案：

       当延迟函数中recover了一个panic时，就会返回1，当 runtime.deferproc 函数的网上几百块的源码靠谱吗返回值是 1 时，编译器生成的代码会直接跳转到调用方函数返回之前并执行 runtime.deferreturn，跳转到runtime.deferturn函数之后，程序就已经从panic恢复了正常的逻辑。

       在这里runtime.fatalpanic实现了无法被恢复的程序崩溃，它在中止程序之前会通过 runtime.printpanics 打印出全部的 panic 消息以及调用时传入的参数。

       这就是这个逻辑流程，累死我了。。。。

       结尾给大家发一个小福利，哈哈，这个福利就是如果避免出现panic，要注意这些：这几个是比较典型的，还有很多会发生panic的地方，交给你们自行学习吧～。

       好啦，这篇文章就到这里啦，素质三连（分享、点赞、在看）都是笔者持续创作更多优质内容的动力！

Go 语言一次性定时器使用方式和实现原理

       在 Go 语言的标准库time包中，有一个名为Timer的类型，它代表了一个单一事件的计时器，即一次性定时器。

       在Go语言的项目开发中，定时器的使用非常普遍。本文将向大家介绍如何在Go语言中使用Timer，以及其背后的实现原理。

       要使用Timer一次性定时器，首先需要导入time包。创建Timer的方式有两种：

       func NewTimer(d Duration) *Timer

       使用func NewTimer创建Timer时，需要传入定时器的等待时间。时间到达时，会向channel中发送当前时间。

       示例代码：

       通过阅读上面的代码，我们可以看到我们定义了一个2秒后执行的定时器timer，然后使用select读取timer.C中的数据。当读取到数据时，会执行特定的业务逻辑代码。

       func AfterFunc(d Duration, f func()) *Timer

       使用func AfterFunc创建Timer时，需要传入定时器的等待时间和时间到达时执行的函数。

       示例代码：

       细心的读者可能已经发现，在代码末尾我们使用了time.Sleep()，这是因为time.AfterFunc()是异步执行的，所以需要等待协程退出。

       在Timer的源码中，我们可以看到一个数据结构，它包含两个字段：一个是可导出字段C，这是一个Time类型的channel；另一个是不可导出字段r，这是武德利面粉二维码溯源码一个runtimeTimer类型。

       实际上，每个Go应用程序底层都会有一个特定的协程来管理Timer。当监控到某个Timer指定的时间到达时，这个协程会将当前时间发送到C中，然后上层读取到C中的数据时，执行相关的业务逻辑代码。

       底层协程会监控Timer的r字段中的数据。在源码中查看runtimeTimer的数据结构，我们可以发现其中包含的所有字段。重点了解when、f和arg。

       在简单了解Timer的数据结构后，我们查看func NewTimer的代码，可以看到它的实现非常简单。它实际上就是构造了一个Timer，然后把Timer.r传参给startTimer()，除了startTimer()函数外，还有两个函数，分别是when()和sendTime，其中when()是计算计时器的执行时间，sendTime是计时器时间到达时执行的事件（实际上就是将当前时间写入通道中）。

       sendTime源码：

       我们已经了解到，func NewTimer将构造的Timer.r传参给startTimer()，它负责将runtimeTimer写入底层协程的数组中（如果底层协程未运行，它将会启动底层协程），将Timer交给底层协程监控。也就是说，当底层协程监控到某个Timer指定时间到达时，将当前时间发送到它的通道中。

       本文介绍了Go语言标准库time包提供的一次性定时器Timer，不仅介绍了它的使用方式，还介绍了它的实现原理。

       限于篇幅，本文没有介绍Stop()和Reset()方法，感兴趣的读者可以查阅相关资料。

client-go 源码分析（4） - ClientSet客户端 和 DynamicClient客户端

       本篇讨论的是客户端ClientSet。对比ClientSet和DynamicClient，ClientSet仅能操作内置资源，而DynamicClient则能操作内置资源与CRD。ClientSet具备类型检查，DynamicClient则不包含此特性。

       举例调用ClientSet查询default namespace下所有pod如下：

       核心操作集中在两行代码：clientset.CoreV1()与clientset.CoreV1().Pods(apiv1.NamespaceDefault)。前者返回corev1客户端，后者获取特定namespace下的pod。

       构造pods结构体的newPods函数，将corev1客户端的RESTClient与namespace参数作为参数传入，pods结构体实现PodInterface接口的List方法。

       调用clientset.CoreV1().Pods(apiv1.NamespaceDefault)返回PodInterface接口，后续操作如删除、创建等皆通过restclient客户端实现。

       DynamicClient则是一种动态客户端，可对任意Kubernetes资源进行RESTful操作，包括CRD自定义资源。与ClientSet操作类似，它同样封装了RESTClient，并提供创建、更新、删除、获取、列表、监控、修补等方法。DynamicClient的主要区别在于，它能够访问包括CRD在内的任意Kubernetes资源，而ClientSet仅限于内置资源的访问。

       注意：与ClientSet客户端不同，调用DynamicClient时，需要通过runtime.DefaultUnstructuredConverter将非结构化数据转成Kubernetes资源对象数据类型。欢迎关注微信公众号“后端云”。

go源码分析——类型

       类型是Go语言中的核心概念，用于定义数据的结构和行为。类型可以分为基础类型和自定义类型，编译器会为每种类型生成对应的描述信息，这些信息构成了Go语言的类型系统。内置类型的数据结构在`runtime.type`文件中，而自定义类型的数据结构在`type.go`文件中，包括了类型名称、大小、对齐边界等属性。例如，切片的元素类型和map的键值类型都在其中有所体现。空接口`interface{ }`和非空接口`iface`是描述接口的底层结构体，分别用于表示不包含方法的接口和包含方法的接口。空接口的结构简单，包含类型和数据的位置信息，而非空接口的结构更复杂，包含接口的类型、实体类型和方法信息。接口的实现依赖于方法集的匹配，时间复杂度为O(m+n)。断言是判断一个类型是否实现了某个接口的机制，它依赖于接口的动态类型和类型元数据。类型转换和接口断言遵循类型兼容性原则，而反射提供了访问和操作类型元数据的能力，其核心是`reflect.Type`和`reflect.Value`两个结构体类型，分别用于获取类型信息和操作值。反射的关键在于明确接口的动态类型和类型实现了哪些方法，以及类型元数据与空接口和非空接口的数据结构之间的关系。

go源码解析之TCP连接（二）——Accept

       go源码解析之TCP连接系列基于go源码1..5

       连接是如何建立的

       在上一章中，我们通过追踪net.Listen的调用，深入理解了socket的创建、端口绑定以及监听过程。最后，net.Listen返回了Listener（在具体情况下为TCPListener），本章将通过该Listener的Accept方法的跟踪，揭示连接建立的过程。

       让我们逐步跟踪源码，探索连接建立的具体步骤：

       1. TCPListener的Accept方法

       此方法调用了TCPListener的内部方法accept。

       随后，我们跳过ln.fd.accept和newTCPConn方法的调用，回顾上一章中关于KeepAlive配置项的讨论：KeepAlive是ListenConfig的一个属性，而ListenConfig与创建成功的监听netFD相关联。

       如果KeepAlive值大于等于0，将设置socket开启KeepAlive功能。若为0，则默认设置TCP_KEEPINTVL和TCP_KEEPIDLE属性为秒，否则依据用户设定的时间。

       2. 设置KeepAlive

       setKeepAlive和setKeepAlivePeriod方法类似，负责设置socket属性。在这两个方法中，我们都执行了fd.pfd.SetsockoptInt操作，而pfd是netFD中的属性。

       继续深入，观察poll.FD的SetsockoptInt方法，进而理解进行socket属性设置的过程。fd.Sysfd是创建系统socket的fd。net包中涉及监听、主动connect成功以及accept建立的socket，均通过netFD进行包装，因此，记住层级关系：netFD对poll.FD进行包装，poll.FD对系统fd进行包装。

       额外知识：keepalive参数

       setKeepAlive方法中的SO_KEEPALIVE用于开启keepalive总开关，而setKeepAlivePeriod中的TCP_KEEPINTVL与tcp_keepalive_intvl相关，TCP_KEEPIDLE与tcp_keepalive_time相关。TCP_KEEPCNT对应tcp_keepalive_probes，但代码中未找到使用实例。

       回到accept主流程，继续追踪ln.fd.accept方法调用。

       3. netFD的accept方法

       通过调用pfd.Accept（即poll.FD的Accept方法），我们深入到accept的内部实现。最终，连接成功时返回新连接socket的fd及主机地址信息。遇到EAGAIN错误（非阻塞模式下，系统调用立即返回）且fd.pd.pollable为true时，当前goroutine阻塞等待新消息（即新连接），之后再次调用accept接收连接。

       简述pollDesc（即FD中的pd），它是IO多路复用在go语言中的集成，pd.waitRead等待io消息的到来。后续章节将详细探讨epoll在go语言网络库中的使用。

       最后，netFD的accept方法调用newFD创建了netFD，此过程在上一章已有详细解释。

       至此，连接建立的整个调用链路基本完成，我们通过下图回顾整个过程。

       4. newTCPConn

       conn实现了接口类型Conn，其唯一属性是netFD，核心方法是对netFD方法的封装。

       进一步，TCPConn继承自conn，它提供了ReadFrom方法，用于从Reader中读取数据并写入到TCPConn的socket上。

       5. 小结

       通过跟踪TCPListener的Accept方法，我们详细阐述了server侧接收新连接的过程。总结了关键点，并为下一章分析TCPConn的Read方法，深入理解数据读取过程奠定了基础。

Go的执行原理以及Go的命令

       Go的源码文件主要分为三类：命令源码文件、库源码文件和测试源码文件。

       命令源码文件是Go程序的入口，被声明为main包，包含main函数。文件被安装后，会根据GOPATH设置存放于当前工作区的bin目录或GOBIN设置的目录。这些文件可以单独运行，使用go run命令直接执行，或通过go build或go install生成可执行文件。命令源码文件不应与其他文件混合在同一个代码包中。

       库源码文件不具备命令源码文件的特征，是普通源码文件。文件被安装后，对应的归档文件(.a文件)会被存放在当前工作区的pkg目录下的平台相关目录。库源码文件不能通过go build或go install编译和安装。

       测试源码文件以_test.go为后缀，并包含Test或Benchmark函数。Test函数接受*testing.T参数，用于功能测试；Benchmark函数接受*testing.B参数，用于性能测试。

       命令方面，Go的最新版本1.提供了个基本命令，如build、get、install、run等。build命令用于编译代码包及其依赖；get命令用于下载远程代码仓库中的代码包；install命令用于编译并安装代码包；run命令用于运行命令源码文件。build和install命令会在指定目录生成可执行文件；run命令只能运行命令源码文件。install命令还负责将编译结果移动到bin目录或GOBIN目录。get命令会将代码包下载到GOPATH中的src目录。clean命令用于清除已编译生成的文件。

       fmt命令用来格式化代码文件，通常与gofmt命令结合使用，格式化后的结果会覆盖源代码文件。test命令自动读取_test.go文件，生成并运行测试用的可执行文件。doc命令提供强大的文档功能，可以查看相应package的文档，甚至创建本地版本的golang.org文档。fix命令用于修复老版本代码到新版本，version命令查看当前Go版本，env命令查看Go环境变量，list命令列出当前安装的所有package。

       综上所述，Go的源码文件分类清晰，命令提供了全面的编译、下载、安装、测试和文档支持，满足了开发者的需求。

Go语言源码阅读分析（3）-- unsafe

       Go语言的unsafe包提供了一套打破类型安全限制的操作，但使用时需谨慎，因为它可能导致代码无法移植。包内主要包含unsafe.go文件和一些声明，实际实现和测试用例并未提供。关键内容如下：

       1. Pointer类型：可以转换为任何类型的指针，以及Uintptr类型，这种转换允许直接读写内存，风险极高，需谨慎使用。

        - 可以将任意类型转换为Pointer类型，但转换后不能长于原类型，且要求内存布局一致。例如，将float转换为uint的函数`Floatbits`。

        - Pointer可以转换为uintptr，但这种转换仅用于内存地址的打印，且不能直接从uintptr恢复为Pointer，除非是枚举类型。

       2. 偏移指针：用于访问结构体字段或数组元素，需确保指针不会超出原始对象的内存范围。

       3. syscall调用：在syscall包中，某些函数需要在同一条语句中进行指针到uintptr的转换，以确保指针指向的对象在调用时仍然有效。

       4. reflect包使用：reflect.Value.Pointer和UndafeAddr返回的都是uintptr，应在获取后立即转换为Pointer，避免对象被GC回收。

       5. 反射结构体转换：例如StringHeader和SliceHeader的Data字段，仅在指向活动切片或字符串时有效。

       总之，unsafe包的使用需遵循特定的规则和限制，不当使用可能导致程序不稳定或移植问题。接下来的计划是研究reflect包。

Go 语言设计与实现 笔记 — 定时器源码分析

       本文深入探讨了《Go语言设计与实现》一书中的定时器源码分析，旨在为读者提供关于Go语言中定时器实现的全面理解。阅读过程中，结合源码阅读和资料查阅，补充了书中未详细介绍的内容，旨在帮助读者巩固对Go语言调度器和定时器核心机制的理解。

       在数据结构部分，重点分析了runtime.timer结构体中的pp字段。该字段在书中虽未详细讲解，但在源码中表明了pp代表了定时器在四叉堆中的P（P为调度器的核心组件）位置。深入理解了pp字段对于后续源码解读的重要性。

       进一步，分析了time.Timer与NewTimer之间的关联，以及time.NewTimer函数的实现细节。这一过程揭示了时间间隔设置（when）、时间发送（sendTime）和启动定时器（startTimer）之间的逻辑关系，清晰地展示了NewTimer函数的完整工作流程。

       状态机部分详细解析了addtimer、deltimer、cleantimers和modtimer等函数的实现。addtimer函数用于将定时器添加至当前P的timer四叉堆中，deltimer负责修改定时器状态，cleantimers用于清除堆顶的定时器，而modtimer则用于修改定时器的多个属性。通过深入分析这些函数的源码，揭示了定时器状态转换的完整流程。

       在清除计时器（cleantimers）和调整计时器（adjusttimers）中，讨论了函数如何处理不同状态的定时器，以及如何在调整定时器时保持堆结构的正确性。这些过程展示了Go语言中定时器管理的精细操作。

       运行计时器（runtimer）部分，探讨了定时器执行的条件以及如何在没有定时器执行或第一个定时器未执行时处理返回值。这一分析深入理解了定时器执行机制。

       最后，文章触及了定时器触发机制与调度器、网络轮询器之间的关系，这部分内容有待进一步整理和补充。文章末尾强调了定时器执行时间误差的来源，并鼓励读者提供反馈，以促进学习和知识共享。

       通过本文，读者能够获得对Go语言定时器实现的深入理解，从数据结构、状态转换到执行机制，全面涵盖了定时器的核心概念。本文章旨在为读者提供一个全面的资源，帮助在实践中更好地应用Go语言定时器功能。