微服务学习(5):消息转换器由JDK序列化——JSON序列化

embedded/2025/3/3 5:21:25/

在企业应用中,将消息转换器从JDK序列化改为JSON序列化提升了系统间通信的效率与安全性。JSON作为轻量级数据交换格式,增强了跨平台兼容性,简化了开发与维护。相比JDK序列化,JSON序列化减少了潜在的安全风险,提供了更紧凑的数据表示,有助于降低带宽占用和提高响应速度,从而优化了整体性能,特别适用于分布式系统的数据交换场景。

JDK序列化的缺点

代码呈现缺点

解决方案

结论


JDK序列化的缺点

性能问题:JDK序列化的过程相对比较慢,因为它涉及复杂的算法来处理对象图的序列化和反序列化。

安全性问题:JDK序列化没有内置的安全措施来防止反序列化过程中执行恶意代码。这意味着如果攻击者能够控制输入流,则可能通过精心构造的对象来执行任意代码,这被称为反序列化漏洞。

兼容性问题:随着类定义的变化,旧版本的对象可能无法被正确地反序列化,除非开发者明确地处理了这些变化。这是因为JDK序列化依赖于类的详细结构信息。

数据冗余:JDK序列化不仅保存对象的数据,还会保存很多关于类的元数据,导致生成的序列化内容通常比实际需要的大得多。

不可跨语言:JDK序列化是Java特有的,不能直接用于与其他编程语言编写的组件之间进行通信。

代码呈现缺点

我们在consumer服务中创建一个配置类,然后基于@Bean的方式创建一个队列。

java"> @Beanpublic Queue messageQueue(){return QueueBuilder.durable("message.queue").build();}

RabbitMQ控制台队列:(成功创建)

接下来就在publisher模块的SpringAmqpTest中新增发送消息的测试类,

发送一个复杂对象(这里使用Map对象):

java">    @Testpublic void testSendMap() {// 准备消息Map<String, Object> msg = new HashMap<>();msg.put("name", "张三");msg.put("age", 18);// 发送消息rabbitTemplate.convertAndSend("message.queue", msg);}
}

RabbitMQ控制台队列获取消息:

我们糟糕的发现消息格式似乎不尽人意,并且占据资源较多。

解决方案

我们使用JSON方式来做序列化和反序列化,代替默认的JDK的实现。

publisherconsumer两个服务中都引入依赖:

java"><dependency><groupId>com.fasterxml.jackson.dataformat</groupId><artifactId>jackson-dataformat-xml</artifactId><version>2.9.10</version>
</dependency>

配置消息转换器,在publisherconsumer两个服务的启动类中添加一个Bean即可:

java">    @Beanpublic MessageConverter messageConverter(){// 1.定义消息转换器Jackson2JsonMessageConverter jackson2JsonMessageConverter = new Jackson2JsonMessageConverter();// 2.配置自动创建消息id,用于识别不同消息,也可以在业务中基于ID判断是否是重复消息jackson2JsonMessageConverter.setCreateMessageIds(true);return jackson2JsonMessageConverter;}

RabbitMQ控制台队列获取消息:

我们可以在consumer服务中定义一个新的消费者,publisher是用Map发送,那么消费者也一定要用Map接收,格式如下:

java">  @RabbitListener(queues = "message.queue")public void listenSimpleQueueMessage(Map<String, Object> msg) {System.out.println("消费者接收到object.queue消息:【" + msg + "】");}

idea控制台接收消息:

结论

将消息转换器从JDK序列化改为JSON序列化显著提升了系统的互操作性和安全性。JSON作为一种轻量级的数据交换格式,不仅易于人类阅读和编写,也便于不同编程语言之间的数据交换,这使得你的应用能够更轻松地与使用其他技术栈的服务进行通信。同时,此举有效避免了JDK序列化中存在的反序列化漏洞风险,增强了系统的安全性。

此外,这一改动还改善了系统性能和可维护性。相较于JDK序列化,JSON序列化通常提供更快的处理速度和更小的数据体积,特别是在网络传输方面表现更为突出。而且,由于JSON格式清晰、工具支持广泛,简化了开发过程中的调试和日志记录工作,有助于减少维护成本并加快问题解决速度。这是一个符合现代软件开发最佳实践的积极改进。


http://www.ppmy.cn/embedded/169530.html

相关文章

【JS】ES模块与CommonJS的区别

ES 模块与 CommonJS 的对比 特性CommonJSES 模块导入方式const module require(‘module’)import module from ‘module’;导出方式module.exports value;export default value;加载方式同步加载异步加载作用域每个模块都有自己的作用域使用 import 和 export 共享作用域适…

通过Nginx负载均衡+Keepalived实现业务高可用

通过Nginx负载均衡和Keepalived可以实现业务的高可用&#xff0c;以下是详细的实现步骤&#xff1a; 环境准备 假设我们有3台服务器&#xff0c;IP地址分别为&#xff1a; 服务器1&#xff08;Nginx Keepalived 主节点&#xff09;&#xff1a;192.168.1.100服务器2&#x…

Imagination通过最新的D系列GPU IP将效率提升至新高度

Imagination DXTP GPU IP在加速移动设备和其他电力受限设备上的 图形和计算工作负载时&#xff0c;能够延长电池续航时间。 近日&#xff0c;Imagination Technologies&#xff08;“Imagination”&#xff09;宣布推出其最新的GPU IP——Imagination DXTP&#xff0c;该产品…

鸿蒙中连接手机可能遇到的问题

连接权限问题&#xff1a;手机开启了严格的权限管理机制&#xff0c;若未授予鸿蒙设备连接所需的权限&#xff0c;如蓝牙连接时未开启蓝牙权限&#xff0c;或者 USB 连接时未允许设备进行调试、文件传输等操作&#xff0c;就会导致连接失败。例如&#xff0c;当使用鸿蒙平板通过…

LangChain解锁LLM大语言模型的结构化输出能力:调用 with_structured_output() 方法

什么是LLM的结构化输出能力&#xff1f; 在一些工业级LLM应用或比较复杂的LLM应用编排环节&#xff0c;我们需要用LLM的输出作为下一环节的输入&#xff0c;而这个过程往往对LLM输出的格式有一定要求&#xff0c;比如JSON、XML、YAML、CSV、Markdown 表格和HTML 等比较常见的格…

JavaScript知识点4

1.解释一下这段JavaScript代码 var fruits ["Apple", "Orange", "Apple", "Mango"]; var a fruits.indexOf("Apple",-1); console.log("index"a); 输出的a值为-1&#xff0c;indexOf的第二个参数是-1&#xf…

Git与GitHub:它们是什么,有什么区别与联系?

1.Git是什么&#xff1f; Git 是一个开源的、分布式版本控制系统&#xff08;Version Control System, VCS&#xff09;&#xff0c;由 Linus Torvalds 于 2005 年开发&#xff0c;最初用于管理 Linux 内核的开发。它的核心功能是跟踪文件的变更历史&#xff0c;帮助开发者高效…

「Selenium+Python自动化从0到1①|2025最新环境搭建+浏览器驱动避坑指南(附验证代码)」

Selenium Python 自动化 1 - 环境搭建 一、Selenium 简介 Selenium 是一个广泛使用的自动化测试工具&#xff0c;主要用于 Web 应用程序的自动化测试。它支持多种编程语言&#xff08;如 Java、Python、C#、Ruby、JavaScript 等&#xff09;&#xff0c;并允许用户控制浏览器…