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

为啥发了mqtt消息,订阅端必须重新链接才能收到之前的消息。不是实时接收到发过来的消息?

Apache RocketMQ为啥发了mqtt消息,订阅端必须重新链接才能收到之前的消息。不是实时接收到发过来的消息?

展开
收起
wenti 2023-02-13 14:02:14 289 3
3 条回答
写回答
取消 提交回答
  • 可能消息问题关闲了,才出现了这样子的事情

    2023-02-19 08:17:52
    赞同 展开评论 打赏
  • 可能消费端订阅的时候没心跳,挂了,可以提工单看看——该回答整理自钉群“阿里云 微消息队列 MQTT产品咨询群”

    2023-02-13 19:43:00
    赞同 1 展开评论 打赏
  • 从事java行业9年至今,热爱技术,热爱以博文记录日常工作,csdn博主,座右铭是:让技术不再枯燥,让每一位技术人爱上技术

    消息队列关于订阅关系,可通过配置控制如下传输行为: 消息过滤规则:用于控制消费者在消费消息时,选择主题内的哪些消息进行消费,设置消费过滤规则可以高效地过滤消费者需要的消息集合,灵活根据不同的业务场景设置不同的消息接收范围。具体信息,请参见消息过滤。 消费状态:消息队列RocketMQ版服务端默认提供订阅关系持久化的能力,即消费者分组在服务端注册订阅关系后,当消费者离线并再次上线后,可以获取离线前的消费进度并继续消费。 同时也支持定时/延时消息,建议你检查一下订阅端是否会实时去获取消息队列中消息,同时也检查一下是否将消息设置成了定时或延时消息。

    2023-02-13 17:54:07
    赞同 展开评论 打赏

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

相关产品

  • 云消息队列 MQ
  • 相关电子书

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