如何在Spring Integration配置中引入自定义处理步骤？

Great question! Let's walk through exactly how to wire up your SomeDocumentProcessingStep into your existing Spring Integration configuration, especially since you already have a <int:chain> setup.

Step 1: Register Your Custom Class as a Spring Bean #

First, Spring needs to manage your SomeDocumentProcessingStep instance. You have two straightforward options here:

Option A: XML Bean Definition #

If you’re using XML-based configuration, add this bean definition to your Spring context:

<bean id="documentProcessingStep" class="com.your.package.SomeDocumentProcessingStep" />

(Replace com.your.package with the actual package where your class resides.)

Option B: Annotation-Based Registration #

Alternatively, add the @Component annotation directly to your class, and ensure your Spring context is scanning the package containing it:

import org.springframework.stereotype.Component;
import org.springframework.messaging.Message;

@Component
public class SomeDocumentProcessingStep {
    public Message<MyDocument> process(Message<MyDocument> myMessage) {
        // Your processing logic (e.g., adding headers) here
        return resultingMessage;
    }
}

Step 2: Insert the Step into Your Existing Chain #

Since you already have a <int:chain> configured, you just need to add a <service-activator> element to the chain to invoke your custom processing method. Here’s how your updated chain might look:

<int:chain input-channel="someInput" output-channel="someOutput">
    <!-- Keep your existing chain elements here (e.g., filters, transformers) -->
    
    <!-- Add your custom processing step -->
    <int:service-activator ref="documentProcessingStep" method="process" />
    
    <!-- Add any subsequent chain elements here -->
</int:chain>

Key Notes: #

• The ref attribute points to the ID of your registered bean (from Step 1).
• The method attribute specifies which method to call (process in your case). Spring Integration will automatically pass the incoming Message<MyDocument> to this method and route the returned message to the next element in the chain.
• If you ever want to simplify your method to work directly with the payload instead of the full Message, you can adjust your method signature to:

  public MyDocument process(MyDocument payload) {
      // Process the payload directly
      return modifiedPayload;
  }
  

  Spring Integration will handle extracting the payload from the message and wrapping the result back into a new message automatically.

Bonus: Java Configuration Alternative #

If you prefer Java-based Spring Integration configuration over XML, here’s how you’d wire this up:

@Configuration
@EnableIntegration
public class IntegrationFlowConfig {

    @Bean
    public SomeDocumentProcessingStep documentProcessingStep() {
        return new SomeDocumentProcessingStep();
    }

    @Bean
    public IntegrationFlow documentProcessingChain() {
        return IntegrationFlows.from("someInput")
                // Existing flow elements go here
                .handle(documentProcessingStep(), "process")
                // Subsequent flow elements go here
                .channel("someOutput")
                .get();
    }
}

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