1.轻量级内部组件解耦神器 Spring Event（Spring 事件）
2.Vert.x 源码解析(4.x)——Local EvnentBus入门使用和源码解析
3.gem5 源码阅读 之 event
4.Nginx源码分析 - Event事件篇 - Event模块和配置的码解初始化
5.Nginx源码分析 - Event事件篇 - Epoll事件模块
6.说下你可能没用过的EventBus

轻量级内部组件解耦神器 Spring Event（Spring 事件）

       Spring Event，作为Spring框架的码解事件处理机制，提供了一种轻量级的码解内部组件解耦神器。

       具体实现上，码解首先创建一个登录事件，码解这是码解2021新版源码事件驱动解耦的基础。其次，码解构建事件发布者与监听器，码解使得系统能够将事件发布出去，码解同时也能捕捉到相应的码解事件。模拟用户登录场景，码解展示事件处理流程。码解

       运行结果体现了事件驱动的码解优点：同步处理和异步处理并存。使用建议是码解在监听器中采用异步实现，通过@Async注解，码解提升系统响应速度。

       深入探讨Spring Event背后的观察者模式（Observer Pattern），通过类图展示四个关键元素，并阐述其优点在于松耦合。源码解析聚焦于ApplicationEventPublisher、ApplicationEventMulticaster及ApplicationEvent的执行流程，通过事件的发布与广播，最终执行监听器。

       总结，Spring Event通过事件机制，提供了一种高效、灵活的系统解耦方式。其背后的观察者模式与事件流的管理，使得开发者能更好地设计出模块化、易于维护的系统。

Vert.x 源码解析(4.x)——Local EvnentBus入门使用和源码解析

       Vert.x 源码解析(4.x)——Local EvnentBus入门使用和源码解析

       本文将介绍使用和解析Vert.x的本地事件总线（Local EvnentBus）的基本概念、入门使用方法以及源码解析。

       1. 简介

       Vert.x EventBus是一个用于异步通信的分布式事件总线，支持在同个Vert.x应用程序内部或跨多个Vert.x应用程序之间的消息交互，实现组件、模块或服务之间的松耦合与高度可扩展性。

       2. 基本概念

       EventBus分为Local模式和Clustered模式，Local模式适用于项目内部通信，而Clustered模式用于集群间传输。

       3. 入门使用

       3.1 获取EventBus

       每个Vertx实例仅有一个EventBus实例，可使用注册处理器、调用consumer()方法获取MessageConsumer对象。

       在集群模式下注册处理器时，注册信息传播至集群中所有节点可能需要时间。

       3.2 注销处理器

       通过unregister方法注销处理器，在集群模式下，此动作传播至节点可能需要额外时间，可使用回调完成通知。

       3.3 发布消息

       使用publish方法指定地址发布消息，消息将传递给所有在该地址注册的dtu配置软件源码处理器。

       3.4 发送消息

       使用send方法发送消息至指定地址的单个处理器。

       3.5 设置消息头

       在发送或publish消息时可提供DeliveryOptions来设置头信息。

       3.6 消息顺序

       消息按发送顺序传递给处理器。

       3.7 消息对象

       消息处理器接收到的对象类型为Message，包含消息体和头信息。

       3.8 应答消息/发送回复

       通过reply方法在处理器接收到消息后发送回复至消息来源，确认处理。

       3.9 带超时的发送

       使用DeliveryOptions指定超时时间，若超时未收到回复，则调用应答处理器。

       3. 发送失败

       消息发送失败时，应答处理器将接收到异常失败结果。

       3. 消息编解码器

       注册消息编解码器支持发送任何对象，通过DeliveryOptions指定对象类型。

       3. 集群模式的Event Bus

       将多个Vert.x实例组合为集群，实现分布式Event Bus。

       4. 关键类简介

       4.1 主要类的作用

       EventBus、EventBusInternal、EventBusImpl: EventBus接口定义方法，EventBusImpl实现管理消息、监听器注册、消息派发等功能，异步操作。

       HandlerRegistration、MessageConsumerImpl: 消费者实现类，管理订阅关系与消息派发。

       DeliveryContextBase、InboundDeliveryContext、OutboundDeliveryContext: 消息传递管理类，处理发送和接收过程。

       4.2 EventBus系列

       EventBus、EventBusInternal: EventBus接口，EventBusImpl实现。

       4.3 MessageConsumer系列

       MessageConsumerImpl实现消息消费与订阅管理。

       4.4 DeliveryContext系列

       DeliveryContextBase管理消息传递过程，InboundDeliveryContext处理接收消息，OutboundDeliveryContext处理发送消息。

       4.5 Message系列

       Message实现消息对象，MessageImpl具体实现。

       4.5.3 MessageCodec系列

       CodecManager获取解码器，lookupCodec方法实现消息解码。

       5. Local模式EventBus源码解析

       5.1 consumer方法分析

       绑定时调用consumer方法，创建MessageConsumerImpl实例。

       5.2 handler

       注册处理器，涉及HandlerRegistration、EventBusImpl等类。

       5.3 send

       发送消息，EventBusImpl类实现，包括创建消息、斗地主网游源码发送上下文等。

       5.4 reply

       回复消息，与send方法类似。

       5.5 总结

       本地事件总线操作简单，消息发布与发送遵循明确的步骤。回复消息与发送类似，关键在于消息处理与应答机制。

