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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/316970.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

vivo 数据库备份恢复系统演化

作者:vivo 互联网数据库团队 - Han Chaobing 介绍 vivo 数据库备份恢复功能的演化,以及对备份文件的功能扩展。 一、概述 vivo互联网领域拥有的数据库组件分别为 MySQL、MongoDB、TiDB 等,其中MySQL集群占比绝大部分, MongoDB …

一、医学影像云平台(AI赋能基层的最佳实践)

医学影像云平台,是一个目前影像业务中,各省市级领导比较重视的业务板块。因为,影像平台不但可以直接给原来没有PACS系统的1,2级医院提供PACS服务,还可以提供院间之间的业务,例如发送远程诊断,远程会诊业务&…

【华为机试】2023年真题B卷(python)-快速人名查找

一、题目 题目描述: 给一个字符串,表示用’, \’分开的人名。然后给定一个字符串,进行快速人名查找,符合要求的输出。 快速人名查找要求︰人名的每个单词的连续前几位能组成给定字符串,一定要用到每个单词。 二、输入输…

STM32MP157/linux驱动学习记录

1. uboot烧录 2.linux安装nfs服务 sudo apt-get install nfs-kernel-server rpcbind安装nfs服务 在用户根目录下创建一个名为“linux”的文件夹,以后所有的东西都放到这个“linux”文件夹里面,在“linux”文件夹里面新建一个名为“nfs”的文件夹&#…

企业使用人工智能情况调查

企业使用人工智能情况调查 人工智能在商业中的应用并不是什么新鲜事。多年来,公司一直在使用人工智能技术来削减成本并提高效率。 但最近生成式人工智能市场的激增帮助人工智能成为主流商业技术。具体来说,ChatGPT 和 Midjourney 等大型语言模型 (LLM)…

2020年认证杯SPSSPRO杯数学建模C题(第一阶段)抗击疫情,我们能做什么全过程文档及程序

2020年认证杯SPSSPRO杯数学建模 C题 抗击疫情,我们能做什么 原题再现: 2020 年 3 月 12 日,世界卫生组织(WHO)宣布,席卷全球的冠状病毒引发的病毒性肺炎(COVID-19)是一种大流行病。…

团结引擎正式发布,已开放下载

2024年1月1日,Unity 正式发布了针对中国开发者的引擎--团结引擎创世版,现在已经可以开放下载,想体验的小伙伴们可以到官网下载了。 团结引擎是专为中国开发者定制的实时3D引擎,目前是基于Unity 2022LTS版本开发的。团结引擎内置了…

一篇关于大模型在信息抽取(实体识别、关系抽取、事件抽取)的研究进展综述

信息提取(IE)旨在从普通自然语言文本中提取结构化知识(如实体、关系和事件)。最近,生成式大型语言模型(LLMs)展现了在文本理解和生成方面的卓越能力,使得它们能够广泛应用于各种领域…

【竞技宝】LOL:S14新赛季改动 将trueskill2隐藏分算法

北京时间2024年1月3日,随着英雄联盟德玛西亚杯的进行,英雄联盟赛事已经进入新赛季的征途。每个赛季的春季赛之前,都会进行一次大的版本更新。据爆料,今年的S14版本大更新中,除了游戏内的英雄、道具、地图的更新之外,排位的隐藏分算法也将进行重大改变。 昨日,英雄联盟设计总监…

【Java进阶篇】字符串常量、字符串常量池详解

字符串常量、字符串常量池详解 ✔️字符串常量池是如何实现的?✔️字符串常量从哪来的? ✔️字符串常量是什么时候进入到字符串常量池的? ✔️字符串常量池是如何实现的? 字符串常量池 (String Constant Pool) 是Java中一块特殊的内存区域,用于存储字符串常量。…

KBDSL1.DLL文件丢失,软件或游戏无法启动,快速修复方法

在Windows操作系统中,KBDSL1.DLL是一个动态链接库文件,由Microsoft Corporation提供。通常包含多个函数和程序,可以被多个应用程序共享,以执行一些特定的任务或功能。 如果KBDSL1.DLL文件丢失或损坏,可能会在启动计算机…

代码随想录算法训练DAY18|二叉树5

算法训练DAY18|二叉树5 513.找树左下角的值 力扣题目链接 给定一个二叉树,在树的最后一行找到最左边的值。 示例 1: 示例 2: 思路 本题要找出树的最后一行的最左边的值。此时大家应该想起用层序遍历是非常简单的了,反而用递归的话会比较难一点。 我…