如何在 Apache Camel 中解组后保留并访问原始输入消息

在 apache camel 中，`unmarshal` 操作会覆盖消息体（body），导致原始输入丢失；可通过 `setproperty()` 将原始消息暂存为 exchange 属性，在后续处理器中安全读取或恢复。

在基于 Camel 的集成路由中，常见场景是从 JMS 队列、Kafka 主题或 HTTP 端点接收 JSON 字符串，随后通过 unmarshal() 转换为 Java 对象（如使用 JacksonDataFormat 或 GsonDataFormat）。但需注意：Camel 的 unmarshal 是“就地替换”操作——它会用反序列化后的 Java 对象完全替代原始消息体（Body），原始 JSON 字符串一旦被覆盖便无法直接通过 exchange.getIn().getBody() 获取。

解决该问题的核心思路是：在 unmarshal 之前，主动将原始消息体捕获并持久化到 Exchange 的属性（

Property）中。Exchange 属性生命周期贯穿整个路由，且独立于消息体，是跨处理器共享上下文数据的推荐方式。

以下是一个典型、健壮的实现示例：

from("jms:queue:example")
    .routeId("receiveExampleMessage")
    // 确保原始输入为 String 类型（尤其当源头为字节数组时）
    .convertBodyTo(String.class)
    // 将当前 Body（即原始 JSON 字符串）存入名为 "originalBody" 的 Exchange 属性
    .setProperty("originalBody", simple("${body}"))
    // 执行反序列化：JSON → Java 对象（例如 ExampleDTO.class）
    .unmarshal(new JacksonDataFormat(ExampleDTO.class))
    // 此时 body() 已为 ExampleDTO 实例，但原始 JSON 仍可通过属性访问
    .log("Received DTO: ${body}, original JSON: ${exchangeProperty.originalBody}")
    .process(exchange -> {
        String originalJson = exchange.getProperty("originalBody", String.class);
        ExampleDTO dto = exchange.getMessage().getBody(ExampleDTO.class);
        // 可在此处进行审计、签名验证、双写日志等需原始输入的操作
        log.info("Audit: processed {} with original payload length {}", dto.getId(), originalJson.length());
    })
    // 如需恢复原始 JSON 作为新消息体（例如转发至另一系统）
    .setBody().exchangeProperty("originalBody");

⚠️ 注意事项：

• 务必在 unmarshal() 前调用 setProperty()，否则原始 Body 已被替换；
• 使用 convertBodyTo(String.class) 可规避因消息体为 byte[] 导致的类型不匹配问题；
• 属性名（如 "originalBody"）建议全局统一命名规范，避免拼写错误；
• 若需在多个分支或子路由中复用，可考虑封装为自定义 Processor 或 RouteBuilder 工具方法；
• 对于高吞吐场景，注意原始 JSON 字符串的内存占用，必要时可仅保存摘要（如 SHA-256）或关键字段。

综上，利用 Exchange 属性是 Camel 中解耦“处理逻辑”与“原始数据访问”的标准实践，既保持路由清晰性，又满足审计、重试、协议转换等企业级需求。