文章目录1. ObservationRegistry 接口1.1 核心定义1.2 方法定义1.2.1 静态方法1.2.2 上下文操作抽象方法1.2.3 配置入口1.2.4 默认工具方法1.3 内部类 ObservationConfig1.3.1 核心定义1.3.2 流式注册方法1.3.3 核心内置业务方法2. ObservationRegistry 实现类2.1 SimpleObservationRegistry2.2 DelegatingObservationRegistry2.3 NOOP 匿名子类3. 核心机制3.1 NOOP 空操作机制3.1.1 普通注册表 NOOP 判定规则3.1.2 全局 NOOP 单例3.2 线程上下文作用域管理4. 整体运行流程1. ObservationRegistry 接口1.1 核心定义ObservationRegistry是Micrometer Observation观测体系的全局入口、工厂、配置中心、上下文管理器。整个框架所有观测能力均由该类统一调度与管控是Micrometer可观测体系的基石组件。它的核心定位可总结为双重角色观测工厂根据全局配置动态创建真实观测实例或空操作NOOP观测实现监控动态启停。全局配置中心统一注册、管理所有观测扩展组件驱动观测全生命周期逻辑。1.2 方法定义1.2.1 静态方法作用创建标准实现SimpleObservationRegistry使用入口应用初始化构建Registry实例。staticObservationRegistrycreate()1.2.2 上下文操作抽象方法Scope是观测上下文载体开启Scope代表Observation绑定到当前线程。获取当前线程Scope绑定的ObservationNullableObservationgetCurrentObservation();获取当前激活的Observation.ScopeObservation.NullableScopegetCurrentObservationScope();设置当前线程Scope底层实现线程本地存储ThreadLocal支撑嵌套观测栈Scope close时恢复上一层Scope防止上下文泄漏。voidsetCurrentObservationScope(Observation.NullableScopecurrent);⚠️ 重点get/setCurrentObservationScope是跨组件上下文传递的底层APIScope必须成对open/close否则线程污染、父子链路错乱。1.2.3 配置入口返回内置ObservationConfig用于注册Handler、Predicate、Convention、FilterObservationConfigobservationConfig();1.2.4 默认工具方法判断当前Registry是否为无操作实例业务可提前判断跳过观测埋点逻辑优化性能。defaultbooleanisNoop(){returnthisNOOP;}NOOP无操作空实现单例。关闭观测时使用所有逻辑不生成指标/链路数据避免大量判空采用匿名内部类防止循环初始化。设计思想依赖注入统一传入Registry开关观测只需切换NOOP/ 正常实例业务代码无需改动。1.3 内部类 ObservationConfig1.3.1 核心定义Registry的内置配置容器承载所有观测全局策略采用CopyOnWriteArrayList保证并发注册安全。publicclassObservationConfig成员变量四大组件集合privatefinalListObservationHandler?observationHandlers;// 观测生命周期处理器privatefinalListObservationPredicateobservationPredicates;// 观测启用开关断言privatefinalListObservationConvention?observationConventions;// 全局观测命名规约privatefinalListObservationFilterobservationFilters;// 上下文过滤器1.3.2 流式注册方法observationHandler(ObservationHandler? handler)注册观测事件处理器监听start/stop/error/event/scopeOpen/scopeClose用于生成指标、链路Span、日志。observationPredicate(ObservationPredicate predicate)全局开关任一predicate返回false→ 创建NoopObservation不执行观测。observationFilter(ObservationFilter observationFilter)Observation创建后对Context进行修改统一追加标签、修改观测名称。observationConvention(GlobalObservationConvention? observationConvention)注册全局命名规约统一标准化观测名称、标签。1.3.3 核心内置业务方法T extends Observation.Context ObservationConventionT getObservationConvention(...)遍历已注册规约找到第一个支持当前Context的ObservationConvention找不到则使用传入默认规约。匹配规则顺序遍历首个匹配生效。boolean isObservationEnabled(Nullable String name, Observation.Nullable Context context)执行所有ObservationPredicate全部返回 true 观测才启用任意一个返回false直接禁用。2. ObservationRegistry 实现类ObservationRegistry为顶层接口框架提供三套核心子类实现全局NOOP匿名实现、委托代理实现、SimpleObservationRegistry默认实现。三者共同支撑完整的注册表能力、空操作降级、动态代理切换逻辑。核心子类体系NOOP匿名内部类全局单例空操作注册表DelegatingObservationRegistry可动态切换代理目标的委托注册表SimpleObservationRegistry框架默认标准实现2.1 SimpleObservationRegistry框架标准默认实现承载真正的观测管理、ThreadLocal上下文存储、配置绑定、NOOP判定核心逻辑所有正常观测流程均由该类驱动。classSimpleObservationRegistryimplementsObservationRegistry{// 线程级观测作用域缓存privatestaticfinalThreadLocalObservation.NullableScopelocalObservationScopenewThreadLocal();// 全局配置中心实例privatefinalObservationConfigobservationConfignewObservationConfig();OverridepublicNullableObservationgetCurrentObservation(){return_getCurrentObservation();}// 静态工具方法获取当前活跃观测staticNullableObservation_getCurrentObservation(){Observation.ScopescopelocalObservationScope.get();if(scope!null){returnscope.getCurrentObservation();}returnnull;}OverridepublicObservation.NullableScopegetCurrentObservationScope(){return_getCurrentObservationScope();}// 静态工具方法获取当前作用域staticObservation.NullableScope_getCurrentObservationScope(){returnlocalObservationScope.get();}OverridepublicvoidsetCurrentObservationScope(Observation.NullableScopecurrent){_setCurrentObservationScope(current);}// 静态工具方法设置当前作用域staticvoid_setCurrentObservationScope(Observation.NullableScopecurrent){localObservationScope.set(current);}OverridepublicObservationConfigobservationConfig(){returnthis.observationConfig;}// 核心 NOOP 判定无处理器则为空操作注册表OverridepublicbooleanisNoop(){returnObservationRegistry.super.isNoop()||observationConfig().getObservationHandlers().isEmpty();}}2.2 DelegatingObservationRegistryDelegatingObservationRegistry对外不直接暴露是Observations的内部实现。Observations提供了全局静态观测入口提供静态全局ObservationRegistry解决无法依赖注入场景下埋点获取Registry的痛点。比如静态工具类无法构造注入时兜底使用Observations.getGlobalRegistry()publicclassHttpUtil{// 静态方法埋点publicstaticStringcallRemote(Stringurl){// 获取全局代理 DelegatingObservationRegistryObservationRegistryglobalRegistryObservations.getGlobalRegistry();returnObservation.createNotStarted(http.remote.call,globalRegistry).lowCardinalityKeyValue(url,url).observe(()-{// 发起远程调用returnresponse-data;});}}2.3 NOOP 匿名子类全局单例空操作注册表是接口匿名内部类实现。3. 核心机制3.1 NOOP 空操作机制NOOPNo Operation是空操作机制核心目的是无监控消费者时完全关闭观测逻辑实现零性能开销。分为实例判定、全局单例两层设计。3.1.1 普通注册表 NOOP 判定规则SimpleObservationRegistry的核心判定逻辑只要没有注册任何 Handler直接视为空操作注册表。核心设计思想没有事件消费者就无需生产观测数据直接降级空操作节省性能。即便注册了断言、规约、过滤器依然走 NOOP 逻辑。OverridepublicbooleanisNoop(){// 无处理器 空操作注册表returnObservationRegistry.super.isNoop()||observationConfig().getObservationHandlers().isEmpty();}3.1.2 全局 NOOP 单例全局静态单例ObservationRegistry.NOOP用于全局强制关闭所有观测能力同时解决框架初始化循环依赖问题。关键特性保留ThreadLocal上下文管理能力保证分布式追踪上下文可正常透传内置NoopObservationConfig所有扩展组件列表为空永久禁用观测创建所有埋点强制降级NOOP零指标、零追踪、零日志开销性能无损3.2 线程上下文作用域管理在分布式追踪场景中需要跨方法、跨组件透传TraceId、Span等上下文信息。SimpleObservationRegistry通过ThreadLocal绑定当前线程的活跃观测作用域无需业务手动传参自动实现上下文流转。核心源码// 线程级缓存存储当前线程的观测作用域privatestaticfinalThreadLocalObservation.ScopelocalObservationScopenewThreadLocal();核心价值任意代码位置可通过getCurrentObservation()获取当前观测上下文绑定线程生命周期杜绝上下文覆盖、丢失问题支撑分布式链路追踪的自动上下文传播4. 整体运行流程通过ObservationRegistry.create()创建实例调用registry.observationConfig()链式注册Handler、Predicate、Filter、ConventionObservation.create()创建观测时读取Config通过isObservationEnabled()判断是否启用通过getObservationConvention()获取命名规约使用ObservationFilter修改上下文observation.openScope()→ 调用setCurrentObservationScope()将Scope存入线程本地业务执行中可随时registry.getCurrentObservation()获取活跃观测scope.close()恢复上一层Scope维持嵌套栈结构observation.stop()触发所有ObservationHandler回调导出指标、链路。