皮皮网

1.Springboot之分布式事务框架Seata实现原理源码分析
2.Thrift入门 | Thrift框架分析（源码角度）
3.ZookeeperApach Curator 框架源码分析：初始化过程（一）Ver 4.3.0
4.腾讯插件化—Shadow源码
5.Android源码定制（3）——Xposed源码编译详解
6.MASA Framework源码解读-01 MASAFacotry工厂设计（一个接口多个实现的框架框架最佳姿势）

Springboot之分布式事务框架Seata实现原理源码分析

       在SpringBoot环境下的分布式事务框架Seata实现原理涉及到了代理数据源、注册代理Bean以及全局事务拦截器等关键环节。调用调用下面我们将逐步解析其核心逻辑。源码源码

       首先，框架框架Seata通过GlobalTransactionScanner来注册项目中所有带有@GlobalTransactional注解的调用调用方法类。该扫描器是源码源码小程序源码调试一个实现了BeanPostProcessor接口的类，它能够在Spring容器初始化时进行后置处理，框架框架从而实现全局事务的调用调用管理。

       GlobalTransactionScanner实际上是源码源码一个InstantiationAwareBeanPostProcessor，它在实例化Bean前执行postProcessBeforeInstantiation方法，框架框架在实例化后执行postProcessAfterInstantiation方法，调用调用并在属性填充时执行postProcessProperties方法。源码源码尽管GlobalTransactionScanner类本身并未覆盖这3个方法，框架框架但在父类的调用调用实现中，这些方法用于处理Bean的源码源码实例化和属性设置过程。

       关键在于postProcessAfterInitialization方法中实现的wrapIfNecessary方法，该方法在GlobalTransactionScanner类中被重写。当方法执行到existsAnnotation方法判断类方法是否带有@GlobalTransactional注解时，如果存在则创建一个GlobalTransactionalInterceptor作为拦截器处理全局事务。

       在创建代理数据源时，Seata通过DataSourceProxy对系统默认数据源进行代理处理。通过shouldSkip方法判断当前bean是否需要被代理，如果bean是SeataProxy的子类且不是DataSource的子类且不在excludes集合中，则进行代理，从而代理当前系统的默认数据源对象。

       全局事务拦截器主要负责全局事务的发起、执行和回滚。在执行全局事务的方法被代理时，具体的执行拦截器是GlobalTransactionalInterceptor。该拦截器处理全局事务的逻辑，包括获取全局事务、开始全局事务、执行本地业务、提交本地事务、记录undo log、提交数据更新等步骤。其中，提交本地事务时会向TC（Transaction Coordinator）注册分支并提交本地事务，整个过程确保了分布式事务的一致性。

       当全局事务中任何一个分支发生异常时，事务将被回滚。参与全局事务的软件验证源码组件在异常发生时执行特定的回滚逻辑，确保事务一致性。在Seata的实现中，异常处理机制确保了事务的回滚能够正确执行。

       Seata还提供了XID（Transaction Identifier）的传递机制，通过RestTemplate和Feign客户端进行服务间的调用，确保分布式系统中各个服务能够共享和处理全局事务。RestTemplate在请求头中放置TX_XID头信息，而Feign客户端通过从调用链中获取Feign.Builder，最终通过SeataHystrixFeignBuilder.builder方法实现XID的传递。

       在被调用端（通过Feign调用服务），Seata自动配置会创建数据源代理，使得事务方法执行时能够获取到连接对象，而这些连接对象已经被代理成DataSourceProxy。SeataHandlerInterceptor拦截器对所有请求进行拦截，从Header中获取TX_XID，参与者的XID绑定到上下文中，通过ConnectionProxy获取代理连接对象。在数据库操作中，XID绑定到ConnectionContext，执行SQL语句时通过StatementProxy或PreparedStatementProxy代理连接，从而完成全局事务的处理。

       综上所述，Seata通过一系列复杂的逻辑和机制，实现了SpringBoot环境下的分布式事务管理，确保了分布式系统中数据的一致性和可靠性。

