皮皮网

1.sofa Դ?源码?
2.蚂蚁金服轻量级类隔离框架概述 | SOFAArk 源码解析
3.深入学习CAS底层原理

sofa Դ??

       在阅读本文之前，你可能会对 SOFABoot 有所了解，源码但本文更关注其异步初始化功能，源码这项特性在 SpringBoot 的源码基础上增加了更多实用能力。SOFABoot，源码一款由蚂蚁金服开源的源码vba源码打开密码基于 SpringBoot 的框架，旨在增强 SpringBoot 的源码功能并提供便捷地使用 SOFA 中间件的方式。本文将聚焦于 SOFABoot 如何通过异步初始化功能加速应用启动过程。源码

       异步初始化功能的源码引入，使得 Bean 的源码初始化方法在异步线程中执行，从而显著缩短 Spring 上下文加载时间，源码提升应用启动速度。源码这一特性是源码基于 SOFABoot 的 @SofaAsyncInit 注解实现的，该注解允许开发者指定哪些 Bean 的源码初始化方法可以异步执行。

       在深入理解这一功能之前，源码我们先通过一个简单的 Demo 来直观感受异步初始化的效果。通过使用 SOFABoot 框架，我们可以轻松地将两个 Java 类添加为 Bean，任务分销平台源码它们各自包含一个初始化方法。在实际应用中，我们可以在 Bean 的初始化阶段进行数据准备或配置拉取等操作。当启用 @SofaAsyncInit 注解时，Spring 上下文加载时间从 1.s 缩短至仅需几秒，大幅提升了应用启动效率。

       接下来，我们将学习如何在项目中引入 SOFABoot 并利用 @SofaAsyncInit 注解。首先，需要将 SpringBoot 项目转换为 SOFABoot 项目，通过官方文档指导完成这一操作。在 pom.xml 文件中添加相应的依赖，并配置 spring.application.name 参数。然后，通过在 Bean 上添加 @SofaAsyncInit 注解来指定哪些初始化方法可以异步执行。

       此外，我们还可以将 SOFABoot 的热门股源码关键类和功能封装为一个自定义的 starter，使其在其他项目中开箱即用。这不仅限于异步初始化功能，更展示了如何在现有框架基础上扩展功能，实现更高效的开发流程。

       本文不仅介绍了异步初始化功能的实现细节，还探讨了这一特性在实际开发中的应用与优化。它不仅提供了一种加速应用启动的手段，更是一次对 SpringBoot 框架深入理解与源码探索的实践案例。通过学习本文，读者可以掌握如何在项目中引入和利用这一功能，同时提高对 Spring 和相关框架的理解，为后续开发工作提供更强大的支持。

蚂蚁金服轻量级类隔离框架概述 | SOFAArk 源码解析

       SOFAStack，蚂蚁金服自主研发的金融级云原生架构组件集，是金融场景的最佳实践。本文由盲僧作者，来自OYO，平均移动指标源码是《SOFAArk实现原理》系列的第二篇，系列代号暂未提及，详情可查看系列共建列表。该系列关注SOFAArk，一款由蚂蚁金服开源的轻量级类隔离框架，主要用于类隔离和应用合并部署。

       SOFAArk的核心产品SOFAArk Biz的打包插件sofa-ark-maven-plugin，是理解Biz包结构的关键。自年起，SOFAArk在蚂蚁金服内部广泛应用，现已被多家企业采用，如网易云音乐、挖财、溢米教育等。本文将介绍插件的使用、打包产物以及与Spring Boot插件的对比，以帮助理解其工作原理。选股法源码

       SOFAArk的插件使用时，需删除或注释Spring Boot插件，然后引入sofa-ark-maven-plugin。打包后，会产生三个jar包：原生jar、Ark Biz包和Ark执行jar。其中，Ark包和Biz包的结构和Spring Boot的FATJAR有所差异，SOFAArk提供了容器和模块合并部署的能力。

       通过对比Spring Boot的打包产物，SOFAArk的包结构更复杂，因为它包含容器和业务模块。SOFAArk的启动流程涉及Ark容器和插件，这使得它在合并部署上优于Spring Boot。插件原理分析部分，通过调试和流程图揭示了SOFAArk Maven插件的构建逻辑。

       《剖析 | SOFAArk源码》系列致力于深入解析SOFAArk的各个部分，有兴趣的读者可通过公众号“金融级分布式架构”参与共建。SOFAArk的GitHub地址是：github.com/sofastack/so...

