八、远程调用(RPC)

在云计算环境中,很多时候需要用它其他机器的计算资源,把一部分计算任务分配到其他节点来完成。RabbitMQ 如何使用 RPC 呢?下面将会通过其它节点完成斐波纳契示例。

流程图

  • 当客户端启动时,它创建了匿名的 callback queue

  • 客户端发起 RPC 请求时将同时设置两个 properties:reply_to 设置为 callback queue;correlation_id 设置为每个请求都是独一无二的值

  • 请求将被发送到一个 rpc_queue 队列

  • RPC 端或者说 Server 一直在等待那个 queue 的请求,当请求到达时,它将通过在 reply_to 指定的 queue 回复一个 Message 给客户端

  • client 一直等待 callback queue 的数据,当 Message 到达时,它将检查 correlation_id 的值,如果值和它 request 发送时的一致那么就将返回响应

演示代码

rpc_client.php

rpc_server.php

测试示例:  


未经允许不得转载!

评论列表 0

访客
取消