RabbitMQ入门指南(六):消息转换器及其案例

简介: RabbitMQ是一个高效、可靠的开源消息队列系统,广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了RabbitMQ默认转换器、JSON转换器及其案例等内容。

一、消息转换器

消息转换器是一个用于将消息转换为特定格式或类型的组件。在分布式系统中,消息转换器通常用于在不同的系统或服务之间进行数据传输和交互。

在Spring框架中,当消息发送者将消息发送到RabbitMQ时,如果消息体被封装为一个Object,在数据传输过程中,这个Object会被序列化为字节流,然后发送给RabbitMQ。同样,当消息接收者从RabbitMQ接收消息时,字节流会被反序列化为Java对象。

然而,默认情况下,Spring使用的是Java的序列化方式(JDK序列化)来进行这种转换。JDK序列化虽然简单易用,但也存在一些问题:

  • 数据体积过大:JDK序列化生成的数据体积相对较大,这可能会影响传输效率和存储效率。
  • 有安全漏洞:JDK序列化可能存在一些安全漏洞,例如,攻击者可能通过序列化恶意对象来执行任意代码。
  • 可读性差:JDK序列化生成的字节流难以阅读和理解,这给调试和审计带来了困难。

为了解决这些问题,可以使用其他的序列化方式,例如JSON序列化等。

二、RabbitMQ默认转换器案例(省略交换机)

在consumer服务中声明队列:

@Bean
    public Queue objectQueue() {
        return new Queue("object.queue");
    }

image.gif

在publisher服务中编写测试类,实现消息发送

@Test
    void testSendObject() {
        Map<String, Object> msg = new HashMap<>(2);
        msg.put("username", "user");
        msg.put("password", 123456);
        rabbitTemplate.convertAndSend("object.queue", msg);
    }

image.gif

运行后在RabbitMQ管理控制台查看消息


三、JSON转换器案例(省略交换机)

1.配置JSON转换器

在publisher和consumer两个服务(父工程)中引入Jackson依赖

<dependency>
            <groupId>com.fasterxml.jackson.dataformat</groupId>
            <artifactId>jackson-dataformat-xml</artifactId>
        </dependency>

image.gif

配置消息转换器(在publisher和consumer两个服务的启动类中添加一个Bean):

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

image.gif

2.运行结果

重启项目,运行测试类,并在RabbitMQ管理控制台查看消息:


在consumer服务中新建一个类实现消息接收

@RabbitListener(queues = "object.queue")
    public void listenObject(Map<String, Object> msg) throws InterruptedException {
        System.out.println("object.queue:" + msg);
    }

image.gif

重启项目查看结果



总结

RabbitMQ是一个开源的消息队列软件,旨在提供可靠的消息传递和消息队列功能。本文主要介绍了RabbitMQ默认转换器、JSON转换器及其案例等内容,希望对大家有所帮助。

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
10天前
|
消息中间件 数据可视化 Go
Rabbitmq 搭建使用案例 [附源码]
Rabbitmq 搭建使用案例 [附源码]
25 0
|
14小时前
|
消息中间件 存储 Kafka
01.RabbitMQ入门
01.RabbitMQ入门
|
14天前
|
消息中间件 存储 前端开发
RabbitMQ在Java中的完美实现:从入门到精通
本文由木头左介绍如何在Java项目中使用RabbitMQ。RabbitMQ是开源的AMQP实现,支持多种客户端,适合分布式系统中的消息传递。首先需安装Erlang和RabbitMQ,接着在Java项目中添加RabbitMQ客户端库依赖。通过创建连接工厂和连接,建立与RabbitMQ的通信,并展示了创建连接和通道的代码示例。
|
1月前
|
消息中间件 Docker 微服务
RabbitMQ入门指南(十一):延迟消息-延迟消息插件
RabbitMQ是一个高效、可靠的开源消息队列系统,广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了DelayExchange插件、延迟消息插件实现延迟消息等内容。
232 0
|
1月前
|
消息中间件 微服务
RabbitMQ入门指南(十):延迟消息-死信交换机
RabbitMQ是一个高效、可靠的开源消息队列系统,广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了死信交换机、死信交换机实现延迟消息等内容。
82 0
|
1月前
|
消息中间件 供应链 Java
RabbitMQ入门指南(九):消费者可靠性
RabbitMQ是一个高效、可靠的开源消息队列系统,广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了消费者确认机制、失败重试机制、失败处理策略、业务幂等性等内容。
73 0
RabbitMQ入门指南(九):消费者可靠性
|
1月前
|
消息中间件 Java 微服务
RabbitMQ入门指南(七):生产者可靠性
RabbitMQ是一个高效、可靠的开源消息队列系统,广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了消息丢失的可能性、生产者可靠性中的生产者重试机制和生产者确认机制等内容。
58 0
RabbitMQ入门指南(七):生产者可靠性
|
1月前
|
消息中间件 存储 Java
RabbitMQ入门指南(八):MQ可靠性
RabbitMQ是一个高效、可靠的开源消息队列系统,广泛用于软件开发、数据传输、微服务等领域。本文主要介绍了MQ数据持久化、LazyQueue模式、管理控制台配置Lazy模式、代码配置Lazy模式、更新已有队列为lazy模式等内容。
119 0
|
8天前
|
消息中间件 Java 双11
RocketMQ:揭秘电商巨头背后的消息队列秘密
**RocketMQ概览:**高性能分布式消息队列,适用于有序消息、事务处理、流计算、消息推送、日志处理及Binlog分发。在双11等高流量场景下证明了其性能、稳定性和低延迟。Java开发,利于扩展,性能超RabbitMQ,支持死信队列,但可能有集成兼容性问题。适合Java开发者,为电商等场景优化,每秒处理大量消息。
28 3
RocketMQ:揭秘电商巨头背后的消息队列秘密
|
14天前
|
消息中间件 监控 应用服务中间件
消息队列 MQ操作报错合集之重启Broker后,积压数出现为负数是什么导致的
在使用消息队列MQ时,可能会遇到各种报错情况。以下是一些常见的错误场景、可能的原因以及解决建议的汇总:1.连接错误、2.消息发送失败、3.消息消费报错、4.消息重试与死信处理、5.资源与权限问题、6.配置错误、7.系统资源限制、8.版本兼容性问题。
消息队列 MQ操作报错合集之重启Broker后,积压数出现为负数是什么导致的

热门文章

最新文章