RabbitMQ（八）消息的序列化

目录

    • 一、为什么需要消息序列化？
    • 二、常用的消息序列化方式
      • 1）Java原生序列化（默认）
      • 2）JSON格式
      • 3）Protobuf 格式
      • 4）Avro 格式
      • 5）MessagePack 格式
    • 三、总结

在这里插入图片描述

RabbitMQ 是一个强大的消息中间件，广泛应用于 分布式系统 中。在使用 RabbitMQ 时，选择 合适的方式来序列化 消息可以提高：性能、可靠性、扩展性。

一、为什么需要消息序列化？

在使用 RabbitMQ 时，消息需要在生产者和消费者之间进行传递。由于网络通信只能传输二进制数据，因此需要对消息进行 序列化（将对象转换为二进制数据）和反序列化（将二进制数据转换回对象）。这样才能实现生产者与消费者之间的无缝通信。

消息序列化的目标是：将对象转换为字节流。以便于在网络上进行传输。在选择序列化方式时，我们 需要考虑以下因素：

  1. 性能： 序列化和反序列化的效率直接 影响消息传输的速度和延迟。
  2. 空间开销： 序列化后的字节流大小会 影响网络带宽的利用 和 存储空间的占用。
  3. 可读性： 序列化后的字节流是否 易于解析和理解，方便调试和维护。
  4. 兼容性： 序列化方式是否 支持不同的编程语言 和 版本之间的交互。

二、常用的消息序列化方式

RabbitMQ 本身不直接处理消息内容的序列化，它主要负责消息的路由、存储和传递。当发送或接收消息时，客户端库（如：Java 中的 RabbitTemplate 或 Spring AMQP 框架）会根据内部配置或默认设置来决定如何对消息体进行序列和反序列化。

1）Java原生序列化（默认）

  • Java 自带的 Serializable 接口和 ObjectOutputStream/ObjectInputStream 可以将对象转换为字节数组进行传输。在 Java Spring AMQP 中，默认的消息序列化方式就是 Java 原生序列化。

优点：

  • 简单易用： Java 内置支持，只需让需要序列化的类实现 Serializable 接口即可。

缺点：

  • 效率低： 生成的数据流可能比 JSON、Protocol Buffers 等二进制格式更大，导致存储和传输效率低。
  • 安全风险： 由于序列化机制中包含了类的信息，存在安全风险，如：恶意攻击者可以构造特殊序列化数据以执行任意代码（例如通过 readObject 方法的重写）。
  • 语言独立性差： Java 原生序列化只适用于 Java 环境，不便于与其他编程语言间的通信。

为了克服这些限制并提供更好的性能和互操作性，开发者通常会选择更现代和灵活的方式，如 JSON 或 Protobuf 等。

2）JSON格式

JSON（JavaScript Object Notation）：是一种轻量级的数据交换格式，易于阅读和编写。它以键值对的形式表示数据，并且在不同的编程语言中都有广泛的支持。

优点：

  • 易于使用和调试。
  • 兼容性好，支持不同编程语言和版本之间的交互。

缺点：

  • 性能较差，相比其他序列化方式，JSON 的序列化和反序列化速度较慢。
  • 字节流相对较大，占用网络带宽较多。

在 Spring AMQP 中，可以配置 MessageConverter 来替换默认的序列化器，例如使用 Jackson 库提供的 Jackson2JsonMessageConverter 将消息转换为 JSON 格式。

Spring Boot 可以通过以下方式更改默认的消息序列化策略：

spring:
    rabbitmq:
        message-converter: org.springframework.amqp.support.converter.Jackson2JsonMessageConverter

或者在 Java 配置类中定义：

@Bean
public MessageConverter jsonMessageConverter() {
    return new Jackson2JsonMessageConverter();
}

@Autowired
public void configureRabbitTemplate(RabbitTemplate rabbitTemplate) {
    rabbitTemplate.setMessageConverter(jsonMessageConverter());
}

这样，消息体就会被自动转换成 JSON 字符串发送到 RabbitMQ，并在接收端反序列化回对应的 Java 对象。

补充：

