初识消息队列

简介:

wKiom1gvHqeSrGAEAAGgZ8qZQ04755.png

wKioL1gvHqiBGlgOAAK5paYkncU276.png

wKiom1gvHqnixTUAAAFvDp5SxlI466.png

一对一

wKiom1gvHqvDhMA6AASCvZtE4Hg409.png

点对点模型特性:消息只有在处理成功后才会删除,失败时不会删除,这样下次取时,队列中还会有

wKioL1gvHqzjASRYAAJ0mXH27zA140.png


wKiom1gvHq_g7sn5AAWuA9dGR6M629.png

发布-订阅模型特性(3、可以理解为过期时间)

wKioL1gvHrCRqE88AAHW_FQpO28620.png

发布订阅模型(3非持久订阅:保持长链接-——持久订阅:消费者产生的消息,会把消息存在消息中间件中,当消费者宕机后,消息中间件会不停的向消费者发送信息,直到成功接收)

wKiom1gvHrHBXDpFAALoxNhZ4xs053.png

交易系统,对实时性较高,所以用推的方式。

wKioL1gvHrLTr2pFAAKyNAsFLmM628.png

延迟消息发送和暂存(通过tcp-copy方式复制一份消息队列,复制出的消息队列先不释放,暂存队列中,可以很好的模拟用户并发,再一次性释放出来)pull较好

wKiom1gvHrPxTlkgAAJlG31G7h4911.png

