Spring Cloud Stream函数式模型：Message<String>与Message<byte[]>及Function性能对比

一、Message vs Message<byte[]> 性能对比 #

Message<byte[]>的性能明显更优，核心原因在于消息传输的底层本质是二进制数据：

• 使用Message<String>时，框架会自动完成String与byte[]之间的编码（如UTF-8）和解码操作，这两步会额外消耗CPU资源，同时生成临时对象增加GC压力。
• Message<byte[]>直接传递原始二进制数据，跳过了编码/解码的转换步骤，完全匹配底层传输的格式，消除了不必要的性能损耗。
• 如果你的业务逻辑不需要直接处理字符串（比如只是转发消息、存储原始数据），用byte[]能进一步避免字符串对象的创建与销毁，降低内存开销。

二、不同Function类型的性能对比 #

先纠正你提问中的重复笔误，默认对比的是Function<String, String>、Function<Message<String>, Message<String>>和Function<Message<byte[]>, Message<byte[]>>三者，性能排序从优到劣为：
Function<Message<byte[]>, Message<byte[]>> > Function<Message<String>, Message<String>> > Function<String, String>

具体分析：

• Function<Message<byte[]>, Message<byte[]>>：直接操作原始二进制消息，既不需要框架做payload的编码/解码转换，也不需要额外封装或解包Message对象，整个处理链路最短，性能损耗最小。
• Function<Message, Message>：相比byte[]版本，需要框架完成byte[]到String的解码，处理完成后再将String转回byte[]，增加了两次转换开销，但胜在能直接操作Message的头信息等属性，灵活性更高，性能比纯字符串的Function好。
• Function<String, String>：这是最上层的抽象，框架不仅要处理payload的编码/解码，还要自动完成Message对象的封装与解包，额外增加了对象创建、属性拷贝等开销，性能最差。

如果你的业务必须处理字符串，优先选择Function<Message<String>, Message<String>>而非Function<String, String>，能在灵活性和性能之间取得较好平衡。

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