1.Flink Collector Output 接口源码解析
2.WAVM源码解析 —— WASI接口定义、接口解析接口解析内部实例初始化及实例链接
3.Vert.x 源码解析(4.x)——Context源码解析
4.go源码解析之TCP连接（二）——Accept
5.Spring Configuration：@Import的源码源码用法和源码解析
6.STM32 SPI DMA 源码解析及总结

Flink Collector Output 接口源码解析

       Flink Collector Output 接口源码解析

       Flink中的Collector接口和其扩展Output接口在数据传递中起关键作用。Output接口增加了Watermark功能，接口解析接口解析是源码源码数据传输的基石。本文将深入解析collect方法及相关重要实现类，接口解析接口解析帮助理解数据传递的源码源码美柚源码逻辑和场景划分。

       Collector和Output接口

       Collector接口有2个核心方法，接口解析接口解析Output接口则增加了4个功能，源码源码WatermarkGaugeExposingOutput接口则专注于显示Watermark值。接口解析接口解析主要关注collect方法，源码源码它是接口解析接口解析数据发送的核心操作，Flink中有多个Output实现类，源码源码针对不同场景如数据传递、接口解析接口解析Metrics统计、源码源码广播和时间戳处理。接口解析接口解析

       Output实现类分类

       Output类可以归类为：同一operatorChain内的数据传递（如ChainingOutput和CopyingChainingOutput）、跨operatorChain间（RecordWriterOutput）、统计Metrics（CountingOutput）、广播（BroadcastingOutputCollector）和时间戳处理（TimestampedCollector）。

       示例应用与调用链路

       通过一个示例，我们了解了Kafka Source与Map算子之间的数据传递使用ChainingOutput，而Map到Process之间的传递则用RecordWriterOutput。在不同Output的选择中，objectReuse配置起着决定性作用，影响性能和安全性。

       总结来说，ChainingOutput用于operatorChain内部，RecordWriterOutput处理跨chain，CountingOutput负责Metrics，BroadcastingOutputCollector用于广播，TimestampedCollector则用于设置时间戳。开启objectReuse会影响选择的Output类型。

       阅读推荐

       Flink任务实时监控

       Flink on yarn日志收集

       Kafka Connector更新

       自定义Kafka反序列化

       SQL JSON Format源码解析

       Yarn远程调试源码

       State Processor API状态操作

       侧流输出源码

       Broadcast流状态源码解析

       Flink启动流程分析

       Print SQL Connector取样功能

WAVM源码解析 —— WASI接口定义、内部实例初始化及实例链接

       从前面文章中，我们知道WAVM执行WASM程序的流程。本文着重解析第三、四、stc下载源码五部分：生成内部实例、调用接口与实例链接。

       生成内部实例的关键在于调用接口，接口参数是Intrinsics::Module类型的列表。内部实例不基于WASM程序，仅关注导入导出段内容，因此Intrinsics::Module类仅包含Function、Global、Table、Memory等元素。宏定义WAVM_INTRINSIC_MODULE_REF(wasi)生成一个Intrinsics::Module对象，其实际实现对应WASI标准接口。

       初始化Intrinsics::Module对象通过宏函数WAVM_DEFINE_INTRINSIC_FUNCTION完成，这个宏定义接口并将其赋值给Intrinsics::Module对象。以sched_yield为例，宏定义后生成一个静态的Intrinsics::Function对象，通过构造函数自动赋值到Intrinsics::Module中。

       Intrinsics::instantiateModule()函数执行步骤包括：将moduleRefs转化为IR::Module，编译生成的IR::Module，调用实例化接口函数生成内部实例。关键步骤为将外部接口函数转化为WASM格式的thunks函数，并将thunks导出。最终，通过实例化创建出内部实例，与普通实例的主要区别在于导入段内容的获取方式。

       链接器实现实例化的一大功能，即提供查询导出项的接口。核心逻辑简单，具体实现则较为复杂，本文不展开解析。关于实例化细节，后续文章将深入探讨。

