天翼云分布式消息服务RocketMQ Push消费和Pull消费
文档简介:
从应用的角度,在RocketMQ中,支持push与pull消费方式。
Push消费:
1)客户端通过注册监听Listener的方式,当有个消息可消费时,API会调用Listener方法,主动推送消息;
从应用的角度,在RocketMQ中,支持push与pull消费方式。
Push消费:
1)客户端通过注册监听Listener的方式,当有个消息可消费时,API会调用Listener方法,主动推送消息;
2)为了能做到实时收消息,PUSH方式使用长轮询机制,保证消息实时性。
Pull消费:
1)客户端调用pull接口,主动拉取数据;
2)PULL是应用控制线程的,应该可以多线程调用pull接口,也可以单线程拉取;
3)对于无序消费,应用可以多次调用pull并拉到数据,且与是否签收无关;
4)对于有序消费,只要同一Queue的消息被拉出去消费,但未签收,则此Queue无法再拉取消费。