Thrift入门 | Thrift框架分析（源码角度）

       深入理解Thrift框架，首先需要掌握其基本概念。Thrift是一个用于跨语言通信的框架，其设计初衷是提高开发效率和简化多语言环境下的服务调用。以下是Thrift框架的核心组成部分及其功能概述。

       Thrift框架主要包括两个层：Protocol层和Transport层。Protocol层主要负责数据的序列化和反序列化，而Transport层则负责数据流的传输。Protocol层中包含多种序列化协议，常见的有Compact、Binary、JSON等，它们都继承自TProtocol基类，提供读写抽象操作。

       以TBinaryProtocol为例，它是盗号主机源码一种基于二进制的序列化协议。序列化过程主要包括以下几个关键步骤：

       writeMessageBegin：用于序列化message的开始部分，包括thrift版本、message名称和seqid等信息。

       writeFieldStop：在所有字段序列化完成后，写入T_STOP标识符，表示序列化结束。

       writeI、writeString、writeBinary：分别用于序列化整型、字符串和二进制数据。

       在读取操作中，这些write操作的逆操作被执行，以实现反序列化。Protocol层的实现细节主要体现在读写函数的调用和抽象上。

       Transport层负责数据的实际传输，它提供了一系列抽象方法，如isOpen、open、close、read和write等，用于管理底层连接的打开、关闭和数据读写。常见的Transport层协议包括TFramedTransport和TSocket。TFramedTransport通过缓冲区管理，实现了数据的分帧传输，而TSocket则基于原始的socket实现网络通信。

       为了进一步提高性能，Transport层可能包含缓存和压缩等功能，以优化数据传输效率。Thrift中，TSocket作为底层传输层，负责与原始socket交互，而TFramedTransport等上层Transport则在TSocket的基础上进行扩展，实现数据的高效传输。

       总结，Thrift框架通过其Protocol层和Transport层，实现了跨语言、高效的数据传输。深入理解这些组件及其工作原理，对于开发和优化基于Thrift的分布式系统具有重要意义。

ZookeeperApach Curator 框架源码分析：初始化过程（一）Ver 4.3.0

       Curator是奇迹登录源码由Netflix开源的一款用于简化Zookeeper客户端开发的工具，它提供了一套高级别API，使得开发者可以更简单易懂地实现分布式应用程序。Curator构建在Zookeeper原生客户端之上，提供了连接重试、异常处理、节点监听等常见功能，减轻了开发者的工作负担。Curator由多个模块组成，其中curator-framework和curator-recipes是最常用的部分，此外还提供了分布式锁等功能。

       Curator的最新版本为5.X系列，不再支持ZK 3.4.X及之前的版本。主要的改动在5.X系列中，原因包括代码重构、API调整等，导致不兼容之前的版本。

       Curator的下载地址可以通过Maven依赖管理或Apache官方网站获取。要开始使用Curator，需要搭建Zookeeper集群环境，详细部署过程可参考其他文章。

       引入Curator依赖后，开发者可以使用CuratorFrameworkFactory构建实例，通过此实例连接Zookeeper集群并执行分布式操作，如分布式锁等。Curator内部实现了重试策略、连接管理等，使得操作更为便捷且稳定。

       Curator提供了可重入锁（公平锁）的示例，开发者可以通过简单的代码实现分布式锁功能。初始化CuratorFramework实例的过程包括设置连接参数、构建实例、启动连接等步骤，内部会处理网络重连、异常处理等逻辑。

       在Curator的初始化过程中，CuratorFrameworkImpl是核心类，它负责构建与Zookeeper集群的连接，并封装了一系列关键组件，如连接管理、异常检测、负载均衡等。神奇公式源码CuratorZookeeperClient类负责Zookeeper客户端的封装和调用。

       CuratorFrameworkImpl的启动过程涉及初始化连接状态管理器、启动客户端连接、执行后台操作等关键步骤。通过CAS操作确保线程安全，并在异常情况下自动重试连接。

       连接状态管理器（ConnectionStateManager）负责维护连接状态并处理状态变更通知，确保在状态改变时能够及时通知到监听器。通知机制包括注册一次性监听器、注册CuratorListener和ConnectionStateListener，以及处理未处理的错误。

       Curator的会话管理机制包括连接状态检查和重连策略，确保在连接断开后能够自动恢复连接。在状态变更时，连接状态管理器会通知所有注册的监听器，执行相应的回调逻辑。

       Curator还提供了缓存机制，用于保存节点数据并在数据发生变化时进行更新。此外，Curator支持多次注册监听器，确保在连接断开后能够重新注册监听器，以避免丢失监听事件。

       通过上述分析，Curator为开发者提供了高效、稳定的Zookeeper客户端实现，简化了分布式应用程序的开发过程。在实际应用中，开发者需要根据项目需求选择合适的版本和功能模块，以充分利用Curator提供的便利性。