gem5 源码阅读 之 event

       Event在gem5中扮演核心角色，本文将聚焦几个关键问题的解答：

       gem5作为事件驱动型仿真器，能高效处理每个动作或响应，无需频繁检查全局时间，显著降低执行时间。每个继承自EventManager的SimObject实例均可承担事件管理职责。

       SimObject的schedule方法将事件排序并插入全局EventQueue，构建全局事件树。Event执行基于排序后的when+priority值，确保事件有序执行。

       以cache为例，事件注册流程始于DCachePort的recvTimingResp函数中的tickEvent自身调用schedule方法，进一步由cpu调用schedule，实际上就是EventManager的schedule函数，将事件插入到event queue中。

       事件的执行时机取决于其特性，如cache中的tickEvent执行数据传输动作，通常在recvTimingResp函数中触发，此时代表完整数据请求完成的事件点。

       事件树的执行依赖于event queue管理，主event queue在doSimLoop中处理，其他event queue通过thread_loop并行处理，并通过threadBarrier同步所有线程，确保事件同时执行。

       全局eventqueue通过getEventQueue函数生成，参数index指定queue索引，第一次使用时创建新对象，每个queue与一个线程关联，执行相关事件。

       EventQueue创建在不同使用场景中，例如cxx_config方式下，在main.cc文件中直接调用getEventQueue，生成全局eventqueue；gem5 within systemc方式下，在main.cc中实例化SimControl对象，进而调用simulate函数，管理全局eventqueue。

       在Python配置文件中，如fs.py，通过build_test_system函数构建系统组件，cpu的eventq_index参数用于创建全局eventqueue，确保所有相关组件事件同步。

       综上所述，扔色子游戏源码gem5通过事件驱动机制高效仿真系统行为，事件注册、执行、管理流程贯穿整个系统仿真过程，确保复杂系统行为的准确模拟。

