类DefaultMQProducerImpl中的request()方法未正确处理钩子函数

在阅读rocketmq源代码时,我发现了一个可能的漏洞场景。

在DefaultMQProducerImpl类中,有一组用request声明的方法,如下图所示

提问30.png

在这个方法中,invoke-wait-response方法等待,并在sendcallback中的onexception中执行countdown();然而,onsuccess()中没有倒计时(),因此即使传输成功,也会被阻止,直到超时

在其他类似的方法中,不调用requestcallback的onsuccess

提问31.png

原提问者GitHub用户Stupid-Dird

展开
收起
芬奇福贵 2023-05-26 10:35:12 93 分享 版权
1 条回答
写回答
取消 提交回答
  • countDown()方法将在调用onSuccess()方法之前执行。

    原回答者GitHub用户Git-Yang

    2023-05-26 16:56:00
    赞同 展开评论

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理