腾讯插件化—Shadow源码

       腾讯插件化框架Shadow介绍及源码解析

       Shadow是一个由腾讯自主研发的Android插件框架，经过线上亿级用户量的检验，其在插件技术领域展现出不俗的实力。Shadow不仅开源分享了关键代码，还全面分享了上线部署所需的设计方案。

       与市面上其他插件框架相比，Shadow在技术特点上主要体现在：

       支持特性编译与开发环境准备：建议使用最新稳定版本的Android Studio，推荐打开工程并选择sample-app或sample-host模块直接运行，体验不同安装情况下的运行效果。

       代码结构清晰：所有代码集中在projects目录下的三个子目录中，sample目录为体验Shadow的最佳环境，详细信息可参考README文档。

       插件加载与启动流程解析

       插件加载是Shadow框架的核心，从loadPlugin作为起点，通过一系列步骤实现插件的动态加载与启动。包括但不限于：

       本地启动顺序：重点关注启动流程的第一、二步，回溯整个过程最终调用Plugin Manager的DynamicPluginManager.enter方法。

       跨进程调用与Activity加载：调用mDynamicPluginLoader.callApplicationOnCreate方法执行插件加载，之后通过FastPluginManager.convertActivityIntent方法启动Activity。

       Activity与Service加载机制

       在Activity与Service加载机制上，Shadow采用与Android系统自身一致的实现方式：通过修改ClassLoader的parent属性，插入DexClassLoader实现插件apk的加载与Activity的实例化。具体步骤包括：new一个DexClassLoader加载插件apk，从插件ClassLoader中load指定的插件Activity名字，newInstance之后强转为Activity类型使用。

       Shell Activity复用与资源管理

       为了解决资源复用与访问问题，Shadow通过代理Activity的方式，通过Intent的参数确定构造哪个Activity，令壳子Activity能够复用，实现资源的隔离管理。此外，对同名View与资源的处理也非常关键，通过自定义类加载器与AOP技术，解决此类问题。

       组件调用与优化

       对于Service、Content Provider与Broadcast Receiver的调用，Shadow提供了优化方案，如通过ShadowContext启动Service、使用ShadowAcpplication注册静态广播等。

       总结与学习建议

       本文详细解析了插件化框架Shadow的源码与实现机制，深入探讨了其解决插件加载、Activity启动、资源管理等问题的策略。对于深入理解Android插件化技术，实现高效、稳定的插件化解决方案具有重要参考价值。建议对Android核心技术感兴趣的开发者深入阅读《Android核心技术手册》，了解更多关于插件化、热修复等技术的详细内容。

Android源码定制（3）——Xposed源码编译详解

       Android源码定制（3）——Xposed源码编译详解

       在前文中，我们完成了Android 6.0源码从下载到编译的过程，接下来详细讲解Xposed框架源码编译和定制。本文将基于编译后的Android 6.0环境，分为两部分：Xposed源码编译和源码定制，期间遇到的问题主要得益于大佬的博客指导。首先，感谢世界美景大佬的定制教程和肉丝大佬的详细解答。

       1. Xposed源码编译

       为了顺利编译，我们需要理解Xposed各模块版本和对应Android版本的关系，实验环境设为Android 6.0。首先，从Xposed官网下载XposedBridge，并通过Android Studio编译，推荐方式。编译过程涉及理解模块作用、框架初始化机制，以及mmm或Android Studio编译步骤。

       2. XposedBridge编译与集成

       从官网下载XposedBridge后，编译生成XposedBridge.jar，可以选择mmm或Android Studio。编译后，将XposedBridge.jar和api.jar分别放入指定路径，替换相应的系统文件。

       3. XposedArt与Xposed源码下载和替换

       下载并替换Android系统虚拟机art文件夹和Xposed源码，确保Xposed首字母为小写以避免编译错误。

       4. XposedTools编译与配置

       下载XposedTools，配置build.conf，解决编译时缺失的依赖包，如Config::IniFiles。

       5. 生成编译结果与测试

       编译完成后，替换system目录，生成镜像文件并刷入手机，激活Xposed框架，测试模块以确保功能正常。

       6. 错误解决

       常见错误包括Android.mk文件错误、大小写问题以及XposedBridge和Installer版本不匹配，通过查找和分析源码来修复。

       实验总结

       在源码编译过程中，遇到的问题大多可通过源码分析和调整源码版本解决。务必注意版本兼容性，确保Xposed框架能顺利激活并正常使用。

       更多详细资料和文件将在github上分享：[github链接]

       参考

       本文由安全后厨团队原创，如需引用请注明出处，未经授权勿转。关注微信公众号：安全后厨，获取更多相关资讯。

