qq_39348131 2018-05-31 02:09 采纳率: 66.7%
浏览 5487
已采纳

java rocketmq 生产者如何取得消费者的消费结果

比如说:我项目的服务接口,需要给调用者返回一个是否成功结果。因为可能并发量比较大,用rocketmq来流量削峰。我将生产者写入到接口中,每次调这个接口,生产者发送消息,消费者监听,并处理接口的实际业务。但是如何返回给生产者处理结果?我没找到具体代码方法。
还是说我上面做的方法,是不可行的?求解答

  • 写回答

3条回答 默认 最新

  • little_how 2018-05-31 02:27
    关注

    首先要明白消息队列是用于什么场景的;
    绝大部分用于削峰和解耦,也有用于处理分布式事务!
    然后再想想削峰的目的是什么,削峰是用于当应用处理不过来过大的并发请求时,将请求存于队列中,用单个或多个消费者来处理请求!

    这时候想要拿到请求怎么办呢?
    1.每个消费者处理完成请求,再发送消息到消息队列中,你的生产者那方再实现消费者来消费这些处理结果信息;
    然后处理你的逻辑!
    2.将处理结果存于缓存等高性能组件中,通过轮询的方式获取任务处理结果

    不管什么方式,你的请求方都应该是在你将请求消息发到队列后立即返回的!消息结果可以用推送的方式告知(移动端的话),也可以让请求方每个几秒轮询一次
    处理结果;

    希望对你有帮助...

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题?

悬赏问题

  • ¥15 qt+ffmpeg报错non-existing PPS 0 referenced
  • ¥15 FOC simulink
  • ¥15 咨询一下有关于王者荣耀赢藏战绩
  • ¥50 MacOS 使用虚拟机安装k8s
  • ¥500 亚马逊 COOKIE我如何才能实现 登录一个亚马逊账户 下发新 COOKIE ..我使用下发新COOKIE 导入ADS 指纹浏览器登录,我把账户密码 修改过后,原来下发新COOKIE 不会失效的方式
  • ¥20 玩游戏gpu和cpu利用率特别低,玩游戏卡顿
  • ¥25 oracle中的正则匹配
  • ¥15 关于#vscode#的问题:把软件卸载不会再出现蓝屏
  • ¥15 vimplus出现的错误
  • ¥30 怎么使用AVL fire ESE软件自带的优化模式来优化设计Soot和NOx?