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

如何使用消息队列

我把内容放到队列中,如何让消费者按照自己写的逻辑自动消费?

展开
收起
清风慕松 2016-02-27 15:15:25 3077 0
2 条回答
写回答
取消 提交回答
  • JAVA开发工程师

    你可以参考我的这篇文章SpringBoot使用消息队列

    2019-07-17 18:31:12
    赞同 展开评论 打赏
  • 如何消费,请参考文档:
    https://help.aliyun.com/knowledge_detail/13051883.html?spm=5176.789006189.2.13.1Ukc5v

    举java为例,用户消费逻辑写在
    public Action consume(Message message, ConsumeContext context) {

    try {
        System.out.println("topic0229: " + new String(message.getBody(),"UTF-8") + "time:" + System.currentTimeMillis() + ",messageid:" + message.getMsgID());
         //Your business here
    } catch (UnsupportedEncodingException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    return Action.CommitMessage;

    }

    2019-07-17 18:31:12
    赞同 展开评论 打赏
问答分类:

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

相关电子书

更多
消息队列 Kafka 版差异化特性 立即下载
消息队列kafka介绍 立即下载
云原生消息队列Apache RocketMQ 立即下载