深入学习CAS底层原理

       什么是CAS

       CAS是Compare-And-Swap的缩写，意思为比较并交换。以AtomicInteger为例，其提供了compareAndSet(intexpect,intupdate)方法，expect为期望值（被修改的值在主内存中的期望值），update为修改后的值。compareAndSet方法返回值类型为布尔类型，修改成功则返回true，修改失败返回false。

       举个compareAndSet方法的例子：

publicclassAtomticIntegerTest{ publicstaticvoidmain(String[]args){ AtomicIntegeratomicInteger=newAtomicInteger(0);booleanresult=atomicInteger.compareAndSet(0,1);System.out.println(result);System.out.println(atomicInteger.get());}}

       上面例子中，通过AtomicInteger(intinitialValue)构造方法指定了AtomicInteger类成员变量value的初始值为0：

publicclassAtomicIntegerextendsNumberimplementsjava.io.Serializable{ ......privatevolatileintvalue;/***CreatesanewAtomicIntegerwiththegiveninitialvalue.**@paraminitialValuetheinitialvalue*/publicAtomicInteger(intinitialValue){ value=initialValue;}......}

       接着执行compareAndSet方法，main线程从主内存中拷贝了value的副本到工作线程，值为0，并将这个值修改为1。如果此时主内存中value的值还是为0的话（言外之意就是没有被其他线程修改过），则将修改后的副本值刷回主内存更新value的值。所以上面的例子运行结果应该是true和1：

       将上面的例子修改为：

publicclassAtomticIntegerTest{ publicstaticvoidmain(String[]args){ AtomicIntegeratomicInteger=newAtomicInteger(0);booleanfirstResult=atomicInteger.compareAndSet(0,1);booleansecondResult=atomicInteger.compareAndSet(0,1);System.out.println(firstResult);System.out.println(secondResult);System.out.println(atomicInteger.get());}}

       上面例子中，main线程第二次调用compareAndSet方法的时候，value的值已经被修改为1了，不符合其expect的值，所以修改将失败。上面例子输出如下：

CAS底层原理

       查看compareAndSet方法源码：

/***Atomicallysetsthevalueto{ @codenewValue}*ifthecurrentvalue{ @code==expectedValue},*withmemoryeffectsasspecifiedby{ @linkVarHandle#compareAndSet}.**@paramexpectedValuetheexpectedvalue*@paramnewValuethenewvalue*@return{ @codetrue}ifsuccessful.Falsereturnindicatesthat*theactualvaluewasnotequaltotheexpectedvalue.*/publicfinalbooleancompareAndSet(intexpectedValue,intnewValue){ returnU.compareAndSetInt(this,VALUE,expectedValue,newValue);}

       该方法通过调用unsafe类的compareAndSwapInt方法实现相关功能。compareAndSwapInt方法包含四个参数：

       this，当前对象；

       valueOffset，value成员变量的内存偏移量（也就是内存地址）：

privatestaticfinallongvalueOffset;static{ try{ valueOffset=unsafe.objectFieldOffset(AtomicInteger.class.getDeclaredField("value"));}catch(Exceptionex){ thrownewError(ex);}}

       expect，期待值；

       update，更新值。

       所以这个方法的含义为：获取当前对象value成员变量在主内存中的值，和传入的期待值相比，如果相等则说明这个值没有被别的线程修改过，然后将其修改为更新值。

       那么unsafe又是什么？它的compareAndSwapInt方法是原子性的么？查看该方法的源码：

/***AtomicallyupdatesJavavariableto{ @codex}ifitiscurrently*holding{ @codeexpected}.**<p>Thisoperationhasmemorysemanticsofa{ @codevolatile}read*andwrite.CorrespondstoCatomic_compare_exchange_strong.**@return{ @codetrue}ifsuccessful*/@HotSpotIntrinsicCandidatepublicfinalnativebooleancompareAndSetInt(Objecto,longoffset,intexpected,intx);

       该方法并没有具体Java代码实现，方法通过native关键字修饰。由于Java方法无法直接访问底层系统，Unsafe类相当于一个后门，可以通过该类的方法直接操作特定内存的数据。Unsafe类存在于sun.msic包中，JVM会帮我们实现出相应的汇编指令。Unsafe类中的CAS方法是一条CPU并发原语，由若干条指令组成，用于完成某个功能的一个过程。原语的执行必须是连续的，在执行过程中不允许被中断，不会存在数据不一致的问题。

getAndIncrement方法剖析

       了解了CAS原理后，我们回头看下AtomicInteger的getAndIncrement方法源码：

