java rocketmq 生产者如何取得消费者的消费结果
java rocketmq 生产者如何取得消费者的消费结果？
本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击链接欢迎加入感兴趣的技术领域群。
展开
收起
4
条回答
写回答
写回答
-
-
为之则易，不为则难
RocketMQ第一阶段发送Prepared消息时，会拿到消息的地址,第二阶段执行本地事物，第三阶段通过第一阶段拿到的地址去访问消息，并修改消息的状态。当RocketMQ确认消息发送失败时，RocketMQ会定期扫描消息集群中的事物消息，如果发现了Prepared消息，它会向消息发送端(生产者)确认.
2019-11-07 11:17:42赞同 展开评论 打赏 -
技术架构师 阿里云开发者社区技术专家博主 CSDN签约专栏技术博主 掘金签约技术博主 云安全联盟专家 众多开源代码库Commiter生产者、消费者，都是经过消息队列，来实现通信。生产者，可以生产消息，消费者去消费，完成之后，将结束消息传递给生产者
2019-11-07 11:15:34赞同 展开评论 打赏 -
每个消费者处理完成请求，再发送消息到消息队列中，你的生产者那方再实现消费者来消费这些处理结果信息；然后处理你的逻辑，将处理结果存于缓存等高性能组件中，通过轮询的方式获取任务处理结果
2019-11-05 15:13:30赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
