Apache Camel新手技术咨询：POST请求JSON参数条件判断触发MethodNotFoundException报错

首先，咱们先搞清楚你遇到的错误根源：Camel默认没有把POST过来的JSON请求体自动解析成可以访问属性的对象。你发送的JSON被当成了普通的String存在Exchange的body里，当你用${body.myVar}这个表达式时，Camel会尝试调用String类的myVar()方法——这显然不存在，所以就抛出了MethodNotFoundException。

第一步：修复JSON解析问题 #

要解决这个问题，你需要告诉Camel：我接收的是JSON格式的请求，帮我把它解析成能直接访问属性的结构（比如Map或者自定义POJO）。

方案1：用Map解析JSON #

修改你的REST端点配置，加上consumes("application/json")和.type(Map.class)：

final Map<String, Object> parameters = new HashMap<>(); // 注意：这个全局Map有线程安全问题，后面会说怎么改
rest()
    .post("/my-endpoint")
    .consumes("application/json") // 声明接收JSON格式
    .type(Map.class) // 把请求体解析成Map<String, Object>
    .choice()
        .when().simple("${body.myVar} == true")
            .process(e -> parameters.put("key", "the value is true"))
        .otherwise()
            .process(e -> parameters.put("key", "the value is false"))
    .to("direct:another-processor");

方案2：用自定义POJO解析JSON #

如果你的请求结构固定，定义一个POJO会更清晰：

// 定义请求体对应的POJO
public class MyRequest {
    private Boolean myVar;
    
    // 必须要有getter方法，Camel会通过getter访问属性
    public Boolean getMyVar() {
        return myVar;
    }

    public void setMyVar(Boolean myVar) {
        this.myVar = myVar;
    }
}

然后修改REST端点的type为这个POJO：

rest()
    .post("/my-endpoint")
    .consumes("application/json")
    .type(MyRequest.class) // 解析成自定义POJO
    .choice()
        .when().simple("${body.myVar} == true")
            .process(e -> parameters.put("key", "the value is true"))
        .otherwise()
            .process(e -> parameters.put("key", "the value is false"))
    .to("direct:another-processor");

第二步：解决线程安全问题 #

你现在用的是全局的HashMap，这在多并发请求场景下会出大问题——多个请求会同时修改这个Map，导致数据混乱甚至错误。正确的做法是把参数存在当前请求的Exchange属性里，每个请求都有自己独立的属性空间。

优化后的代码示例（用Exchange属性存储）：

rest()
    .post("/my-endpoint")
    .consumes("application/json")
    .type(Map.class)
    .choice()
        // 可以加上null判断，更严谨：${body.myVar} != null && ${body.myVar} == true
        .when().simple("${body.myVar} == true")
            .setProperty("myKey", constant("the value is true")) // 存到Exchange属性
        .otherwise()
            .setProperty("myKey", constant("the value is false"))
    .to("direct:another-processor");

然后在another-processor里，你可以这样获取值：

// 在another-processor的逻辑中
String value = exchange.getProperty("myKey", String.class);

更简洁的实现方式 #

其实你可以不用自定义process，直接用Camel的内置表达式和处理器，代码会更简洁：

rest()
    .post("/my-endpoint")
    .consumes("application/json")
    .type(Map.class)
    // 用EL表达式直接设置属性，替代choice+process
    .setProperty("myKey", simple("${body.myVar} == true ? 'the value is true' : 'the value is false'"))
    .to("direct:another-processor");

额外注意事项 #

• 确保你的项目依赖里已经包含了Camel的JSON解析组件，比如camel-jackson（如果用Jackson的话），否则解析会失败。
• 如果myVar的取值是字符串类型的"true"/"false"，而不是布尔类型，你需要调整表达式为${body.myVar} == 'true'（注意单引号）。

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