初识消息队列

简介:

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

相关文章
|
8天前
|
消息中间件 存储
消息队列LiteQueue
消息队列LiteQueue
|
5月前
|
消息中间件 存储 数据可视化
消息队列使用的四种场景介绍(一)
消息队列使用的四种场景介绍
|
9月前
|
消息中间件 分布式计算 Hadoop
在实际应用中使用消息队列
在实际应用中使用消息队列
81 2
|
11月前
|
消息中间件 前端开发 大数据
|
消息中间件 数据库
|
消息中间件 SQL 关系型数据库
消息队列
消息队列
195 0
|
消息中间件 存储 缓存
常用消息队列对比
常用消息队列对比
|
消息中间件 存储 中间件
消息队列(四)
消息队列(四)
174 0
消息队列(四)
|
消息中间件 网络协议
消息队列(二)
消息队列(二)
121 0
消息队列(二)
|
消息中间件 存储 缓存
消息队列(三)
消息队列(三)
100 0
消息队列(三)