用户定义的消息转换器

Spring Cloud Stream 公开了一种机制来定义和注册额外的MessageConverters. 要使用它，请实现org.springframework.messaging.converter.MessageConverter，将其配置为@Bean. 然后将其附加到MessageConverters.spring-doc.cadn.net.cn

重要的是要了解习惯MessageConverter实现被添加到现有堆栈的头部。因此，定制MessageConverter实现优先于现有实现，这使您可以覆盖和添加到现有转换器中。

以下示例显示如何创建消息转换器 Bean 以支持名为application/bar:spring-doc.cadn.net.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));
    }
}