Vert.x 源码解析(4.x)——Context源码解析

       Vert.x 4.x 源码深度解析：Context核心概念详解

       Vert.x 通过Context这一核心机制，解决了多线程环境下的资源管理和状态维护难题。Context在异步编程中扮演着协调者角色，确保线程安全的钻石macd 源码资源访问和有序的异步操作。本文将深入剖析Context的源码结构，包括其接口设计、关键实现以及在Vert.x中的具体应用。

       Context源代码解析

       Context接口定义了基础的事件处理功能，如立即执行和阻塞任务。ContextInternal扩展了Context，包含内部方法和功能，通常开发者无需直接接触，如获取当前线程的Context。在vertx的beginDispatch和endDispatch方法中，Context的切换策略取决于线程类型，Vertx线程会使用上下文切换，而非Vertx线程则依赖ThreadLocal。

       ContextBase是ContextInternal的实现类，负责执行耗时任务，内部包含TaskQueue来管理任务顺序。WorkerContext和EventLoopContext分别对应工作线程和EventLoop线程的执行策略，它们通过execute()、runOnContext()和emit()方法处理任务，同时监控性能。

       Context的创建和获取贯穿于Vert.x的生命周期，它在DeploymentManager的doDeploy方法中被调用，如NetServer和NetClient等组件的底层实现也依赖于Context来处理网络通信。

       额外说明

       Context与线程并非直接绑定，而是根据场景动态管理。部署时创建新Context，非部署时优先获取Thread和ThreadLocal中的Context。当执行异步任务时，当前线程的Context会被暂时替换，任务完成后才恢复。源码中已加入详细注释，如需获取完整注释版本，可联系作者。

       Context的重要性在于其在Vert.x的各个层面如服务器部署、EventBus通信中不可或缺，它负责维护线程同步与异步任务的web大神源码执行顺序，是异步编程中不可或缺的基石。理解Context的实现，有助于更好地利用Vert.x进行高效开发。

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方法，深入理解数据读取过程奠定了基础。

Spring Configuration：@Import的用法和源码解析

       Spring 3.0之后的@Configuration注解和注解配置体系替代了XML配置，本文主要讲解@Import的用法和源码解析。

       @Import的用法

       配置类（带有@Configuration注解）不仅可通过@Bean声明bean，还可通过@Import导入其他类。例如，WebMvcConfig类通过@Import导入其他配置类，同时启用@EnableWebMvc。

       直接导入

       配置类上使用@Import可以导入一个或多个类，甚至可以出现在父类注解中。如WebMvcConfig导入DelegatingWebMvcConfiguration等。

       ImportBeanDefinitionRegistrar和ImportSelector

       @Import除了导入配置类，还可以导入实现了ImportBeanDefinitionRegistrar（如@EnableAspectJAutoProxy）和ImportSelector（如@EnableTransactionManagement）的类。

       源码解析

       ConfigurationClassPostProcessor负责处理@Configuration类，通过ConfigurationClassParser解析配置和导入，由ConfigurationClassBeanDefinitionReader注册BeanDefinition。在解析过程中，处理@Import避免循环导入，通过导入链和ImportStack进行判断。

       处理直接导入时，通过导入链判断循环。

       处理注册器和选择器时，提前触发Aware接口方法，然后在适当时机注册导入的类。

       总结来说，@Import提供了多种导入方式的灵活性，Spring的源码设计考虑了循环导入和重复解析的处理，展示了其强大的自定义配置能力。

STM SPI DMA 源码解析及总结

       一 前言

       在调试STM的SPI接口时，我遇到了一个复杂的难题。解决这一问题花费了大量时间，这次经历促使我回顾并总结了STM的SPI代码。本文将以此为主线，分享我在这个过程中的心得。

       二 初始化

       STM SPI接口的初始化遵循标准流程，包括初始化和配置两部分。确保接口正确初始化，需注意以下几点：

       1. 避免重复使用接口，确保其唯一性。

       2. 检查接口硬件部分是否正常连接，可通过GPIO端口的电平检测。

       3. 选择合适的系统主频，避免设置过高，以匹配SPI接口的速率。

       三 数据收发

       数据收发功能通过HAL库的API实现，主要包括：

       1. 数据发送：`HAL_SPI_Transmit_DMA`函数。

       2. 数据接收：`HAL_SPI_Receive_DMA`函数。

       使用时应特别注意CS（Chip Select）信号的控制，确保在DMA操作期间保持CS低电平，避免数据丢失。

       四 总结

       在SPI开发中，遵循正确流程至关重要。面对问题，应基于对代码的理解和实践经验进行分析，而不是依赖计算机自动解决。正确处理初始化、数据收发等环节，避免常见错误，能有效提升开发效率。

