,会影响其他线程发送消息的响应时间
默认以同步的方式发送消息
查找主题的路由信息,这样才知道要发送到哪个Broker,有缓存就去缓存中拿,没缓存就去NameServer中查
1个Broker默认有4个消息队列...只会启动一次
消息拉取
Pull模式
应用程序直接调API拉消息即可
消息拉取Push模式
每次消息拉取操作可以看成是一个任务,该任务被抽象成PullRequest对象,拉取到的消息先存放在PullRequest...1000,将触发流控,放弃本次拉取,并且该队列的下一次拉取任务将在50毫秒后才加入到拉取队列中; 对ProcessQueue中最大偏移量和最小偏移量的限制
拉取该订阅主题的消息,如果为空,结束本次拉取,...将PullRequest对象添加到pullRequestQueue中,唤醒消费消息的线程
集群内多个消费者如何负载主题下的多个消费队列?...如果broker未接收到回查的结果(或者查到的是unknow),则broker会定时进行重复回查,以确保查到最终的事务结果