MASA Framework源码解读- MASAFacotry工厂设计（一个接口多个实现的最佳姿势）

       闲来无事，偶然接触到了MASA Framework，此框架是MASA Stack系列中专门用于构建web系统的开源框架。通过在几个小型项目中的应用，我发现它确实拥有诸多优点。为深入理解其内部结构和设计思路，我决定详细阅读MASA Framework的源代码，并记录整个阅读过程。如有任何错误或疑问，还请各位指正。

       MASA Framework是一个功能全面且易于扩展的框架，主要由三个部分组成：BuildingBlocks（抽象层）、Contrib（BuildingBlocks的实现）以及Utils（工具库）。官方将BuildingBlocks称为构建块，实际上，这个层将日常开发中频繁使用到的功能抽象出来，如多租户、多语言、仓储、配置中心等，形成易于替换的接口，大大提高了框架的灵活性和可扩展性。

       MASA Framework包含个主要模块，几乎涵盖了日常开发所需的所有组件，从基础服务到高级功能应有尽有。这些模块协同工作，共同构建了一个强大且功能丰富的框架。

       让我们从MASA Framework的核心设计——构建工厂（MasaFactory）开始探讨。构建工厂在框架中起着至关重要的作用，它负责通过配置选项来创建不同实现的实例。在实际项目中，构建工厂设计用于解决接口具有多种实现时的依赖注入问题，比如在面对多实现的场景时，如何优雅地注入并使用特定的实现类。以下是构建工厂解决多实现问题的具体步骤：

       首先，通过下载MASA Framework的源码（地址：github.com/masastack/MA...）进行研究。我们首先关注的是Masa.BuildingBlocks.Data.Contracts类库的设计。MASA Framework的构建工厂通过选项配置，允许为接口的每个实现类指定一个简短的名称。根据传入的不同名称，构建工厂类的Create方法能够创建对应的实例。

       通过使用MASA Framework的构建工厂，我们能够轻松地创建与特定名称对应的面单消息转换类，而无需依赖于IEnumerable集合进行复杂的筛选。这种方法在实现多实现场景时明显更加直观且高效。

       以物流面单申请为例，不同销售订单对应不同的商家店铺，而每个商家店铺可能选择不同的物流商。利用MASA Framework构建工厂实现不同物流商的面单申请，不仅简化了开发过程，而且在使用层面保持了无感的效果。

       总结而言，MASA Framework提供了强大的构建工厂设计，以解决多实现接口的依赖注入问题，简化了开发流程。这个设计不仅限于构建工厂模块，其他模块同样采用了类似的设计理念，允许用户根据需要替换官方实现或结合自定义实现，以适应不同场景和需求。

       MASA Framework的其他模块同样采用了构建工厂的设计，用户既可以替换官方实现，也可以在程序内同时共存官方实现和自定义实现。例如，Service Caller模块不仅支持使用dapr的服务调用，还提供了HTTP服务调用等选项。

Laravel框架源码分析之Queue 消息队列服务注册

       队列是处理异步任务的关键工具。在 Laravel 中，队列服务提供了轻量级的解决方案，适用于发短信、发邮件等非关键任务。Laravel 支持多种队列驱动类型，包括 sync、database、beanstalkd、sqs、redis，其中，redis 驱动是应用最为广泛的。

       在 Laravel 的启动过程中，队列服务核心类会被注册到服务容器中。接着，注册了 Illuminate\Queue\QueueServiceProvider 服务，其会根据配置文件 app.php 中 providers 数组注册服务提供者。

       Illuminate\Queue\QueueServiceProvider 内部源码负责实现队列服务的注册，其中会调用 registerConfiguredProviders 方法，将配置中的所有服务提供者注册到容器。

       队列服务中，配置可以使用可序列化闭包，以实现更加灵活的配置管理。注册门面中，QueueManager 被定义为队列服务的总入口，提供了一系列与队列相关的操作接口。

       通过 registerConnectors 方法，QueueManager 根据不同的驱动类型注册对应的连接器。这些连接器存入 connectors 属性中，其值为匿名函数，用于在调用时动态返回连接实例。

       队列连接绑定通过 queue.connection 单例绑定匿名函数完成。此匿名函数返回 QueueManager 对象的连接实例，从而实现在创建队列连接时的选择性绑定。

       从注册门面得到的 QueueManager 对象，其 connectors 属性值为匿名函数返回的对应驱动解析器对象。以 redis 驱动为例，通过匿名函数调用执行得到 Illuminate\Queue\Connectors\RedisConnector 实例。随后，使用 connect 方法建立队列连接，redis 驱动实现时返回 RedisQueue 对象。RedisQueue 继承自 Illuminate\Queue\Queue，执行 setConnectionName 方法设置队列连接名称，最后返回 RedisQueue 对象。

       队列消费者注册完成后，会通过注册队列侦听器的方式，使特定的队列任务与处理程序关联。此外，还提供注册失败的工作服务，以确保任务在出现异常时能够得到适当的处理。