1.Vert.x 源码解析(4.x)——Context源码解析
2.说下你可能没用过的源码EventBus
3.消息框架 EventBus 的实现原理
4.Android开发-EventBus使用详解

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

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

       Vert.x 通过Context这一核心机制，解决了多线程环境下的介绍资源管理和状态维护难题。Context在异步编程中扮演着协调者角色，源码确保线程安全的介绍资源访问和有序的异步操作。本文将深入剖析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的exe获取源码创建和获取贯穿于Vert.x的生命周期，它在DeploymentManager的doDeploy方法中被调用，如NetServer和NetClient等组件的底层实现也依赖于Context来处理网络通信。

       额外说明

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

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

说下你可能没用过的EventBus

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

       这个方法对吗？

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

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

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

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

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

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

       那么，今天要介绍的是这两种解决方案之外的处理方式。对于这种场景，我们可以使用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提供了一个更优雅的代码解耦方式，你在实际工作中的业务中肯定能用得上它！

消息框架 EventBus 的实现原理

       免费获取网络安全入门到进阶学习资源

       点击此链接：网络安全入门到进阶全套G学习资源包免费分享！

       事件总线（EventBus）的使用

       EventBus 是用于 Android 的事件发布-订阅机制，简化了组件间通信，尤其是碎片间通信。它有三个关键角色：事件（Event）、订阅者（Subscriber）和发布者（Publisher）。事件可以是任意类型，订阅者处理事件，发布者发布事件，通常使用 `EventBus.getDefault().post(event)` 发布。EventBus 3.0 及以后版本允许自定义事件处理方法名，并通过 `@subscribe` 注解指定线程模型。

       事件线程模型包括：

       POSTING：事件处理在发布事件的线程中。

       MAIN：事件处理在主线程(UI)中，避免耗时操作。

       BACKGROUND：事件处理在后台线程中，同样避免UI操作。

       ASYNC：无论线程如何，事件处理始终在新线程中，UI操作受限。

       使用 EventBus 的例子包括事件注册、发布与监听。

       优先级控制在 `@subscribe` 中通过 `priority` 参数调整，影响事件处理顺序。`stopDelivery` 方法用于终止事件分发，确保优先级高的方法优先接收。

       源码分析关注 EventBus 实例获取、注册、取消注册与事件触发过程。

       网络安全成长路径

       从基础技术学习到更高级别技能，网络安全学习路线分为多阶段。入门阶段掌握基本知识和工具，随后深入学习系统、网络、安全策略、编程语言等，最终提升至高级别威胁分析、安全策略设计和实施。

       学习方法包括视频教程、实践练习和持续更新知识库。CSDN官方提供了免费的入门到进阶全套G学习资源包，涵盖理论、实践和案例分析。

Android开发-EventBus使用详解

        我们大家在使用EventBus的时候，需要了解他的逻辑原理，不必了解它的源码，那么高深。所以我就在这里不讲源码了!

        首先EventBus是一个订阅者模式，也就是像我们关注一个微信公众号一样，公众号是发消息者，我们关注该公众号的人就是订阅的人，也就是收消息的。公众号只要一有新的消息推送，我们的微信就会弹出一条公众号所发的消息，这就像EventBus逻辑一样。

        首先我们使用EventBus时需要注册，具体在什么时间注册，根据自己的需要去注册，如果不注册，EventBus就无法正常发送消息，

        接收者也就无法接收到发送的消息，我的项目是用EventBus传值，所以我就写在Base类中了，不过你们写demo的话可以写在onCreate中。

EventBus注册

        EventBus取消注册（一般我们写在onDestroy中，或者onStop中，不过我都是写在onDestroy中）

        正常使用发送消息，我这里的HomeFragmentRequest 就是一个Bean类，我们可以定义普通类型数据，只不过发送什么类型，我们就要用什么类型去接收

        正常接收消息，也就是接收发送过来的消息(方法名自定义，一定要用发送过来的数据类型#必须带上注解#)

        粘性事件的发送方式

        有人猜到了，接受和普通接受一样只不过在注解的后面加了点作料,这样我们就能在创建前保存，创建之后使用传递过来的数据啦