如果对象中使用了 LocalDateTime，在反序列化的时候会报错：InvalidDefinitionException: Cannot construct instance of java.time.LocalDateTime (no Creators, like default constructor, exist): cannot deserialize from Object value (no delegate- or property-based Creator)

在这里插入图片描述

解决方式：

  • 首先，需要引入 jackson-datatype 依赖，如果之前已经引入了 spring-boot-starter-web 依赖则不需要手动添加。

在这里插入图片描述

<!-- LocalDateTime反序列化 -->
<dependency>
    <groupId>com.fasterxml.jackson.datatype</groupId>
    <artifactId>jackson-datatype-jsr310</artifactId>
    <version>2.4.0</version>
</dependency>
  • 需要在 LocalDateTime 类型的字段上面添加 @JsonDeserialize 注解和 @JsonSerialize 注解来指定如何序列化和反序列化java.time.LocalDateTime类型的数据，如下所示：
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;

@JsonDeserialize(using = LocalDateTimeDeserializer.class)
@JsonSerialize(using = LocalDateTimeSerializer.class)
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime createTime;

补充： 上述代码中，@JsonFormat 注解是完善显示形式。

使用 @JsonFormat 注解前：

在这里插入图片描述

使用 @JsonFormat 注解后：

在这里插入图片描述

3）Protobuf 格式

Protobuf（Protocol Buffers）是 Google 开发的一种高效的数据序列化格式。它以 二进制格式 存储数据，可以通过定义消息结构和 IDL（Interface Description Language）文件来实现消息的序列化和反序列化。

优点：

  • 高性能，比 JSON 和 XML 等方式更快速和高效。
  • 字节流较小，占用网络带宽和存储空间较小。

缺点：

  • 由于二进制格式存储，不易读和调试。

4）Avro 格式

Avro 是一种基于 Schema 的数据序列化系统，由 Apache 开发。Avro 使用简单的动态 Schema 来定义消息格式，并支持多种编程语言。它具有高效的压缩和快速的序列化/反序列化性能。

优点：

  • 高性能，支持快速的序列化和反序列化。
  • 字节流小，占用网络带宽和存储空间较小。

缺点：

  • Schema 管理较为复杂，需要定义并维护 Schema。

5）MessagePack 格式

MessagePack 是一种快速、紧凑且可读写的二进制序列化格式。它以键值对的形式表示数据，并支持多种编程语言。MessagePack的主要目标是提供高性能的序列化和反序列化。

优点：

  • 高性能，比 JSON 和 XML 等方式更快速和高效。
  • 字节流较小，占用网络带宽和存储空间较小。

缺点：

  • 不易读和调试。

三、总结

RabbitMQ消息序列化 是构建 分布式系统 的关键环节之一。在选择序列化方式时，需要综合考虑性能、空间开销、可读性和兼容性等因素。根据具体需求 选择合适的序列化方式，并遵循最佳时间，可以提高系统的性能、可靠性和扩展性。通过测试、优化和监控，不断改进序列化方案，使其更好地 适应实际应用场景。

整理完毕，完结撒花~ 🌻





参考地址：

1.Spring boot使用Rabbitmq注解及消息序列化，https://blog.csdn.net/cristianoxm/article/details/114883340

2.RabbitMQ消息序列化的终极指南，https://baijiahao.baidu.com/s?id=1773630009654004953&wfr=spider&for=pc

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

网络层协议及IP编址

网络层协议及IP编址

0x00 前言 本节为网络层协议及IP编址内容 IP地址的范围&#xff1a;0.0.0.0-255.255.255.255 IP分为网络位以及主机位。子网划分就是向主机位借位。 网络层协议 IPICMP&#xff08;internet Control message protocol&#xff09;IPX IP协议的作用 为网络层的设备提供逻…
阅读更多...
程序语言相关知识——偏向Eigen矩阵

程序语言相关知识——偏向Eigen矩阵

1 查看 Eigen库表示的矩阵 方法 1.1 列矩阵x在监视中&#xff0c;这样查看&#xff0c;数值右侧的圈圈 可用于更新数值 随程序 1.2 比较全的方法&#xff1a;来自于知乎&#xff1a;https://zhuanlan.zhihu.com/p/625334009?utm_id0 1.3 eigen的用法&#xff1a;https://ww…
阅读更多...
linux高级管理——Squid代理

