文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

三分钟白话RocketMQ系列—— 如何发送消息

2024-11-30 10:35

关注

那接下来,我们白话一下,RocketMQ是如何发送消息的,揭秘消息生产全过程。

注意,如果白话中不小心提到相关代码配置与类名,请参考RocketMQ 4.9.4版本

关键字摘要

Q1: RocketMQ有哪些消息类型?

RocketMQ生产消息时,支持多种「消息类型」:

SendResult send(final Message msg);
SendResult send(final Message msg, final MessageQueueSelector selector, final Object arg);
SendResult send(final Message msg, final MessageQueue mq);

上面列举的三种send方法,都是以同步发送模式为例。定时/延迟消息从发送方式角度来说,不算一种独立的消息类型。

Q2:RocketMQ怎么知道一条消息要发送给谁?

一般我们要发送一条消息给RocketMQ,需要创建这样一个消息体。

Message msg = new Message( "TestTopic", "Hello World".getBytes() );

在这个消息体里面,我们只单纯指定了要发送的Topic名字,以及要发送的消息内容。

那么,RocketMQ-client怎么知道这条消息要发送到RocketMQ集群中的哪一个broker上呢?

这里需要了解下RocketMQ中Topic的「路由注册与发现机制」。

RocketMQ基本架构

Topic 路由注册与发现:

Topic路由信息

Topic的路由信息,包括了Topic的 队列queue和broker的映射关系 ,那么如何利用这个Topic的路由信息呢?

我们需要根据前面的不同「消息类型」进行分别讨论:

根据消息类型获取到目标队列queue后,就可以根据Topic路由信息发送消息到指定broker上了。

Q3:怎么发送一条消息?

从发送模式角度来说,RocketMQ有三种「消息发送模式」:

SendResult send(final Message msg);
void send(final Message msg, final SendCallback sendCallback);
void sendOneway(final Message msg);

上面列举的三种send方法,都是以「普通消息」为例。

「消息类型」 和 「消息发送模式」 是 N*M 的关系,所以聪明的你一定已经想到了,存在9种不同组合(不包括事物消息),RocketMQ也是在接口中定义了9种不同方法。

Q4: 发送后,怎么知道消息发成功了还是失败了?

前面介绍了三种「消息发送模式」,其中「单向发送」属于不可靠发送,我们无法知道是否发送成功。

而「同步发送」和「异步发送」都是可靠发送,我们能够获取发送状态,知道是否成功。

在「同步发送」中,我们可以根据SendResult中的sendStatus属性判断是否发送成功。

SendResult类属性

在「异步发送」中,我们可以自定义实现SendCallback的onSuccess()方法和onException()方法,来判断消息是否发送成功。

SendCallback接口定义

Q5: 消息发送失败了怎么办?

如果消息发送失败了,RocketMQ-client默认有重试机制,以确保消息的高可用性。

前面提到,生产者每30秒获取一次主题的路由信息,所以即使某个 Broker 宕机,消息发送者可能无法立即察觉到它的宕机状态。

但是,当消息发送者向某个 Broker 发送消息后,如果返回异常,生产者会在接下来的一段时间内(例如5分钟)避免再次选择该 Broker 上的队列来发送消息。这样做的目的是规避可能发生故障的 Broker。

当然了,用户也能根据返回的异常,自己定义业务重试、补偿机制。

需要注意的是,不同「消息类型」和「消息发送模式」的RocketMQ-client默认重试机制不同。

消息类型:

注意:有序消息异常时RocketMQ-client都是默认不重试

消息发送模式:

注意:单向发送模式异常时RocketMQ-client默认不重试

总结

来源:阿丸笔记内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