RabbitMQ(六)-RPC远程调用

六、RPC 远程调用

没用过RPC调用,这里只记录实现思路,不做具体实现。完整文档详见最后的参考资料

摘要

RPC远程调用

工作流程如下:

  • Client 客户端发送一条带有两个属性的消息:replyTo 设置为专门为请求创建的匿名独占队列;correlationId
  • 请求被发送到 rpc_queue 队列中
  • 服务器等待来自 rpc_queue 队列上的请求,当请求出现时,执行并使用来自 replyTo 的字段
  • 客户端等待应答队列上的数据,当有消息出现时,检查 correlationId,如果匹配,则返回应用程序的相应结果

Message Properties:

  • deliveryMode:将消息标记为持久性(2)或暂时
  • contentType:用于描述编码的mime类型
  • replyTo:用于命名回调队列
  • correlationId:用于将 RPC 响应与请求关联

二、参考资料

文章作者: koral
文章链接: http://luokaiii.github.io/2019/12/10/后端/消息队列/RocketMQ/7.Rpc/
版权声明: 本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自