Spring Cloud Function自定义消息转换器：convertToInternal未触发问题

你的自定义消息转换器逻辑本身没问题，但convertToInternal未触发的核心原因是Spring Cloud Function在输出转换时未获取到匹配的目标Content-Type，导致跳过了自定义转换器，直接调用toString()处理Bundle对象。

一、确保自定义转换器正确注册 #

首先要确认MyCustomMessageConverter已被Spring容器加载并加入消息转换器列表，可通过配置类显式注册：

@Configuration
public class MessageConverterConfig {

    @Bean
    public MyCustomMessageConverter myCustomMessageConverter() {
        return new MyCustomMessageConverter();
    }

    // 将自定义转换器添加到Spring的消息转换器链中
    @Bean
    public WebMvcConfigurer webMvcConfigurer() {
        return new WebMvcConfigurer() {
            @Override
            public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
                converters.add(0, myCustomMessageConverter()); // 优先使用自定义转换器
            }
        };
    }
}

二、触发convertToInternal的关键：指定输出Content-Type #

Spring Cloud Function的convertOutputIfNecessary方法需要明确的目标Content-Type才能匹配对应的转换器，可通过以下3种方式设置：

1. 在函数中返回带消息头的Message对象

直接在你的Function返回值中携带Content-Type头，强制触发转换器：

@Bean
public Function<String, Message<Bundle>> processFhirBundle() {
    return input -> {
        // 业务逻辑处理，得到Bundle对象
        Bundle bundle = ...;

        // 设置Content-Type为自定义转换器支持的类型
        MessageHeaders headers = new MessageHeaders(
                Collections.singletonMap(MessageHeaders.CONTENT_TYPE, "application/json+fhir")
        );
        return MessageBuilder.createMessage(bundle, headers);
    };
}

2. 通过配置设置全局默认输出Content-Type

在application.properties或application.yml中添加配置，为所有函数设置默认输出类型：

# application.properties
spring.cloud.function.default-output-content-type=application/json+fhir

3. HTTP触发时通过请求头指定

如果是通过HTTP调用函数，在请求中添加Accept: application/json+fhir头，Spring Cloud Function会自动将该值作为目标Content-Type传入convertOutputIfNecessary。

三、优化转换器代码 #

FhirContext是重量级对象，建议单例复用，不要每次转换都创建新实例：

public class MyCustomMessageConverter extends AbstractHttpMessageConverter<Bundle> {

    private final FhirContext fhirContext;

    public MyCustomMessageConverter() {
        super(new MimeType("application", "json+fhir"), new MimeType("application", "json"));
        this.fhirContext = FhirContext.forR4(); // 初始化一次即可
    }

    @Override
    protected boolean supports(Class<?> clazz) {
        return Bundle.class.equals(clazz);
    }

    @Override
    protected Object convertFromInternal(Message<?> message, Class<?> targetClass, Object conversionHint) {
        String payload = (String) message.getPayload();
        return fhirContext.newJsonParser().parseResource(Bundle.class, payload);
    }

    @Override
    protected Object convertToInternal(Bundle payload, MessageHeaders headers, Object conversionHint) {
        return fhirContext.newJsonParser().encodeResourceToString(payload);
    }
}

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