Apache Camel API触发自定义异常时返回空响应与无效状态码问题

出现空响应体、响应状态码无效的核心原因有3个：

1. 响应内容和响应头设置位置错误：handled(true)标记异常已处理后，Camel的HTTP组件默认从当前生效的响应消息（Camel 3+版本为exchange.getMessage()获取的消息对象，Camel 2.x为OUT消息对象）读取返回内容，之前所有内容都设置在IN消息上，HTTP端点无法读取到自定义的状态码和响应体。
2. 异常处理路由缺少终止逻辑：direct同步调用走完marshal逻辑后，没有终止路由，可能继续执行原业务路由的剩余逻辑，覆盖掉设置的异常响应内容。
3. 隐藏风险点：代码中JacksonDataFormat初始化直接使用jacksonConfig对象，如果没有提前注入该配置，会抛出空指针，导致异常处理流程本身失败，直接返回空响应。

1. 修改通用异常处理器的消息设置逻辑 #

替换原有IN消息设置的写法，统一用exchange.getMessage()设置响应头和响应体，兼容Camel 3+版本的响应读取规则，同时确保自定义异常的code字段为合法HTTP状态码（取值范围100~599，比如400、500这类标准值，否则HTTP组件会自动替换为无效状态值）：

@Component
public class CommonExceptionProcessor implements Processor {
    
    @Override
    public void process(Exchange exchange) throws Exception {
        CustomException ex = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, CustomException.class);
        Error e = new Error();
        e.setMessage(ex.getMessage());
        e.setStatus("FAILED");
        // 设置自定义响应状态码
        exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, ex.getCode());
        // 设置响应体
        exchange.getMessage().setBody(e, Error.class);
    }
}

2. 补全异常处理路由逻辑 #

注入缺失的Jackson配置，添加JSON响应头标记，最后增加路由终止逻辑，避免响应被后续流程覆盖：

@Component
public class CustomExceptionHandler extends RouteBuilder {
    
    @Autowired
    private CommonExceptionProcessor commonExceptionProcessor;
    // 注入缺失的Jackson配置，避免空指针
    @Autowired
    private JacksonConfig jacksonConfig;

    @Override
    public void configure() throws Exception {
        JacksonDataFormat jackErrorResponse = new JacksonDataFormat(jacksonConfig.jsonObjectMapper(), Error.class);

        from("direct:customErrorHandler")
                .routeId("customErrorHandler-Route")
                .log(LoggingLevel.DEBUG, this.getClass().getName(), "Handling Error")
                .process(commonExceptionProcessor)
                .marshal(jackErrorResponse)
                // 标记响应内容类型为JSON，避免客户端解析失败
                .setHeader(Exchange.CONTENT_TYPE, constant("application/json"))
                // 终止路由，防止后续逻辑覆盖响应
                .stop();
           }
}

3. （可选优化）简化异常配置 #

如果不需要复用异常处理逻辑，可以直接把处理逻辑写在onException块中，减少跨direct调用的链路问题：

// 提前在RouteBuilder中初始化好JacksonDataFormat
onException(CustomException.class)
                .handled(true)
                .log(LoggingLevel.DEBUG, this.getClass().getName(), "Handling Custom Error")
                .process(commonExceptionProcessor)
                .marshal(jackErrorResponse)
                .setHeader(Exchange.CONTENT_TYPE, constant("application/json"))
                .stop();

修改完成后触发自定义异常，接口会返回符合要求的响应：

• 响应状态码为你在CustomException中定义的合法HTTP状态值
• 响应体结构为：

{
    "message":"customException occured",
    "status":"FAILED"
}

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