Nginx源码分析 - Event事件篇 - Event模块和配置的初始化

       深入探讨Nginx源码分析中的Event事件篇，专注于Event模块和配置的初始化，旨在清晰理解配置解析与模块初始化的协同工作。

       Event模块的配置解析分为两层：最外层的events模块以及内层的ngx_events_module事件模块和ngx_event_core_module事件核心模块。

       在初始化流程中，最开始配置文件的初始化调用的是核心模块的指令集，即events模块的配置解析指令函数：ngx_events_block。这里涉及的事件模块结构主要包括：事件模块本身和事件核心模块，每层模块拥有特定的角色与功能。

       具体而言，事件核心模块初始化函数为ngx_event_module_init，而配置解析流程则始于解析顶层“event”的配置，并通过ngx_conf_parse方法实现。在顶层配置解析完成后，将进入对事件块block中的内容解析，即ngx_events_block方法执行，此方法为事件命令集的回调函数，负责核心模块配置信息的创建。

       配置初始化中，首先在ngx_init_cycle方法中完成核心模块初始化，但由于ngx_events_module中的create_conf方法为NULL，故不会调用创建配置的步骤。接着，顶层配置解析完成后，进入事件块block内容解析，通过遍历模块命令集cmd->set方法，完成具体配置的创建与初始化。

       在配置获取过程中，首先从ngx_events_module获取配置信息，再通过查找找到ngx_event_core_module的配置信息。配置的获取涉及从事件模块到事件核心模块的层级访问，确保配置信息的准确获取。

       综上所述，Event事件篇中的模块和配置初始化通过多层解析与调用，确保了Nginx配置的完整执行与模块功能的有效实现。这一过程不仅涉及配置的层次结构，还涉及到初始化函数的精确调用与配置解析的细致处理，体现了Nginx源码设计的严谨与高效。

Nginx源码分析 - Event事件篇 - Epoll事件模块

       本文重点解析Nginx源码中的epoll事件模块，作为事件模块家族的一员，epoll以其高效性广受开发者喜爱。

       Nginx的epoll事件模块位于源码文件 /event/module/ngx_epoll_module.c 中。

       一、epoll模块的html相框 框架源码数据结构

       epoll模块包含以下三个关键数据结构：

       ngx_epoll_commands: epoll模块命令集

       ngx_epoll_module_ctx: epoll模块上下文

       ngx_epoll_module: epoll模块配置

       二、epoll模块的初始化

       在配置文件初始化阶段，epoll模块的初始化工作主要在核心函数 ngx_events_block 中完成。

       随后，ngx_event_process_init 函数负责执行模块的初始化操作，ngx_epoll_init 用于具体实现epoll模块的初始化。

       三、核心函数

       epoll模块的关键功能体现在 ngx_epoll_process_events 函数，此函数实现了事件的收集和分发功能，是Nginx处理事件的核心。

       以上是对Nginx源码中epoll事件模块的简要分析。

