顺序消息分析|学习笔记

简介: 快速学习顺序消息分析

开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段)顺序消息分析】学习笔记,与课程紧密联系,让用户快速学习知识

课程地址:https://developer.aliyun.com/learning/course/702/detail/12381


顺序消息分析


内容介绍

一、含义

二、Broker

三、发送者

四、消费者

五、总结

 

一、含义

顺序消息,是消费者消费消息的顺序要与生产者发送顺序是一致的,当前 MQ 是一

个消息队列,本身数据结构是先进先出。

 

二、Broker

消息发送方会依次进入对列,消息队列会保证先进先出。

将信息发送 Broker。Broker 内部有四个队列。

 

三、发送者

左边是消息的发送者,右边是消息的消费者发送的消息是与订单有关的消息。假设

与张三有创建、付款、推送、完成四个方面有关系,必须按着顺序发送。

Broker 中有多个队列是为了提高消息发送与消息消费的顺序。由于有多个队列,那么这几个消息会被放到多个队列,发送到 Broker 中,会采取轮循的方式,将消息一次放到多个队列中。

 

四、消费者

消费者采用多线程方式去同时消费多个消息。但是采用多线程方式去同时消费多个

消息很难保证发送的顺序,这时要保证消息顺序,会分成两个方面。

(1)全局消息顺序:当前发送给 Broker 所有队列的消息,要保证所有 Broker 中的所有队列的消息的消费,要遵循发送顺序.全局是没有必要的

(2)局部消息顺序:只保证张三消息发送的顺序就行,如果有李四的消息,只需保证每个人发送的顺序就可以了。保证局部消息顺序,其实可以把张三的消息放到一个队列里,李四放到队列里。对于一个单位的消费采用单线程,对于多个单位可

以采用多线程。

image.png


五、总结

对于消息顺序来说,只要保证 Broker 某一队列的顺序即可。局部消息的顺序一般来讲可以在发送消息时通过订单的业务标识,比如订单 id 去选择当前的某一队列,只要是这个订单后续消息,都给一个队列中去,就通过订单 id 去选择当前的队列。保证发送者和消费者的顺序。

相关文章
|
3天前
|
数据采集 人工智能 安全
|
13天前
|
云安全 监控 安全
|
4天前
|
自然语言处理 API
万相 Wan2.6 全新升级发布!人人都能当导演的时代来了
通义万相2.6全新升级,支持文生图、图生视频、文生视频,打造电影级创作体验。智能分镜、角色扮演、音画同步,让创意一键成片,大众也能轻松制作高质量短视频。
1084 152
|
18天前
|
机器学习/深度学习 人工智能 自然语言处理
Z-Image:冲击体验上限的下一代图像生成模型
通义实验室推出全新文生图模型Z-Image,以6B参数实现“快、稳、轻、准”突破。Turbo版本仅需8步亚秒级生成,支持16GB显存设备,中英双语理解与文字渲染尤为出色,真实感和美学表现媲美国际顶尖模型,被誉为“最值得关注的开源生图模型之一”。
1751 9
|
9天前
|
人工智能 自然语言处理 API
一句话生成拓扑图!AI+Draw.io 封神开源组合,工具让你的效率爆炸
一句话生成拓扑图!next-ai-draw-io 结合 AI 与 Draw.io,通过自然语言秒出架构图,支持私有部署、免费大模型接口,彻底解放生产力,绘图效率直接爆炸。
694 152
|
11天前
|
人工智能 安全 前端开发
AgentScope Java v1.0 发布,让 Java 开发者轻松构建企业级 Agentic 应用
AgentScope 重磅发布 Java 版本,拥抱企业开发主流技术栈。
660 14
|
6天前
|
SQL 自然语言处理 调度
Agent Skills 的一次工程实践
**本文采用 Agent Skills 实现整体智能体**,开发框架采用 AgentScope,模型使用 **qwen3-max**。Agent Skills 是 Anthropic 新推出的一种有别于mcp server的一种开发方式,用于为 AI **引入可共享的专业技能**。经验封装到**可发现、可复用的能力单元**中,每个技能以文件夹形式存在,包含特定任务的指导性说明(SKILL.md 文件)、脚本代码和资源等 。大模型可以根据需要动态加载这些技能,从而扩展自身的功能。目前不少国内外的一些框架也开始支持此种的开发方式,详细介绍如下。
437 5