生产者必须启动pullMessageService?

生产者必须启动pullMessageService?

  // Start pull service //producer don't start pullMessageService if (!getDefaultMQProducer().getProducerSide()) { this.pullMessageService.start(); }

原提问者GitHub用户zyong2004

展开
收起
芬奇福贵 2023-05-26 10:43:30 86 分享 版权
1 条回答
写回答
取消 提交回答
  • 无需启动IMO,如果启动,它将始终等待从队列中获取任务,并且线程将始终处于等待状态。基本上不消耗cpu资源

    while (!this.isStopped()) { try { PullRequest pullRequest = this.pullRequestQueue.take(); this.pullMessage(pullRequest); } catch (InterruptedException ignored) { } catch (Exception e) { log.error("Pull Message Service Run Method exception", e); } }

    原回答者GitHub用户panzhi33

    2023-05-26 17:02:30
    赞同 展开评论
问答地址: