Spring Cloud Stream与Micrometer：@Timed注解函数指标异常问题

核心原因 #

你把@Timed和@Transactional注解加在了创建Function Bean的方法上，而非实际处理消息的逻辑方法上。这个@Bean方法仅在应用启动时执行一次（用于生成Function实例），所以指标只会统计这一次调用；后续每次消息处理调用的是返回的lambda函数，该函数未被注解代理，自然不会更新指标。

修复方案 #

将业务逻辑提取到单独的方法中，把注解移到这个实际处理消息的方法上，再通过Bean返回的lambda调用该方法：

// 用@Component让Spring管理处理器类
@Component
class TestMessageHandler {
    // 注解移至此处，作用于每次消息处理
    @Transactional
    @Timed(value = "rrems_handle_test", percentiles = [0.5, 0.95, 0.99])
    fun processMessage(message: Message<String>): String {
        // 编写原业务逻辑
        return "处理结果"
    }
}

// 定义Function Bean，调用处理器的方法
@Bean
fun handleTest(handler: TestMessageHandler): Function<Message<String>, String> {
    return Function { handler.processMessage(it) }
}

方案有效性说明 #

• @Timed直接标注在每次消息处理都会触发的processMessage方法上，Micrometer会为每一次调用生成完整的指标数据（计数、耗时、分位数）。
• @Transactional同样作用于实际处理逻辑，确保每次消息处理都在事务上下文执行，而非仅在Bean初始化时生效。

补充说明 #

Spring Cloud Function的Bean定义逻辑中，返回的lambda/Function实例本身不会被Spring AOP代理，因此注解必须直接作用于被Spring管理的实例方法（比如@Component类中的方法），才能让切面逻辑（指标统计、事务控制）正常生效。

内容的提问来源于stack exchange，提问作者Sia