开发者社区 > 云原生 > 云消息队列 > 正文

Apache RocketMQ大佬们,rocketmq5 发送的任意延时消息,有延迟十几秒消费的情?

Apache RocketMQ大佬们,rocketmq5 发送的任意延时消息,有延迟十几秒消费的情况,pom包引入rocketmq-client-java 5.0.5 咋回事啊?

展开
收起
真的很搞笑 2023-06-28 17:14:57 345 0
4 条回答
写回答
取消 提交回答
  • 您好,Apache RocketMQ5 发送的任意延时消息,有延迟十几秒消费的情况可能是由于以下原因导致的:

    1. 消费者端的消费者组配置中,没有正确地指定tag过滤条件。请确保在消费者组配置中设置了正确的tag过滤条件,以便只接收带有指定tag的消息。
    2. 消费者端的消费线程数不足,导致无法及时处理消息。请检查消费者端的消费线程数是否足够。
    3. 消息生产和消费有时间窗口要求。例如在电商交易中超时未支付关闭订单的场景,在订单创建时会发送一条RocketMQ延时消息,这条消息将会在30分钟以后投递给消费者,消费者收到此消息后需要判断对应的订单是否已经超时未支付关闭。
    2023-06-30 07:50:38
    赞同 展开评论 打赏
  • Apache RocketMQ 发送的延时消息,需要满足以下两个条件:

    消息的 topic 需要设置为支持延时消息的 topic,即在创建 topic 时需要设置 messageDelayLevel 参数。

    发送消息时需要设置延时级别,即使用 setDelayTimeLevel 方法设置消息的延时级别。

    2023-06-29 22:08:04
    赞同 展开评论 打赏
  • 公众号:网络技术联盟站,InfoQ签约作者,阿里云社区签约作者,华为云 云享专家,BOSS直聘 创作王者,腾讯课堂创作领航员,博客+论坛:https://www.wljslmz.cn,工程师导航:https://www.wljslmz.com

    RocketMQ支持任意延迟的延时消息方案,精确到秒,最长延迟时间为1年。如果您使用的是RocketMQ 5.0.5版本,那么您可以尝试以下方法解决问题:

    • 确保您的生产者和消费者都使用了相同的版本号。
    • 确保您的生产者和消费者都使用了相同的配置文件。
    • 确保您的生产者和消费者都使用了相同的JVM参数。
    • 确保您的生产者和消费者都使用了相同的网络连接。
    2023-06-29 08:12:09
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    如果您使用的是 Apache RocketMQ 5.x 版本,并且在发送任意延时消息时遇到了消费延迟的问题,可能有以下几种原因:

    延时时间设置不正确:在发送任意延时消息时,需要正确设置消息的延时时间。如果延时时间设置不正确,可能导致消息在消费端延迟。

    消费端消费能力不足:如果消费端的消费能力不足,可能导致消息在消费端延迟。您可以检查消费端的消费能力,以确定是否需要增加消费端的消费能力。

    网络延迟:如果消息在发送和消费过程中经过的网络传输过程中出现延迟,也可能导致消息在消费端延迟。您可以检查网络连接是否正常,或者尝试使用其他网络连接方式。

    关于您提到的使用 Apache RocketMQ 5.0.5 版本的情况,建议您先检查以上可能的原因,并根据具体情况进行调整和优化。

    2023-06-28 18:56:19
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载

    相关镜像