"PullMessageProcessor的executeRequestWhenWakeup()方法重新尝试发起Pull消息的RPC请求(此处,每隔5S重试一次,默认长轮询整体的时间设置为30s"
请问PullMessageProcessor本身就是是broker端的,怎么还有尝试发起RPC请求?
消息中间件—RocketMQ消息消费(二)(push模式实现)摘要:在RocketMQ中,消息消费都是基于Pull消息方式,那么Push模式中又是如何实现Consumer端准实时消费的呢?在上一篇—“消息中间件—RocketMQ消息消费...