11、消息广播(例:消费者购物,商品价格为100,突然有一天,变为105,但消费者看到的依然是100,这时便会出现数据不一致,可以用消息中间件来解决,给消费者(cache)缓存数据同步更新来解决【但还有一种情况,消息中间件给cache同步时,同步较慢(正好赶上数据同步),一刷100,再一刷105的情况,但最终是105,可以用租约的方式去解决。给每个数据加一个时间戳,数据在某一时间会过期,当然必须保证服务器时间是同步的】对实时性要求较高,所以用推较好pull

wKioL1gvHrSDRO19AAHD0YcOPfQ104.png

wKioL1gvHrWA6W9YAAOX2jxpxR4856.png

消息中间件分类(发布订阅用的push较多一些,(立马同步到消费者(实时性比较高)pull 更多适用于点对点模型)

wKiom1gvHrbweY_TAAFBgZGn3ec765.png

14、数据复制立案----对时间的限制对比是用pull还是用push

wKiom1gvHrfyvEBzAAIh5FjaUEs229.png

metaq(根据磁盘顺序来写,典型pull模型)

wKioL1gvHrjQgx9bAAFfBoUiEws275.png

wKiom1gvHrqDnCmmAATsJK8WTf8821.png

wKioL1gvHrui8WuoAAE4dVxjPLg129.png

1、topic:可看作队列的名字

2、offset:偏移,主要对消费者使用,给消费者使用,消费者存在的偏移,就是在消息中间件中的一个起始位置。

3、broker:存储消息的一个点

4、依次定位,减少磁盘寻道时间。

wKiom1gvHr3zOxVRAAN5m_ucNeA646.png

wKioL1gvHr6yEyKGAAJV5IqSdk0296.png

wKioL1gvHsDxiCdmAAPUQ861948864.png

wKiom1gvHsCjCe-NAAFitPchWjo590.png

wKioL1gvHsGTP1LAAAGPKwhq6kM435.png

wKiom1gvHsLiSOnvAAD7s-ZcOto529.png

本文转自silence博客51CTO博客,原文链接http://blog.51cto.com/silencezone/1874475如需转载请自行联系原作者


a120518129

相关文章
|
10月前
|
人工智能 程序员 API
GPT-5.2来了,老金详细给你说说它为什么是王
OpenAI悄然上线GPT-5.2,因谷歌Gemini 3发布引发“红色警报”。新模型提升显著:幻觉减少38%,上下文达40万token,支持长文档精准处理;ARC-AGI-2与GDPval评测显示其真实推理与工作能力大幅增强,尤其适合金融、法律等专业场景。推出Instant、Thinking、Pro三版本,满足不同需求。虽无惊艳发布,但聚焦打工人实际应用,标志着AI向通用生产力工具迈进。
987 11
|
10月前
|
存储 弹性计算 安全
阿里云“99套餐”活动解析:套餐相关规则及云产品及组合配置与价格参考
阿里云“99套餐”是阿里云为了助力个人和中小企业无忧上云而推出的套餐组合活动,目前活动截止日期已延长到2027年3月31日。“99套餐”为在选购云服务器的同时还需要选购AI建站、SSL证书、安全防护包、RDS数据库等云产品的用户提供了额外的组合购买套餐,包括建站礼包、加36元防护主机安全、加99元解锁弹性数据库、加99元享高效存储保障等套餐,帮助用户一键选购。本文为大家介绍活动的相关规则及组合套餐配置与价格,以供参考。
1379 2
|
10月前
|
人工智能 算法 搜索推荐
Geo优化“两大核心+四轮驱动”的深度解读与实践要点
本文将深度解读“两大核心+四轮驱动”Geo优化方式的优化要点,旨在为内容创作者和企业营销人员提供一套专业、可信、有深度的实践指南。
533 6
|
9月前
|
存储 编解码 Cloud Native
全链路解析:基于云原生架构的 Bilibili 视频下载引擎实现
本文深入解析基于云原生架构的B站视频下载引擎,涵盖DASH协议分析、音视频分片下载、FFmpeg无损合成及阿里云Serverless部署。结合异步任务编排、OSS存储与反爬策略,实现高效、合规的全链路流媒体解析,适用于离线学习与弱网播放场景。(238字)
1014 1
|
机器学习/深度学习 弹性计算 人工智能
在阿里云ECS上一键部署DeepSeek-R1
Open WebUI 和 Ollama 的联合,通过集成 DeepSeek-R1 的强大功能,赋予每一位用户使用尖端 AI 技术的能力,使得复杂的 AI 技术不再是遥不可及的梦想。无论是研究人员、开发者,还是企业用户,您都能从这一创新中获得新的灵感和增长点。本文介绍通过计算巢一键部署和使用DeepSeek-R1。
在阿里云ECS上一键部署DeepSeek-R1
|
传感器 人工智能 机器人
|
SQL 存储 算法
PostgreSQL 执行计划,成本公式解说,代价因子校准,自动跟踪SQL执行计划(二)|学习笔记
快速学习PostgreSQL 执行计划,成本公式解说,代价因子校准,自动跟踪SQL执行计划(二)
PostgreSQL 执行计划,成本公式解说,代价因子校准,自动跟踪SQL执行计划(二)|学习笔记
Altium Designer中编译原理图之后出现 off grid at..... 的解决方法
Altium Designer中编译原理图之后出现 off grid at..... 的解决方法
1745 0
|
机器学习/深度学习 人工智能 算法
传统笔触与算法洪流:AI时代的艺术创作挑战
本文探讨了传统艺术与AI技术在创作中的共生关系及其对艺术生产力的赋能。研究表明,混合工作流能显著提升效率,而传统媒介带来的“意外美学”与AI生成的跨时空意象拼接相辅相成。AI通过快速生成视觉原型、优化色彩方案和提供即用元素,极大加速创作过程。同时,人机协同可实现风格融合、逆向思维训练及动态知识网络构建,但创作者需建立风格防火墙、验证机制和价值评估体系以守住创作主权。未来艺术教育将涵盖多层能力培养,具备跨维能力的艺术家市场竞争力将大幅提升。最终,真正成功的创作者是能够融合传统与科技、让艺术回归情感表达本质的“双脑创作者”。
811 0
|
存储 缓存 自然语言处理
智能客服进阶:基于DeepSeek与PHP的多轮对话与上下文管理
本文基于前文构建的DeepSeek和PHP智能客服系统,深入探讨了多轮对话与上下文管理的实现。通过维护会话状态(如使用PHP的`$_SESSION`),系统能记住对话历史,提供连贯的回答。具体案例展示了如何处理书籍推荐及后续查询,如“这本书的作者是谁”。此外,还介绍了优化方向,包括实体识别、对话策略调整和持久化存储,以提升智能客服的复杂需求处理能力。