linux高级管理——Squid代理

一、squid服务基础&#xff1a; 1.1缓存代理的概述&#xff1a; 代理的工作机制 当客户机通过代理来请求Web页面时&#xff0e;指定的代理服务器会先检查自己的缓存&#xff0c;如果缓存中已经有客户机需要的页面&#xff0c;则直接将缓存中的页面内容反馈给客户机:如果缓存中…
阅读更多...
整合事务,名词,概念

整合事务,名词,概念

1、MySQL是单进程多线程&#xff08;而Oracle等是多进程&#xff09;&#xff0c;也就是说MySQL实例在系 统上表现就是一个服务进程&#xff0c;即进程&#xff0c;&#xff08;通过多种方法可以创建多实例&#xff0c;再安装一个端口号不同的mysql&#xff0c;或者通过workben…
阅读更多...
滞回比较器（施密特触发器）在软件中的应用-电池电压显示

滞回比较器（施密特触发器）在软件中的应用-电池电压显示

1、单限比较器和滞回比较器的区别 在单限比较器中&#xff0c;输入电压在阈值电压附近的任何微小变化&#xff0c;都会引起输出电压的跃变。不管这种微小变化是来源于输入电压还是来源于外部干扰。因此&#xff0c;虽然单限比较器很灵敏&#xff0c;但是抗干扰能力差。在单限比…
阅读更多...
学习Redis缓存

学习Redis缓存

学习Redis缓存 NoSQL和SQL的区别缓存缓存作用缓存成本添加Redis缓存 Redis特征Redis中数据结构Redis通用命令String类型Key的层级格式Hash类型Redis的Java客户端 NoSQL和SQL的区别 缓存 缓存就是数据交换的缓冲区&#xff0c;是存储数据的临时地方&#xff0c;一般读写性比较高…
阅读更多...
Sei新手完全指南科普，以及钱包介绍测评（bitget）

Sei新手完全指南科普，以及钱包介绍测评（bitget）

阅读更多...
10款有趣的前端源码分享（附效果图及在线演示）

10款有趣的前端源码分享（附效果图及在线演示）

分享10款非常有趣的前端特效源码 其中包含css动画特效、js原生特效、svg特效以及小游戏等 下面我会给出特效样式图或演示效果图 但你也可以点击在线预览查看源码的最终展示效果及下载源码资源 自毁按钮动画特效 自毁按钮动画特效 点击打开盒子可以点击自毁按钮 进而会出现自毁…
阅读更多...
使用Python+selenium3.0实现第一个自动化测试脚本

使用Python+selenium3.0实现第一个自动化测试脚本

这篇文章主要介绍了使用Pythonselenium实现第一个自动化测试脚本&#xff0c;文中通过示例代码介绍的非常详细&#xff0c;对大家的学习或者工作具有一定的参考学习价值&#xff0c;需要的朋友们下面随着小编来一起学习学习吧 最近在学web自动化&#xff0c;记录一下学习过程。…
阅读更多...
Linux驱动学习—中断

Linux驱动学习—中断

1、中断基础概念 1.1 什么是中断 CPU在正常运行期间&#xff0c;由外部或者内部引起的时间&#xff0c;让CPU停下当前正在运行的程序&#xff0c;转而去执行触发他的中断所对应的程序&#xff0c;这就是中断。 响应中断的过程&#xff1a; <1>中断请求 <2>中断…
阅读更多...
Spring Cloud之OpenFeign异常处理

Spring Cloud之OpenFeign异常处理

简易原理图 原理基于请求头传递错误消息&#xff0c;利用aop和全局异常拦截机制实现。 服务提供者 远程调用本地方法b&#xff0c;throw异常出来FeignExceptionAspect AOP拦截处理异常到请求头中&#xff0c;继续throwGlobalExceptionHandler处理&#xff0c;返回响应Respons…
阅读更多...
1868_C语言单向链表的实现

1868_C语言单向链表的实现

Grey 全部学习内容汇总&#xff1a; GitHub - GreyZhang/c_basic: little bits of c. 1868_C语言中简单的链表实现 简单整理一下链表的实现&#xff0c;这一次结合前面看到的一些代码简单修改做一个小结。 主题由来介绍 以前工作之中链表的使用其实不多&#xff0c;主要是…
阅读更多...
C++动态内存分配（动态内存分配函数）栈区

C++动态内存分配（动态内存分配函数）栈区

内存拷贝函数&#xff1a; void *memcpy(void *dest,const void *src,size_tn);#include<string.h>功能&#xff1a;从源src所指的内存地址的起始位置开始拷贝n个字节到目标dest内存地址的起始位置 分配内存使用new 例如&#xff1a;salarynew int[num]; 最后需要释放…
阅读更多...
三、Qt核心与Qt类库

三、Qt核心与Qt类库

一、Qt核心&#xff1a;元对象系统 1、Qt核心特点 Qt对标准C进行了扩展&#xff0c;引入了一些新的概念和功能元对象编译器&#xff08;MOC&#xff09;是一个预处理器&#xff0c;先将Qt的特性程序转为标准C程序&#xff0c;再由标准C编译器进行编译Qt为C语言增加的特性在Qt…
阅读更多...
Android学习（三）：在Android虚拟机中运行项目

Android学习（三）：在Android虚拟机中运行项目

Android学习&#xff08;三&#xff09;&#xff1a;在Android虚拟机中运行项目 一、前期准备 在系统环境变量中添加ANDROID_SDK_HOME&#xff0c;把值指定到一个其他目录。就可以把Android AVD(虚拟机)创建在指定目录下。修改环境变量后&#xff0c;如果Android Studio是在运…
阅读更多...
Java Swing手搓童年坦克大战游戏(I)

Java Swing手搓童年坦克大战游戏(I)

前言 业余偶尔对游戏有些兴趣&#xff0c;不过这样的时代&#xff0c;硬件软件飞速进步&#xff0c;2D游戏画面都无比精美&#xff0c;之前的8bit像素游戏时代早就过去了&#xff0c;不过那时候有许多让人印象深刻的游戏比如魂斗罗、超级玛丽、坦克大战(Battle City)等等。 学…
阅读更多...
1866_FreeRTOS的存储管理方案heap_4分析

1866_FreeRTOS的存储管理方案heap_4分析

Grey 全部学习内容汇总&#xff1a; GitHub - GreyZhang/g_FreeRTOS: learning notes about FreeRTOS. 1866_FreeRTOS的存储管理方案heap_4分析 对FreeRTOS的heap_4进行分析拆解&#xff0c;按照文学式编程的方式重新组织成个人笔记。 主题由来介绍 free以及malloc这样的存…
阅读更多...
辗转相除法求最大公约数

辗转相除法求最大公约数

介绍 辗转相除法&#xff08;又称欧几里德算法&#xff09;是一种求最大公约数的算法。它基于这样一个事实&#xff1a;两个数的最大公约数等于较大数和较小数余数的最大公约数。即两个数相除&#xff0c;再将除数和余数反复相除&#xff0c;当余数为0时&#xff0c;取当前除法…
阅读更多...
Python异常捕获和处理语句 try-except-else-finally

Python异常捕获和处理语句 try-except-else-finally

目录 try-except-else-finally语句 1. 基本用法 2. 多个异常处理 3. 处理所有其他异常 4. 多个except子句 5. 使用else子句 6. 使用finally子句 7. 使用as关键字 实例 例1 例2 例3 例4 例5 例6 例7 例8 结论 try-except-finally语句 在Python中&#xff0c;try-e…
阅读更多...
概率论与数理统计 知识点+课后习题

概率论与数理统计 知识点+课后习题

文章目录 &#x1f496; [学习资源整合](https://www.cnblogs.com/duisheng/p/17872980.html)&#x1f4da; 总复习&#x1f4d9; 选择题&#x1f4d9; 填空题&#x1f4d9; 大题1. 概率2. 概率3. 概率4. P5. 概率6. 概率密度函数 F ( X ) F(X) F(X)7. 分布列求方差 V ( X ) …
阅读更多...
最新文章

Copyright @ 2022~2023