初识消息队列

<a href="http://s2.51cto.com/wyfs02/M01/8A/6D/wKiom1gvHqeSrGAEAAGgZ8qZQ04755.png" target="_blank"></a>

<a href="http://s4.51cto.com/wyfs02/M01/8A/69/wKioL1gvHqiBGlgOAAK5paYkncU276.png" target="_blank"></a>

<a href="http://s5.51cto.com/wyfs02/M02/8A/6D/wKiom1gvHqnixTUAAAFvDp5SxlI466.png" target="_blank"></a>

一对一

<a href="http://s4.51cto.com/wyfs02/M00/8A/6D/wKiom1gvHqvDhMA6AASCvZtE4Hg409.png" target="_blank"></a>

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

<a href="http://s5.51cto.com/wyfs02/M02/8A/69/wKioL1gvHqzjASRYAAJ0mXH27zA140.png" target="_blank"></a>

<a href="http://s2.51cto.com/wyfs02/M00/8A/6D/wKiom1gvHq_g7sn5AAWuA9dGR6M629.png" target="_blank"></a>

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

<a href="http://s2.51cto.com/wyfs02/M00/8A/69/wKioL1gvHrCRqE88AAHW_FQpO28620.png" target="_blank"></a>

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

<a href="http://s2.51cto.com/wyfs02/M01/8A/6D/wKiom1gvHrHBXDpFAALoxNhZ4xs053.png" target="_blank"></a>

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

<a href="http://s4.51cto.com/wyfs02/M00/8A/69/wKioL1gvHrLTr2pFAAKyNAsFLmM628.png" target="_blank"></a>

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

<a href="http://s4.51cto.com/wyfs02/M01/8A/6D/wKiom1gvHrPxTlkgAAJlG31G7h4911.png" target="_blank"></a>

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

<a href="http://s4.51cto.com/wyfs02/M01/8A/69/wKioL1gvHrSDRO19AAHD0YcOPfQ104.png" target="_blank"></a>

<a href="http://s4.51cto.com/wyfs02/M01/8A/69/wKioL1gvHrWA6W9YAAOX2jxpxR4856.png" target="_blank"></a>

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

<a href="http://s4.51cto.com/wyfs02/M02/8A/6D/wKiom1gvHrbweY_TAAFBgZGn3ec765.png" target="_blank"></a>

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

<a href="http://s1.51cto.com/wyfs02/M02/8A/6D/wKiom1gvHrfyvEBzAAIh5FjaUEs229.png" target="_blank"></a>

metaq（根据磁盘顺序来写，典型pull模型）

<a href="http://s1.51cto.com/wyfs02/M02/8A/6A/wKioL1gvHrjQgx9bAAFfBoUiEws275.png" target="_blank"></a>

<a href="http://s2.51cto.com/wyfs02/M00/8A/6D/wKiom1gvHrqDnCmmAATsJK8WTf8821.png" target="_blank"></a>

<a href="http://s4.51cto.com/wyfs02/M02/8A/6A/wKioL1gvHrui8WuoAAE4dVxjPLg129.png" target="_blank"></a>

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

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

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

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

<a href="http://s1.51cto.com/wyfs02/M00/8A/6D/wKiom1gvHr3zOxVRAAN5m_ucNeA646.png" target="_blank"></a>

<a href="http://s1.51cto.com/wyfs02/M00/8A/6A/wKioL1gvHr6yEyKGAAJV5IqSdk0296.png" target="_blank"></a>

<a href="http://s4.51cto.com/wyfs02/M00/8A/6A/wKioL1gvHsDxiCdmAAPUQ861948864.png" target="_blank"></a>

<a href="http://s3.51cto.com/wyfs02/M01/8A/6D/wKiom1gvHsCjCe-NAAFitPchWjo590.png" target="_blank"></a>

<a href="http://s3.51cto.com/wyfs02/M01/8A/6A/wKioL1gvHsGTP1LAAAGPKwhq6kM435.png" target="_blank"></a>

<a href="http://s3.51cto.com/wyfs02/M01/8A/6D/wKiom1gvHsLiSOnvAAD7s-ZcOto529.png" target="_blank"></a>

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