Spring 通过 Micrometer 提供了对可观测性的支持，它定义了一个观察概念，该概念在应用程序中同时启用度量和跟踪。
Spring cloud Stream 在 Spring Cloud Function 级别集成了这种支持，在几个抽象中提供了一个 ，它包装了函数来处理开箱即用的观察结果。ObservationFunctionAroundWrapper
必需的依赖项
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-core-micrometer</artifactId>
</dependency>以及可用的示踪剂桥之一。例如，Zipkin Brave
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-tracing-bridge-brave</artifactId>
</dependency>命令式函数
命令性函数与观察包装器一起包装，该包装器提供必要的基础结构来处理与观察注册表的交互。
这种交互发生在函数的每次调用中，这实际上意味着观察被附加到函数的每次调用中。
函数（即每条消息的单个观察值）。
换句话说，对于命令式函数，如果存在前面提到的必需依赖关系，则可观测性将起作用。ObservationFunctionAroundWrapper
反应函数
反应式函数与命令式函数本质上是不同的，因此不用 .ObservationFunctionAroundWrapper
命令式函数是一个消息处理函数，每次有消息时由框架调用，有点像典型的事件处理程序，对于 N 条消息，将有 N 次调用此类函数。这允许我们包装这样的函数，用额外的功能来装饰它，比如错误处理、重试，当然还有可观察性。
反应函数是初始化函数。它的工作是将用户提供的流处理代码 （Flux） 与 binder 提供的源流和目标流连接起来。在应用程序启动期间，它仅调用一次。一旦流代码与源/目标流连接，我们就无法看到或控制实际的流处理。它掌握在反应式 API 手中。反应函数还带来了一个额外的变量。鉴于该函数使您可以查看整个流链（而不仅仅是单个事件），那么默认的观察单位应该是什么？ 流链中的单个项目？一系列项目？如果一段时间后没有消息怎么办？等。。.我们想强调的是，对于反应式函数，我们不能假设任何事情。（有关反应式函数和命令式函数之间差异的更多信息，请参阅反应式函数）。
因此，就像重试和错误处理一样，您需要手动处理观察。
值得庆幸的是，您可以通过使用响应式 API 的操作来访问流的一段，同时提供 .该段定义了一个观察单位，它可以是通量中的单个项目或范围，也可以是您可能希望在流中观察的任何其他内容。tapObservationRegistry
@SpringBootApplication
public class DemoStreamApplication {
Logger logger = LoggerFactory.getLogger(DemoStreamApplication.class);
public static void main(String[] args) {
Hooks.enableAutomaticContextPropagation();
SpringApplication.run(DemoStreamApplication.class, args);
}
@Bean
public Function<Flux<String>, Flux<String>> uppercase(ObservationRegistry registry) {
return flux -> flux.flatMap(item -> {
return Mono.just(item)
.map(value -> value.toUpperCase())
.doOnNext(v -> logger.info(v))
.tap(Micrometer.observation(registry));
});
}
}上面的示例模拟将 Observation 附加到单个消息处理（即命令式函数），因为在本例中，观察单元以 Mono.just（..） 开头，最后一个操作将 附加到订阅者。ObservationRegistry
如果订阅者已经附加了一个观察值，它将用于为 的上游链/段创建一个子观察值，但是正如我们已经说过的，默认情况下，框架不会将任何观察值附加到您返回的流链上。tap