Pytorch nn.Module接口及源码分析

       本文旨在介绍并解析Pytorch中的torch.nn.Module模块，它是构建和记录神经网络模型的基础。通过理解和掌握torch.nn.Module的作用、常用API及其使用方法，开发者能够构建更高效、灵活的神经网络架构。

       torch.nn.Module主要作用在于提供一个基类，用于创建神经网络中的所有模块。它支持模块的树状结构构建，允许开发者在其中嵌套其他模块。通过继承torch.nn.Module，开发者可以自定义功能模块，如卷积层、池化层等，这些模块的前向行为在`forward()`方法中定义。例如：

       python

       import torch.nn as nn

       class SimpleModel(nn.Module):

        def __init__(self):

        super(SimpleModel, self).__init__()

        self.conv1 = nn.Conv2d(in_channels=3, out_channels=6, kernel_size=3)

        self.conv2 = nn.Conv2d(in_channels=6, out_channels=, kernel_size=3)

        def forward(self, x):

        x = self.conv1(x)

        x = self.conv2(x)

        return x

       torch.nn.Module还提供了多种API，包括类变量、重要概念（如parameters和buffer）、数据类型和设备类型转换、hooks等。这些API使开发者能够灵活地控制和操作模型的状态。

       例如，可以通过requires_grad_()方法设置模块参数的梯度追踪，这对于训练过程至关重要。使用zero_grad()方法清空梯度，有助于在反向传播后初始化梯度。`state_dict()`方法用于获取模型状态字典，常用于模型的保存和加载。

       此外，_apply()方法用于执行自定义操作，如类型转换或设备迁移。通过__setattr__()方法，开发者可以方便地修改模块的参数、缓存和其他属性。

       总结而言，torch.nn.Module是Pytorch中构建神经网络模型的核心组件，它提供了丰富的API和功能，支持开发者创建复杂、高效的神经网络架构。通过深入理解这些API和方法，开发者能够更高效地实现各种深度学习任务。

Java原理系列 Java可序列化接口Serializable原理全面用法示例源码分析

       实现Serializable接口的类表示该类可以进行序列化。未实现此接口的类将不会被序列化或反序列化。所有实现Serializable接口的子类也是可序列化的。这个序列化接口没有方法或字段，仅用于标识可序列化的语义。

       为了使非可序列化的类的子类能够进行序列化，子类需要承担保存和恢复父类的公共、受保护以及（如果可访问）包级字段状态的责任。只有当扩展的类具有可访问的无参构造函数来初始化类的状态时，子类才能承担这种责任。如果不满足这个条件，则声明类为可序列化是错误的，错误会在运行时被检测到。

       在反序列化过程中，非可序列化类的字段将使用类的公共或受保护的无参构造函数进行初始化。无参构造函数必须对可序列化的子类可访问。可序列化子类的字段将从流中恢复。

       在遍历图形结构时，可能会遇到不支持Serializable接口的对象。在这种情况下，将抛出NotSerializableException异常，并标识非可序列化对象的类。

       实现Serializable接口的类需要显式指定自己的serialVersionUID，以确保在不同的java编译器实现中获得一致的值。如果未显式声明serialVersionUID，则序列化运行时会根据类的各个方面计算出一个默认的serialVersionUID值。

       在使用Serializable接口时，有一些注意事项需要注意。例如，writeObject方法适用于以下场景：在覆写writeObject方法时，必须调用out.defaultWriteObject()来使用默认的序列化机制将对象的非瞬态字段写入输出流。只有在确实需要自定义序列化行为或保存额外的字段时，才需要覆写writeObject方法。

       可以使用Externalizable接口替代Serializable接口，以实现更细粒度的控制，但需要更多的开发工作。Externalizable接口允许在序列化时指定额外的字段，但需要在类中实现writeExternal和readExternal方法。

       序列化和反序列化的过程是通过ObjectOutputStream和ObjectInputStream来完成的。可以使用这两个类的writeObject和readObject方法来手动控制序列化和反序列化的过程。

       序列化示例：定义了一个Person类，并实现了Serializable接口。Person类有两个字段：name和age。age字段使用了transient关键字修饰，表示该字段不会被序列化。在main方法中，创建了一个Person对象并将其序列化到文件中。从文件中读取序列化的数据，并使用强制类型转换将其转换为Person对象。输出原始的person对象和恢复后的对象，验证序列化和反序列化的结果。

       序列化兼容性示例：在类进行了修改后，可以通过显式声明serialVersionUID来解决之前序列化的对象无法被正确反序列化的问题。

       加密和验证示例：在进行网络传输或持久化存储时，可以使用加密算法对序列化的数据进行加密，或使用数字签名来验证数据的完整性。

       自定义序列化行为示例：如果需要对对象的状态进行特殊处理，或以不同于默认机制的方式序列化对象的字段，可以通过覆写writeObject方法来控制序列化过程。

       使用Externalizable接口的示例：定义一个类，实现Externalizable接口，并在类中实现writeExternal和readExternal方法，用于保存和恢复额外的字段。

       序列化和反序列化的源码分析：序列化示例中的writeObject方法用于将指定的对象写入ObjectOutputStream中进行序列化。而readObject方法用于从ObjectInputStream中读取一个对象进行反序列化。

       序列化和反序列化的核心代码段展示了如何在序列化和反序列化过程中处理对象的类、类的签名以及类和其所有超类的非瞬态和非静态字段的值。确保了对象的完整恢复和验证过程的执行。