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

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

展开
收起
wenti 2023-02-13 14:02:14 337 分享 版权
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-learning.com/

收录在圈子:
+ 订阅
阿里云 云原生应用平台 肩负阿里巴巴集团基础设施云化以及核心技术互联网化的重要职责,致力于打造稳定、标准、先进的云原生产品,成为云原生时代的引领者,推动行业全面想云原生的技术升级,成为阿里云新增长引擎。商业化产品包括容器、云原生中间件、函数计算等。
还有其他疑问?
咨询AI助理