RabbitMQ消费者消息异常Base64编码问题（SAP CPI+Groovy）

使用SAP CPI结合Groovy脚本向RabbitMQ 4.0版本队列发送消息时，消息在队列中显示为Base64编码格式；但SAP CPI中间件日志中消息为常规JSON格式，发送至在线Webhook时也能正常以JSON格式送达，采用的是AMQP 1.0协议。

相关Groovy代码：

import com.sap.gateway.ip.core.customdev.util.Message

Message processData(Message message) { 
def fixedBody = '{"pattern":"test.evt","data":{"ID":"663","ChaveSAP":"0001","Status":"S","MensagemSAP":"Cliente 0001 created with success."}}'

message.setBody(fixedBody)

message.setHeader("Content-Type", "text/plain")
message.setHeader("CamelHttpCharacterEncoding", "UTF-8")

return message
}

待发送JSON：

{"pattern":"test.evt","data":{"ID":"663","ChaveSAP":"0001","Status":"S","MensagemSAP":"Cliente 0001 created with success."}}

1. 修正Content-Type头部 #

当前代码中设置的Content-Type为text/plain，AMQP 1.0协议下，消息代理会将text/plain类型的消息视为二进制数据进行Base64编码。将其改为application/json，明确告知消息代理这是JSON文本：

import com.sap.gateway.ip.core.customdev.util.Message

Message processData(Message message) { 
def fixedBody = '{"pattern":"test.evt","data":{"ID":"663","ChaveSAP":"0001","Status":"S","MensagemSAP":"Cliente 0001 created with success."}}'

message.setBody(fixedBody)

// 修改Content-Type为application/json
message.setHeader("Content-Type", "application/json")
message.setHeader("CamelHttpCharacterEncoding", "UTF-8")

return message
}

2. 检查SAP CPI RabbitMQ适配器配置 #

• 打开CPI中RabbitMQ发送器的配置界面，确认是否启用了二进制模式（Binary Mode），若启用则关闭该选项，避免消息被强制转换为二进制后编码。
• 检查适配器的消息属性设置，确保content-type属性被正确传递为application/json，部分场景下需要在适配器中显式配置，而非仅通过Groovy脚本设置Header。

3. 确保消息体为字符串类型 #

Groovy脚本中直接使用字符串设置消息体即可，避免将消息体转换为字节数组（如调用getBytes()），否则会被视为二进制数据触发Base64编码。

4. 验证AMQP 1.0消息属性 #

通过RabbitMQ管理控制台查看消息的属性，确认content-type是否为application/json，若属性未正确设置，可在CPI适配器的“消息属性”中手动添加content-type键值对，值设为application/json。

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