V2EX = way to explore
V2EX 是一个关于分享和探索的地方
Sign Up Now
For Existing Member  Sign In
• 请不要在回答技术问题时复制粘贴 AI 生成的内容
ljmready
V2EX  ›  程序员

请教一个关于 RocketMQ 消费堵塞的问题

  •  1
     
  •   ljmready · Feb 9, 2020 · 2830 views
    This topic created in 2271 days ago, the information mentioned may be changed or developed.

    背景: 从 rocketmq 中 10 个 queue 消费出数据,处理完后写入数据库,总体 qps 大概在 4k

    现象: 写入数据库的耗时变高后,会出现队列堵塞,并且在数据库耗时下降后,队列依旧堵塞。观察 mq 的控制面板和业务日志发现有个别 queue 会停止消费,直到手动启动 client 才会恢复消费。

    问题:

    为什么数据库耗时下降后,队列的消费进度不会逐渐恢复,而是要手动重启?

    请大佬们指点下,谢谢!

    Supplement 1  ·  Apr 25, 2023
    应该排查 Consume Thread 的情况,检查线程池中的线程被业务逻辑堵塞住了
    3 replies    2020-02-09 20:25:02 +08:00
    find
        1
    find  
       Feb 9, 2020 via iPhone
    又有新的消息发送到了 mq 里面
    abcbuzhiming
        2
    abcbuzhiming  
       Feb 9, 2020
    你是不是参数设错了,数据库的耗时变高后,消费 client 可能因为超时而出错,多次出错后,client 可能会自动停下来,我在别的消息队列里见过这种设计
    ljmready
        3
    ljmready  
    OP
       Feb 9, 2020
    @abcbuzhiming 没见到有这种设置,我再查一下
    About   ·   Help   ·   Advertise   ·   Blog   ·   API   ·   FAQ   ·   Solana   ·   3786 Online   Highest 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 38ms · UTC 10:30 · PVG 18:30 · LAX 03:30 · JFK 06:30
    ♥ Do have faith in what you're doing.