初识消息队列

Posted 2020-08-20

一对一

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

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

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

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

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

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

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

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

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

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

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

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

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

本文出自 “silence” 博客，请务必保留此出处http://silencezone.blog.51cto.com/3613477/1874475