Spring环境下使用Bean集成时如何指定Apache Camel数据格式？

这个问题我之前也碰到过，Camel默认不会自动把POJO序列化成JSON格式，得咱们手动配置转换器或者在端点里指定序列化规则。给你两种方案，全局生效和单个端点生效，按需选择就行：

1. 先确保依赖到位 #

首先得把Jackson的Camel组件加上，适配你用的Camel 2.21.1版本：
如果是Maven项目，在pom.xml中添加依赖：

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-jackson2</artifactId>
    <version>2.21.1</version>
</dependency>

如果是Gradle项目：

compile 'org.apache.camel:camel-jackson2:2.21.1'

2. 全局配置（所有端点自动序列化POJO为JSON） #

如果想让所有Camel端点都自动处理POJO到JSON的转换，可以通过以下方式配置：

方式一：Spring/Spring Boot配置类 #

创建一个配置类，注册JacksonDataFormat为Bean，同时可以自定义序列化规则：

import org.apache.camel.component.jackson.JacksonDataFormat;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class CamelJsonConfig {

    @Bean
    public JacksonDataFormat jacksonDataFormat() {
        JacksonDataFormat jsonFormat = new JacksonDataFormat();
        // 可自定义Jackson参数，比如是否格式化输出、忽略空字段等
        jsonFormat.setPrettyPrint(true);
        jsonFormat.setContentType("application/json");
        return jsonFormat;
    }
}

如果是Spring Boot，还可以直接在application.properties里配置全局内容类型：

camel.dataformat.json.content-type=application/json

方式二：Camel RouteBuilder全局配置 #

如果是纯Camel路由场景，在RouteBuilder中设置全局数据格式：

@Override
public void configure() throws Exception {
    JacksonDataFormat jsonFormat = new JacksonDataFormat();
    jsonFormat.setContentType("application/json");
    // 将该格式设为全局默认JSON转换器
    getContext().setDataFormat("json", jsonFormat);
}

3. 单个端点配置（仅当前RabbitMQ端点生效） #

如果不想全局修改，只针对这个RabbitMQ端点配置序列化，可以直接在@EndpointInject的URI里添加marshal=json参数：

@RestController
public class Partners {

    @EndpointInject(uri = "rabbitmq:core/partners/create?marshal=json")
    private ProducerTemplate partnersCreate;

    @RequestMapping("/partners/create")
    public Partner create(Partner partner) {
        return partnersCreate.requestBody(partner, Partner.class);
    }
}

也可以在发送消息时手动指定序列化逻辑：

@RequestMapping("/partners/create")
public Partner create(Partner partner) {
    // 手动marshal为JSON后发送
    return partnersCreate.sendBody("rabbitmq:core/partners/create", 
        getContext().createProducerTemplate().marshal().json().body(partner), 
        Partner.class);
}

报错原因说明 #

你碰到的NoTypeConversionAvailableException，本质是Camel找不到把Partner对象转成RabbitMQ所需byte[]的转换器。添加JSON序列化配置后，Camel会先用Jackson把POJO转成JSON字符串，再自动转成byte[]，就能解决这个问题了。

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