0%

RocketMQ推送方式

文章字数:192,阅读全文大约需要1分钟

阿里巴巴用java开发的消息中间件,支持大规模topic数量,性能好。

推送方式

  1. pull模式:拉取,DefaultMQPullConsumer模式。是由客户端主动向MQ请求数据,主动权在客户端,先拉取数据再消费。不会因为推送太快而处理不及时。

  2. push模式:推送,DefaultMQPushConsumer模式。一般的pushMQ主动推送信息,但是可能会导致消费者跟不上推送速度。RocketMQ采用的是长轮询的方式,客户端访问MQ,有信息就拉取关闭连接消费,然后再请求并拉取。没有信息请求就会等待新信息,知道超时,超时会关闭连接并再次发送新的请求。