说下你可能没用过的EventBus

       最近在Code Review过程中，我发现了一个业务场景：业务处理完成后，需要通知审核人员，通知方式包括短信和邮件。代码如下：

       这个方法对吗？

       针对这种常见的业务场景，我们首先会考虑同步或异步发送的问题。

       如果选择同步，会对接口的响应时间产生影响，并且与业务逻辑紧密耦合，这显然不是好的做法。

       一般情况下，我们会选择异步方式，使用消息队列（MQ）进行消息的发送和消费，或者使用线程池来处理，这样不会影响主业务逻辑，可以提高性能，并且实现了解耦。

       此外，我们还需要考虑数据一致性的问题，邮件是否一定要发送成功？

       大多数情况下，我们并不要求邮件必须%发送成功，失败了就失败了，只要监控告警的失败率不超过阈值即可。同时，消息服务一旦收到请求，应该自行保证消息的投递。

       因此，总的来说，使用MQ发送消息并自行处理，或者使用线程池进行异步处理，最后自行处理补偿逻辑，就能解决这类问题。

       那么，今天要介绍的是这两种解决方案之外的处理方式。对于这种场景，我们可以使用EventBus来解决。

       EventBus是事件总线的意思，它是Google Guava库的一个工具，基于观察者模式，可以在进程内实现代码的解耦。

       以上面的例子来说，引入MQ可能会有些过于复杂，其实使用EventBus也能达到相同的效果。与MQ相比，EventBus只能提供进程内的消息事件传递，但对于我们的业务场景来说，这已经足够了。

       接下来，我们来看一下EventBus的使用方法。首先，创建一个EventBus实例。

       第二步，创建一个事件消息订阅者，处理方式非常简单，只需在希望处理事件的方法上添加@Subscribe注解即可。

       形参只能有一个，如果定义0个或多个，运行时将会报错。

       第三步，注册事件。

       第四步，发送事件。

       这就是EventBus使用的最简单例子。下面我们看看如何结合开头的例子进行处理。

       比如上面提到的案例，比如注册和用户下单的场景，都需要发送消息和邮件给用户。

       EventBus并不强制要求我们使用单例模式，因为其创建和销毁成本较低，所以更多是根据我们的业务场景和上下文来选择。

       在业务逻辑处理完成后，分别注册了邮件和短信两个事件订阅者。

       最后，我们发送事件，用户注册时发送一个用户ID，下单成功时发送一个订单ID。

       然后写一个测试类进行测试，分别创建两个service，然后分别调用方法。

       执行测试类，我们可以看到输出，分别执行了事件订阅的方法。

       使用起来你会发现非常简单，对于希望轻量级简单地实现解耦，使用EventBus非常合适。

       注意，例子中的参数都是Long类型。如果事件的参数是其他类型，那么消息是无法接收到的。比如，如果我们将下单中发送的订单ID改为String类型，会发现没有消费。因为我们没有定义一个参数类型为String的方法。

       去EmailMsgHandler和SmsMsgHandler都新增一个接收String类型的订阅方法，这样就可以接收到了。

       除此之外，我们还可以定义一个DeadEvent来处理这种情况，它相当于是一个默认的处理方式。当没有匹配的事件类型参数时，就会默认发送一个DeadEvent事件。

       定义一个默认处理器。

       给BookingService新增一个pay()支付方法，下单完成后去支付，注册我们的默认事件。

       执行测试bookingService.pay()，看到输出结果：

       OK，简单的介绍就到这里。到目前为止，我们所说的都是同步调用，这并不符合我们的要求。我们当然希望使用异步处理更好。

       那就看看源码它是如何实现的。

       identifier是一个名字，标记，默认是default。

       executor是执行器，默认创建一个MoreExecutors.directExecutor()，事件订阅者根据你提供的executor来决定如何执行事件订阅的处理方式。

       exceptionHandler是异常处理器，默认创建的就是打点日志。

       subscribers是我们的消费者，订阅者。

       dispatcher用来做事件分发。

       默认创建的executor是一个MoreExecutors.directExecutor()，看到command.run()你就会发现这其实是同步执行。

       同步执行并不太好。我们希望不仅解耦，还要异步执行。EventBus提供了AsyncEventBus，我们可以自己传入executor。

       上面的代码我们改成异步的，这样不就好起来了嘛。实际上，我们可以结合自己的线程池来处理。

       OK，这个说清楚了。我们可以顺便再看看事件分发的处理。看到DeadEvent了吗？没有当前事件的订阅者，就会发送一个DeadEvent事件，bingo！

       OK，这个使用和源码都比较简单，有兴趣的同学可以自己去看看，花不了多少功夫。

       总的来说，EventBus提供了一个更优雅的代码解耦方式，你在实际工作中的业务中肯定能用得上它！

Nginx源码分析 - Event事件篇 - Nginx的Event事件模块概览

       深入分析Nginx的Event事件模块，从nginx_event.c文件中开始理解事件分发器ngx_process_events_and_timers的机制。在前一章中，我们已经触及到事件模块的一些基础概念，通过这个函数，我们能见到Nginx事件流程的启动。

       本章将全面解析Nginx的event模块，对不熟悉网络IO模型的读者，建议先学习这一领域知识。同时，对于Linux下的epoll模型若感到陌生，请先进行深入学习。一切准备工作完成后，我们便可以开始深入探究。

       在event模块中，几个常见且至关重要的数据结构包括：

       1. ngx_listening_s：此结构专门用于管理监听连接的socket。

       2. ngx_connection_s：存储与连接相关的数据及读写事件。

       3. ngx_event_s：封装了事件处理的相关信息。

       为了帮助大家更深入地理解Nginx源码，推荐以下视频内容：

       视频一：从9个组件开始，教你如何高效阅读nginx源码。

       视频二：深入理解epoll的原理与使用，以及它相较于select/poll的优越性。

       视频三：探讨红黑树在不同场景中的应用，从Linux内核到Nginx源码的关联。

       推荐免费学习资源：Linux C/C++开发（涵盖后端/音视频/游戏/嵌入式/高性能网络/存储/基础架构/安全等领域），获取方法如下：加入群获取C/C++ Linux服务器架构师学习资料（包括C/C++、Linux、golang技术、Nginx、ZeroMQ、MySQL、Redis、fastdfs、MongoDB、ZK、流媒体、CDN、P2P、K8S、Docker、TCP/IP、协程、DPDK、ffmpeg等资料），免费分享。

