如何在纯Java环境下将ObjectMapper注入RouteBuilder？

我来帮你分析下问题所在，以及对应的解决方案：

问题原因分析 #

1. 构造函数中查找为空：当你通过new RouteBuilder()初始化时，CamelContext还处于初始化阶段，注册表（Registry）里的json-jackson实例还没被加载或注册，这时候自然拿不到对象。
2. @BeanInject注入为空：在纯Java环境下，Camel不会自动处理@BeanInject注解——这个注解需要依赖注入容器（比如Spring/Guice）或者手动启用Camel的注解处理机制才能生效，默认情况下纯Java环境没有这个处理逻辑。

可行解决方案 #

方案1：利用Camel生命周期回调，在上下文启动后获取ObjectMapper #

Camel提供了生命周期钩子，你可以在CamelContext完全启动后再去注册表查找对象，这时候json-jackson已经被正确注册了：

public class MyCustomRoute extends RouteBuilder {
    private ObjectMapper objectMapper;

    @Override
    public void configure() throws Exception {
        // 先定义你的路由逻辑
        from("direct:input")
            .process(exchange -> {
                // 这里可以安全使用objectMapper
                String payload = objectMapper.writeValueAsString(exchange.getIn().getBody());
                exchange.getIn().setBody(payload);
            });

        // 添加生命周期回调，在上下文启动后初始化ObjectMapper
        getContext().addLifecycleStrategy(new LifecycleStrategyAdapter() {
            @Override
            public void onContextStarted(CamelContext context) {
                try {
                    objectMapper = context.getRegistry().lookupByNameAndType("json-jackson", ObjectMapper.class);
                } catch (Exception e) {
                    throw new RuntimeException("Failed to retrieve ObjectMapper from registry", e);
                }
            }
        });
    }
}

方案2：手动启用Camel的注解处理，让@BeanInject生效 #

如果你想保留@BeanInject的用法，需要手动添加Camel的AnnotationBeanPostProcessor来处理注解：

// 主程序入口
public class CamelMain {
    public static void main(String[] args) throws Exception {
        DefaultCamelContext camelContext = new DefaultCamelContext();

        // 创建并注册注解处理器，用于处理@BeanInject
        AnnotationBeanPostProcessor annotationProcessor = new AnnotationBeanPostProcessor();
        annotationProcessor.setCamelContext(camelContext);
        camelContext.getRegistry().bind("annotationProcessor", annotationProcessor);

        // 初始化RouteBuilder并让处理器处理注解
        MyCustomRoute routeBuilder = new MyCustomRoute();
        annotationProcessor.postProcessBeforeInitialization(routeBuilder, "myRoute");
        camelContext.addRoutes(routeBuilder);

        camelContext.start();
        // 保持程序运行
        Thread.currentThread().join();
    }
}

// 你的RouteBuilder类
public class MyCustomRoute extends RouteBuilder {
    @BeanInject("json-jackson")
    private ObjectMapper objectMapper;

    @Override
    public void configure() throws Exception {
        from("direct:input")
            .process(exchange -> {
                if (objectMapper != null) {
                    // 正常使用objectMapper处理数据
                }
            });
    }
}

方案3：提前注册ObjectMapper到Camel注册表 #

如果json-jackson是你自己维护的实例，可以在初始化CamelContext时就把它注册进去，这样RouteBuilder在configure方法里就能直接拿到：

public class CamelMain {
    public static void main(String[] args) throws Exception {
        DefaultCamelContext camelContext = new DefaultCamelContext();

        // 提前创建并注册ObjectMapper到注册表
        ObjectMapper customObjectMapper = new ObjectMapper();
        // 可以添加自定义配置，比如序列化规则
        customObjectMapper.configure(SerializationFeature.INDENT_OUTPUT, true);
        camelContext.getRegistry().bind("json-jackson", customObjectMapper);

        // 添加RouteBuilder
        camelContext.addRoutes(new MyCustomRoute());

        camelContext.start();
        Thread.currentThread().join();
    }
}

public class MyCustomRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        // 在configure方法里直接获取，此时注册表已经有这个实例了
        ObjectMapper objectMapper = getContext().getRegistry().lookupByNameAndType("json-jackson", ObjectMapper.class);

        from("direct:input")
            .process(exchange -> {
                // 使用objectMapper处理数据
            });
    }
}

额外说明 #

你之前在Processor里通过getContext().getRegistry().lookupByNameAndType能拿到对象，是因为此时CamelContext已经完全启动，注册表中的所有实例都已加载完成，这个时机是安全的。

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