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

阿里云消息队列怎么让Consumer即时监听消息

现在注册了阿里,开通了消息队列服务,创建了一个topic,在程序中写了个producer类负责发送消息,写了个Consumer类负责接收消息并做相应的事情。可是,Consumer类怎么一直运行起保证main方法一直运行着随时监听是否有消息进来。。。。好愁啊,求指教啊,谢谢啦

展开
收起
萍2 2016-02-25 11:46:20 5516 0
1 条回答
写回答
取消 提交回答
  • 如果是java, consumer.start()后,应用程序不退出,监听就会一直在,不需要用户干预。
    如果非java, pConsumer.start()后,主线程需要sleep(N),等不需要再消费时,再执行pConsumer.shutdown()。
    N值多大合适?根据用户的业务需要来决定。

    2019-07-17 18:30:40
    赞同 展开评论 打赏

多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖多行业。

相关产品

  • 云消息队列 Kafka 版
  • 消息服务
  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

    更多
    企业互联网架构之消息队列 立即下载
    基于消息队列RocketMQ的大型分布式应用上云最佳实践 立即下载
    云原生消息队列Apache RocketMQ 立即下载