初识消息队列

简介:

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



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

相关文章
|
Java Android开发 索引
Android 解析DEX文件
1. DEX文件简介 1). 基本格式 Android DEX文件格式--非虫大神杰作.png dex-file-general-structure.
1540 0
|
数据安全/隐私保护 安全 定位技术
什么是GSM?GSM是什么
本文讲的是什么是GSM?GSM是什么,GSM全名为:Global System for Mobile Communications,中文为全球移动通讯系统,俗称"全球通",是一种起源于欧洲的移动通信技术标准,是第二代移动通信技术,其开发目的是让全球各地可以共同使用一个移动电话网络标准,让用户使用一部手机就能行遍全球。
4826 0
|
8月前
|
人工智能 自然语言处理 搜索推荐
2025年企业如何选择合适的智能客服系统,适合中小企业的智能客服系统推荐
2025年,智能客服从“降本工具”升级为“增长引擎”。瓴羊Quick Service依托阿里云与大模型技术,具备高并发、全渠道、行业化适配等优势,助力企业实现服务智能化升级,是兼具性能与扩展性的优选方案。
|
10月前
|
机器学习/深度学习 人工智能 算法
大型语言模型为何产生幻觉
语言模型为何会产生幻觉?OpenAI 最新研究指出,幻觉源于模型在训练和评估中被鼓励猜测而非承认“不知道”。即使强大如 GPT-5,也无法完全避免幻觉。改进评估方式、奖励模型表达不确定性,是减少幻觉的关键。
657 10
|
11月前
|
SQL 缓存 前端开发
如何开发一套门店业绩上报管理系统?(附架构图+流程图+代码参考)
门店业绩上报管理系统通过统一数据口径,实现门店销售、客流、目标完成情况的自动化上报、审核与分析,提升数据准确性与管理效率。系统支持多维度分析、目标比对与预警,助力管理层快速决策,优化营销与补货策略。
|
存储 编解码 数据挖掘
阿里云通用算力型u1实例2核4G199元1年测评,适合搭建中小型网站
在当今数字化时代,网站已成为企业展示形象、推广产品、服务客户的重要窗口。对于中小型企业而言,搭建一个稳定、高效且成本可控的网站尤为重要。阿里云推出的通用算力型U1实例云服务器,以其高性价比成为了搭建中小型网站的首选,目前企业用户购买u1实例2核4G5M带宽80G ESSD Entry云盘只要199元一年,而且续费价格不变。本文将深入解析通用算力型U1实例的特点、适用场景,帮助用户更好地了解这款云服务器,以供参考。
|
人工智能 缓存 自然语言处理
阿里云 × 天润融通:基于智能体的企业营销与客户服务实践分享
本次分享由阿里云与天润融通联合呈现,主题为“基于智能体的企业营销与客户服务实践”。主讲人安静波(北京天润融通科技股份有限公司CTO)将介绍天润融通的智能体平台架构及其在企业营销和客服场景中的应用。内容涵盖天润融通的发展历程、基于阿里云的AICC架构、智能体平台的技术细节及优化实践,并通过客户案例展示如何通过智能体提升营销转化率和客户满意度。重点探讨了智能体在实时响应、打断处理等方面的优化措施,以及大模型的应用经验。
1357 0
|
机器学习/深度学习 人工智能 搜索推荐
智能CRM系统排名2024:AI技术如何提升客户管理
在数字化时代,人工智能(AI)技术正逐渐成为企业提升客户管理能力的关键因素。智能CRM系统通过集成AI技术,不仅能够自动化日常任务,还能提供深入的客户洞察,从而帮助企业实现更高效的销售和更个性化的客户服务。AI技术在CRM系统中的应用包括:24/7的自动化客户服务、客户行为分析、个性化推荐以及销售预测和管道管理。根据2024年市场表现和用户反馈,纷享销客、用友CRM、金蝶CRM、悟空CRM、普华基石CRM、珍客CRM、八百客CRM和销帮帮CRM等智能CRM系统表现出色。其中,纷享销客凭借先进的AI技术成为行业领导者。企业应积极探索AI与CRM的集成,实现客户管理的数字化转型。
|
网络协议 网络架构
《黑神话:悟空》的网络架构与多人游戏实现
【8月更文第26天】《黑神话:悟空》作为一款备受期待的动作冒险游戏,其网络架构对于支持多人在线游戏体验至关重要。本文将详细介绍游戏在网络架构方面的设计思路,以及如何实现稳定且高效的多人游戏体验。
743 0