标签:metaq 消息队列
一对一
点对点模型特性:消息只有在处理成功后才会删除,失败时不会删除,这样下次取时,队列中还会有
发布-订阅模型特性(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
标签:metaq 消息队列
原文地址:http://silencezone.blog.51cto.com/3613477/1874475