Envoy源码分析之Dispatcher

       Dispatcher在Envoy中扮演着核心角色，是EventLoop的实现，负责任务队列、网络事件处理、定时器与信号处理等关键功能。其设计与Libevent库紧密集成，并通过封装与抽象，简化了内存管理。Dispatcher通过EventLoop提供了非阻塞的事件循环机制，支持多种事件类型，如FileEvent、SignalEvent、Timer等，通过继承unique_ptr来管理Libevent的C结构，利用RAII机制自动处理内存。SignalEvent通过初始化与添加事件使事件处于未决状态。Timer事件通过初始化与添加到Dispatcher中实现超时触发机制，确保在超时时执行。Envoy通过封装Libevent的事件类型，实现事件的抽象与统一处理。FileEvent封装了socket套接字相关的事件，支持主动触发与事件类型的设置。Dispatcher内部的任务队列用于调度与处理回调任务，通过post方法投递任务至队列，并通过循环运行这些任务。Envoy还引入了DeferredDeletable接口，允许对象在特定时间点被安全地析构，避免回调时对象已析构导致的野指针问题，同时确保析构操作在Dispatcher生命周期内完成，避免内存泄漏与程序崩溃。通过实现延迟析构机制，Envoy能够在回调执行前确保对象已正确析构，保障了程序的稳定性和安全性。这一设计与任务队列的实现类似，但在对象析构逻辑上有所不同，更专注于解决多线程环境下对象生命周期管理的复杂性。

Netty源码-Reactor线程模型之NioEventLoopGroup研究

       在Netty网络编程中，NioEventLoopGroup作为线程池的核心组件，其作用至关重要。从初始化的逻辑分析来看，NioEventLoopGroup扮演多重角色，不仅提供了线程池相关功能，同时也继承了线程模型的ScheduledExecutorService，ExecutorService和Executor接口，体现其多功能性。

       其层次结构显示，NioEventLoopGroup从底层向上层层封装，实现了线程池模型的关键功能。进一步深入分析，NioEventLoopGroup通过继承自MultithreadEventLoopGroup，并在构造函数中执行关键初始化操作，展现了其独特的设计。首先，NioEventLoopGroup在初始化时创建线程工厂，构建线程执行器Executor，如果未提供自定义Executor，将使用DefaultThreadFactory创建FastThreadLocalThread线程执行任务。其次，根据指定数量nThreads创建子线程组，若nThreads未定义或设为0，则默认设置为2倍的CPU线程数。最后，在初始化子线程组时，NioEventLoopGroup通过newChild()方法执行初始化，这一步操作具体实现由NioEventLoop类完成，其初始化参数包括线程选择器chooser，以及其他多个关键参数，确保线程高效运行。

       NioEventLoopGroup与Java线程池之间的区别主要体现在其面向特定应用场景的设计上，尤其在事件驱动和非阻塞IO模型的支持方面。Netty通过NioEventLoopGroup实现了更灵活、高效的并发处理机制，使得在处理高并发、高网络流量场景时，性能得到显著提升。

       在研究NioEventLoopGroup的过程中，我们深入学习到了设计模式的应用，如单例模式确保了线程选择器的唯一性，工厂模式则负责创建不同类型的线程组。此外，模板设计模式的使用，使得NioEventLoopGroup能够提供高度抽象的初始化逻辑，同时保持了代码的复用性和可扩展性。通过这种设计，Netty不仅优化了资源管理，还提升了系统的整体性能和稳定性。