Spring Integration中请求Header读取位置及IntegrationFlow内参数传递与请求体构造问题问询

方案一：在Controller层读取Header并传递到IntegrationFlow #

这种方案逻辑清晰，适合需要在Controller层先做Header校验或预处理的场景，具体实现步骤如下：

1. 修改ServiceGateway接口，添加参数接收Header信息，Spring Integration会自动将这些参数封装为消息头传入指定通道：

@MessagingGateway
public interface ServiceGateway {
    @Gateway(requestChannel = "integration.info.gateway.channel")
    String info(@Header("X-Custom-Header") String customHeader, 
                @Header("X-User-Id") String userId);
    // 根据实际业务需求添加更多Header参数即可
}

2. 更新ServiceController，从外部请求中提取Header，调用Gateway时传入：

@RestController
@RequestMapping("/api/v1/integration")
public class ServiceController {
    @Autowired
    private ServiceGateway gateway;

    @GetMapping(value = "info")
    public String info(@RequestHeader("X-Custom-Header") String customHeader,
                       @RequestHeader("X-User-Id") String userId) {
        return gateway.info(customHeader, userId);
    }
}

3. 在IntegrationFlow中使用Header构造请求体：
   通过transform步骤转换消息 payload，从消息头中提取数据构造目标接口需要的JSON请求体，再发送到指定URL：

@Bean
public IntegrationFlow info() throws URISyntaxException {
    String uri = "http://localhost:8081/hellos/simpler";
    ObjectMapper objectMapper = new ObjectMapper(); // 用Jackson工具类构造JSON更可靠
    
    return IntegrationFlows.from("integration.info.gateway.channel")
            .transform((Message<?> message) -> {
                MessageHeaders headers = message.getHeaders();
                // 从消息头中获取之前传递的Header值
                String customHeader = headers.get("X-Custom-Header", String.class);
                String userId = headers.get("X-User-Id", String.class);
                
                // 构造请求体Map，再转为JSON字符串
                Map<String, String> requestBodyMap = new HashMap<>();
                requestBodyMap.put("customHeader", customHeader);
                requestBodyMap.put("userId", userId);
                return objectMapper.writeValueAsString(requestBodyMap);
            })
            .handle(Http.outboundGateway(uri)
                    .httpMethod(HttpMethod.POST)
                    .expectedResponseType(String.class)
                    // 如果需要把原Header传递给目标接口，可添加Header映射
                    .headerMapper(mapper -> {
                        mapper.setOutboundHeaderNames("X-Custom-Header", "X-User-Id");
                        return mapper;
                    }))
            .get();
}

方案二：直接在IntegrationFlow中读取原始请求Header #

你之前遇到的报错，是因为第一个handle方法没有返回可传递的消息，导致单向通道中断。修正后可以直接从消息头中获取原始请求的Header信息，步骤如下：

1. 保持Controller和Gateway不变：
   不需要手动传递Header，Spring会自动将请求Header封装到IntegrationFlow的消息头中（注意：Spring MVC会将Header名称转为小写）：

// ServiceController.java 保持原代码不变
@RestController
@RequestMapping("/api/v1/integration")
public class ServiceController {
    @Autowired
    private ServiceGateway gateway;

    @GetMapping(value = "info")
    public String info() {
        return gateway.info();
    }
}

// ServiceGateway.java 保持原代码不变
@MessagingGateway
public interface ServiceGateway {
    @Gateway(requestChannel = "integration.info.gateway.channel")
    String info();
}

2. 修正IntegrationFlow代码：
   使用transform处理消息转换（比handle更适合payload转换场景），确保返回有效的消息内容，避免通道中断：

@Bean
public IntegrationFlow info() throws URISyntaxException {
    String uri = "http://localhost:8081/hellos/simpler";
    ObjectMapper objectMapper = new ObjectMapper();
    
    return IntegrationFlows.from("integration.info.gateway.channel")
            .transform((Message<?> message) -> {
                MessageHeaders headers = message.getHeaders();
                // Spring MVC会把请求Header转为小写，所以用小写名称获取
                String customHeader = headers.get("x-custom-header", String.class);
                String userId = headers.get("x-user-id", String.class);
                
                // 构造JSON请求体
                Map<String, String> requestBodyMap = new HashMap<>();
                requestBodyMap.put("customHeader", customHeader);
                requestBodyMap.put("userId", userId);
                return objectMapper.writeValueAsString(requestBodyMap);
            })
            .handle(Http.outboundGateway(uri)
                    .httpMethod(HttpMethod.POST)
                    .expectedResponseType(String.class))
            .get();
}

关键注意事项 #

• Header名称大小写：Spring MVC会自动将请求Header的名称转为小写，所以在IntegrationFlow中获取时要使用小写名称，或者在Controller层手动指定原始名称传递。
• 消息传递连续性：IntegrationFlow的每个处理步骤（transform/handle）必须返回有效的消息或payload，否则会导致通道中断（这是你之前报错的核心原因），transform更适合做payload转换，handle多用于终端操作（如调用外部服务）。
• JSON构造规范：建议使用Jackson的ObjectMapper构造JSON请求体，避免手动拼接字符串引发格式错误。

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