RabbitMQ 发送消息 绕过系统配置的 消息转换器方法

1. 背景

我负责的系统需要与其他系统交互，需要我将消息发送到 MQ 上，其他系统监听消息。

遇到问题，两个系统的发送消息格式都是不一致的，所以这个地方是需要协商打通的。

目前这个系统经我查阅发现用的 fastjson 的 jsonb 序列化数据的（将 Java 对象转为 byte[]）。

jsonb具体怎么序列化，网上也没查到。又考虑到其他语言对接的话可能不支持该序列化方式，所以，还是将本次与其他系统交互用的 MQ 单独换成简单通用的 JSON 字符串。

2. 解决方法

所以问题来了，系统目前已经集成好了， 都是用的 JSONB，这也是统一的配置。如何实现就这个MQ单独发一个 JSON 字符串出去呢。

起初想的是再弄一套配置，也就是 rabbitmqTemplate，这套配置就不配 JSON?的消息转换器了。

不过说起来很简单，改造起来并不容易。所以还是回到问题原点思考，就是要解决最初的那一个原因，就是要单独这个消息不经过消息转换器。

所以，直接就是看发送消息的源码，convertAndSend 方法，这里具体是哪里使用到了配置的消息转换器，消息转换器何时何以参加？

这里的 object 是发送时传的消息体。

下方又有一个?convertMessageIfNecessary 转换消息。

也就是说，如果传的消息直接就是 Message 类型，那么就直接返回了。不再走下面的消息转换了。

所以代码便可以如此写

经过我的测试，发现消息确实发送的是 JOSN?字符串了。

3. 其他理解

所以消息转换器的意义此时也更加深刻，消息转换器就是序列化方式，描述 byte[] 和 Java 对象之间的转化方法。

为何要使用消息转换器呢

1. 可以自定义序列化协议，数据更安全，因为别人拿到消息也解析不出来了。

2. 可以自己选择一个序列化协议，站在?RabbitMQ 框架来说，它是可配置的，不是强绑死的，这样，如果以后有了新的协议，用户无需关注?RabbitMQ，只需要将它配进来即可。