文章字数:192,阅读全文大约需要1分钟
阿里巴巴用java开发的消息中间件,支持大规模topic数量,性能好。
推送方式
pull
模式:拉取,DefaultMQPullConsumer
模式。是由客户端主动向MQ
请求数据,主动权在客户端,先拉取数据再消费。不会因为推送太快而处理不及时。push
模式:推送,DefaultMQPushConsumer
模式。一般的push
是MQ
主动推送信息,但是可能会导致消费者跟不上推送速度。RocketMQ
采用的是长轮询的方式,客户端访问MQ
,有信息就拉取关闭连接消费,然后再请求并拉取。没有信息请求就会等待新信息,知道超时,超时会关闭连接并再次发送新的请求。