/***Atomicallyincrementsthecurrentvalue,*withmemoryeffectsasspecifiedby{ @linkVarHandle#getAndAdd}.**<p>Equivalentto{ @codegetAndAdd(1)}.**@returnthepreviousvalue*/publicfinalintgetAndIncrement(){ returnU.getAndAddInt(this,VALUE,1);}

       该方法通过调用unsafe类的getAndAddInt方法实现相关功能。继续查看getAndAddInt方法的源码：

/***Atomicallyaddsthegivenvaluetothecurrentvalueofafield*orarrayelementwithinthegivenobject{ @codeo}*atthegiven{ @codeoffset}.**@paramoobject/arraytoupdatethefield/elementin*@paramoffsetfield/elementoffset*@paramdeltathevaluetoadd*@returnthepreviousvalue*@since1.8*/@HotSpotIntrinsicCandidatepublicfinalintgetAndAddInt(Objecto,longoffset,intdelta){ intv;do{ v=getIntVolatile(o,offset);}while(!weakCompareAndSetInt(o,offset,v,v+delta));returnv;}

       结合源码，我们便可以很直观地看出为什么AtomicInteger的getAndIncrement方法是线程安全的了：

       o是AtomicInteger对象本身；offset是AtomicInteger对象的成员变量value的内存地址；delta是需要变更的数量；v是通过unsafe的getIntVolatile方法获得AtomicInteger对象的成员变量value在主内存中的值。dowhile循环中的逻辑为：用当前对象的值和var5比较，如果相同，说明该值没有被别的线程修改过，更新为v+delta，并返回true（CAS）；否则继续获取值并比较，直到更新完成。

CAS的缺点

       CAS并不是完美的，其存在以下这些缺点：

       如果刚好while里的CAS操作一直不成功，那么对CPU的开销大；

       只能确保一个共享变量的原子操作；

       存在ABA问题。

       CAS实现的一个重要前提是需要取出某一时刻的数据并在当下时刻比较交换，这之间的时间差会导致数据的变化。比如：thread1线程从主内存中取出了变量a的值为A，thread2页从主内存中取出了变量a的值为A。由于线程调度的不确定性，这时候thread1可能被短暂挂起了，thread2进行了一些操作将值修改为了B，然后又进行了一些操作将值修改回了A，这时候当thread1重新获取CPU时间片重新执行CAS操作时，会发现变量a在主内存中的值仍然是A，所以CAS操作成功。

解决ABA问题

       那么如何解决CAS的ABA问题呢？由上面的阐述课件，光通过判断值是否相等并不能确保在一定时间差内值没有变更过，所以我们需要一个额外的指标来辅助判断，类似于时间戳，版本号等。

       JUC为我们提供了一个AtomicStampedReference类，通过查看它的构造方法就可以看出，除了指定初始值外，还需指定一个版本号（戳）：

/***Createsanew{ @codeAtomicStampedReference}withthegiven*initialvalues.**@paraminitialReftheinitialreference*@paraminitialStamptheinitialstamp*/publicAtomicStampedReference(VinitialRef,intinitialStamp){ pair=Pair.of(initialRef,initialStamp);}

       我们就用这个类来解决ABA问题，首先模拟一个ABA问题场景：

publicclassAtomticIntegerTest{ publicstaticvoidmain(String[]args){ AtomicReference<String>atomicReference=newAtomicReference<>("A");newThread(()->{ //模拟一次ABA操作atomicReference.compareAndSet("A","B");atomicReference.compareAndSet("B","A");System.out.println(Thread.currentThread().getName()+"线程完成了一次ABA操作");},"thread1").start();newThread(()->{ //让thread2先睡眠2秒钟，确保thread1的ABA操作完成try{ TimeUnit.SECONDS.sleep(2);}catch(InterruptedExceptione){ e.printStackTrace();}booleanresult=atomicReference.compareAndSet("A","B");if(result){ System.out.println(Thread.currentThread().getName()+"线程修改值成功，当前值为："+atomicReference.get());}},"thread2").start();}}

       运行程序，输出如下：

       使用AtomicStampedReference解决ABA问题：

publicclassAtomicIntegerextendsNumberimplementsjava.io.Serializable{ ......privatevolatileintvalue;/***CreatesanewAtomicIntegerwiththegiveninitialvalue.**@paraminitialValuetheinitialvalue*/publicAtomicInteger(intinitialValue){ value=initialValue;}......}0

       程序输出如下：