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,只需要将它配进来即可。