🎯 Spring Integration 消息元注解教程

用注解简化企业集成，告别 XML 配置的繁琐时代

---

📌 核心概念速览

消息元注解 (Messaging Meta-Annotations) = 自定义注解 + 预置消息注解。
✅ 优势：

• 通过注解继承减少重复配置
• 隔离框架依赖到自定义注解中
• 支持 @Bean 方法直接声明消息端点

---

🔍 第一章：元注解基础与应用

1.1 元注解层级配置

通过继承关系实现注解属性覆盖：

@Target(AnnotationTarget.FUNCTION, AnnotationTarget.ANNOTATION_CLASS)
@Retention(AnnotationRetention.RUNTIME)
@ServiceActivator(inputChannel = "annInput", outputChannel = "annOutput")
annotation class MyServiceActivator(
    val adviceChain: Array<String> = ["annAdvice"]
)


@Target(AnnotationTarget.FUNCTION, AnnotationTarget.ANNOTATION_CLASS)
@Retention(AnnotationRetention.RUNTIME)
@MyServiceActivator
annotation class MyServiceActivator1(
    val inputChannel: String,
    val outputChannel: String
)

// 使用自定义注解
@MyServiceActivator1(inputChannel = "input", outputChannel = "output")
fun service(payload: Any): Any {
    return payload.toString().uppercase()
}

TIP

注解继承链生效顺序：
@MyServiceActivator1 → @MyServiceActivator → @ServiceActivator

---

⚙️ 第二章：@Bean 方法的高级注解

2.1 声明消息端点组件

直接在 @Configuration 类中创建消息处理链：

@Configuration
@EnableIntegration
class MyFlowConfig {


    @Bean
    @InboundChannelAdapter(
        value = "inputChannel",
        poller = [Poller(fixedDelay = "1000")]
    )
    fun consoleSource(): MessageSource<String> {
        return CharacterStreamReadingMessageSource.stdin()
    }


    @Bean
    @Transformer(inputChannel = "inputChannel", outputChannel = "httpChannel")
    fun toMapTransformer(): ObjectToMapTransformer {
        return ObjectToMapTransformer()
    }


    @Bean
    @ServiceActivator(inputChannel = "httpChannel")
    fun httpHandler(): HttpRequestExecutingMessageHandler {
        return HttpRequestExecutingMessageHandler("https://foo/service").apply {
            expectedResponseType = String::class.java
            outputChannelName = "outputChannel"
        }
    }
}

2.2 Supplier 接口支持 (Spring 5.0+)

使用函数式接口简化消息生成：

@Bean
@InboundChannelAdapter(
    value = "inputChannel",
    poller = [Poller(fixedDelay = "1000")]
)
fun pojoSupplier(): Supplier<String> = { "foo" }

@Bean
@InboundChannelAdapter(
    value = "inputChannel",
    poller = [Poller(fixedDelay = "1000")]
)
fun messageSupplier(): Supplier<Message<String>> = {
    GenericMessage("foo")
}

WARNING

关键限制：

• outputChannel/requiresReply 等属性需在 MessageHandler 实例上设置
• inputChannel 必须引用已声明的通道 Bean

---

🌉 第三章：使用注解创建桥接

3.1 通道桥接配置

通过 @BridgeFrom/@BridgeTo 连接通道：

@Bean
fun bridgeFromInput(): PollableChannel = QueueChannel()

@Bean
@BridgeFrom(  // 从Pollable到Direct
    value = "bridgeFromInput",
    poller = [Poller(fixedDelay = "1000")]
)
fun bridgeFromOutput(): MessageChannel = DirectChannel()

@Bean
fun bridgeToOutput(): QueueChannel = QueueChannel()

@Bean
@BridgeTo("bridgeToOutput")  // 从Direct到Queue
fun bridgeToInput(): MessageChannel = DirectChannel()

NOTE

桥接本质：自动创建 BridgeHandler 连接两个通道，处理消息转发逻辑。

---

🛡️ 第四章：最佳实践与陷阱规避

4.1 端点 Bean 命名规则

框架自动生成名称的三种模式：

组件类型	命名模式	示例
MessageHandler/@Bean	原始Bean名称	httpHandler
端点抽象实现	[@Bean名称].[注解短名]	consoleSource.inboundChannelAdapter
代理组件	[@Bean名称].[注解短名].handler	serviceBean.serviceActivator.handler

4.2 条件化端点配置

结合 @Profile 实现环境隔离：

@Bean
@ServiceActivator(inputChannel = "skippedChannel")
@Profile("production")
fun productionHandler(): MessageHandler {
    return MessageHandler { msg ->
        println("PROD: ${msg.payload}")
    }
}

4.3 常见错误解决方案

问题1：通道未声明异常

No qualifying bean of type 'MessageChannel' named 'undefinedChannel'

✅ 解决：

1. 在配置类中声明通道：

@Bean
fun inputChannel() = DirectChannel()

2. 或开启自动声明：

spring.integration.channels.auto-create=true

问题2：注解属性不生效

'outputChannel' property ignored on @ServiceActivator

✅ 解决：
对于返回 MessageHandler 的 @Bean 方法：

@ServiceActivator(inputChannel = "channel")
fun handler(): MessageHandler {
    return HttpRequestExecutingMessageHandler(...).apply {
        outputChannel = ...  在此设置而非注解
    }
}

---

💎 总结：元注解核心价值

⚡️ 现代集成开发黄金法则：
1. 自定义注解封装通用配置 → 2. @Bean方法声明组件 → 3. 函数式接口简化实现