Spring Integration：HTTP入站网关检测空响应体并返回204状态码

现有Spring Integration HTTP入站网关配置如下：

@Bean
public IntegrationFlow httpInbound() {
  return IntegrationFlows
      .from(Http.inboundGateway("/").requestMapping(m -> m.methods(HttpMethod.POST)))
      .channel(SOME_CHANNEL_NAME).get();
}

对应的响应处理服务：

@ServiceActivator(inputChannel = SOME_CHANNEL_NAME)
public String receive() {
  // 处理逻辑
  return string;
}

当前问题：即使返回空字符串""，网关仍返回200状态码，需求是返回空字符串时返回204，非空时返回200。已实现的方式是返回GenericMessage并手动设置状态头，以下是更简洁优雅的替代方案：

方案1：使用@Header注解动态设置响应头 #

无需返回GenericMessage，直接在业务方法中通过输出参数结合@Header注解设置状态码，业务方法只需专注返回业务数据：

@ServiceActivator(inputChannel = SOME_CHANNEL_NAME)
public String receive(@Header(HttpHeaders.STATUS_CODE) HttpStatus statusCode) {
  String processedString = "处理后的字符串"; // 替换为实际处理逻辑
  statusCode = "".equals(processedString) ? HttpStatus.NO_CONTENT : HttpStatus.OK;
  return processedString;
}

方案2：使用HeaderEnricher在集成流中处理 #

将状态码设置逻辑从业务方法剥离，放到集成流中通过HeaderEnricher动态处理，实现关注点分离：

@Bean
public IntegrationFlow httpInbound() {
  return IntegrationFlows
      .from(Http.inboundGateway("/").requestMapping(m -> m.methods(HttpMethod.POST)))
      .channel(SOME_CHANNEL_NAME)
      .enrichHeaders(h -> h.headerFunction(HttpHeaders.STATUS_CODE, 
          message -> "".equals(message.getPayload()) ? HttpStatus.NO_CONTENT : HttpStatus.OK))
      .get();
}

对应的业务方法保持原样，仅返回处理后的字符串：

@ServiceActivator(inputChannel = SOME_CHANNEL_NAME)
public String receive() {
  // 处理逻辑
  return string;
}

方案3：自定义ResponseStatusCallback配置到入站网关 #

通过实现ResponseStatusCallback接口封装状态判断逻辑，配置到HTTP入站网关中实现全局统一处理：

public class EmptyPayloadStatusCallback implements ResponseStatusCallback {
  @Override
  public HttpStatus resolveResponseStatus(Message<?> requestMessage, Message<?> responseMessage, Exception ex) {
    if (responseMessage != null && "".equals(responseMessage.getPayload())) {
      return HttpStatus.NO_CONTENT;
    }
    return HttpStatus.OK;
  }
}

配置到入站网关：

@Bean
public IntegrationFlow httpInbound() {
  return IntegrationFlows
      .from(Http.inboundGateway("/")
          .requestMapping(m -> m.methods(HttpMethod.POST))
          .responseStatusCallback(new EmptyPayloadStatusCallback()))
      .channel(SOME_CHANNEL_NAME)
      .get();
}

业务方法无需任何修改，状态判断逻辑独立封装，便于复用和维护。

方案对比 #

• 方案1适合状态码逻辑与业务逻辑紧密关联的场景；
• 方案2适合希望业务方法纯处理业务数据、HTTP相关逻辑由集成流统一管控的场景；
• 方案3适合需要全局统一处理响应状态、或多个网关复用同一判断逻辑的场景。

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