此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.4！spring-doc.cn

用户定义的消息转换器

Spring Cloud Stream 公开了一种定义和注册其他 s 的机制。要使用它，请实施，将其配置为 . 然后，它被附加到现有的 s 堆栈中。MessageConverterorg.springframework.messaging.converter.MessageConverter@BeanMessageConverterspring-doc.cn

重要的是要了解 custom implementations 被添加到现有堆栈的头部。因此，自定义 implementations 优先于现有 implementations，这使您可以覆盖和添加现有 converters。MessageConverterMessageConverter

以下示例显示如何创建消息转换器 bean 以支持名为：application/barspring-doc.cn

@SpringBootApplication
public static class SinkApplication {

    ...

    @Bean
    public MessageConverter customMessageConverter() {
        return new MyCustomMessageConverter();
    }
}

public class MyCustomMessageConverter extends AbstractMessageConverter {

    public MyCustomMessageConverter() {
        super(new MimeType("application", "bar"));
    }

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

    @Override
    protected Object convertFromInternal(Message<?> message, Class<?> targetClass, Object conversionHint) {
        Object payload = message.getPayload();
        return (payload instanceof Bar ? payload : new Bar((byte[]) payload));
    }
}