背景概述

综合之前所学的知识点, 我们现在需要实现一个下面的任务, 客户端发送消息给服务端 B, 然后服务端 B 将消息发送给服务端 C, 然后 C 将结果返回给 B, B再把消息返回给 A, 这样的一个处理流程.
image.png

客户端A代码

case_client.php

  1. <?php
  2.     // 创建一个 TCP 连接
  3.     $client = new Swoole\Client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC);
  5.     // 尝试连接到本地的 9501 端口
  6.     if (!$client->connect('127.0.0.1', 9503, 1000)) {
  7.         // 连接失败的提示信息
  8.         exit("connect failed. Error: {$client->errCode}\n");
  9.     }
  11.     // 发送到服务端的数据
  12.     $client->send("hello world\n");
  14.     // 打印服务端返回的数据
  15.     echo $client->recv();
  17.     // 关闭连接
  18.     $client->close();
  19. ?>

服务端B

case_server_and_client.php

  1. <?php
  2.     // 创建Server对象，监听 9501端口
  3.     $server = new Swoole\Server('0.0.0.0', 9503);
  5.     // 监听连接进入事件
  6.     $server->on('Connect', function ($server, $fd) {  
  7.         echo "Client: Connect.\n";
  8.     });
  10.     // 监听数据接收事件
  11.     $server->on('Receive', function ($server, $fd, $from_id, $data) {
  12.         echo 'client request data : ', $data;
  14.         // 创建Server对象，监听 9501端口
  15.         $client = new Swoole\Client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC);
  16.         // 尝试连接到本地的 9501 端口
  17.         if (!$client->connect('127.0.0.1', 9504, 1000)) {
  18.             // 连接失败的提示信息
  19.             exit("connect failed. Error: {$client->errCode}\n");
  20.         }
  21.         // 发送到服务端的数据
  22.         $client->send("Server and Client request data \n");
  23.         $result = $client->recv();
  24.         echo $result."\n";
  25.         $client->close();
  27.         $server->send($fd, $result."\n");
  28.     });
  30.     // 监听连接关闭事件
  31.     $server->on('Close', function ($server, $fd) {
  32.         echo "Client: Close.\n";
  33.     });
  35.     // 启动服务器
  36.     $server->start(); 
  38. ?>

服务端C

case_server.php

  1. <?php
  2.     // 创建Server对象，监听 9501端口
  3.     $server = new Swoole\Server('0.0.0.0', 9504);
  5.     // 监听连接进入事件
  6.     $server->on('Connect', function ($server, $fd) {  
  7.         echo "Client: Connect.\n";
  8.     });
  10.     // 监听数据接收事件
  11.     $server->on('Receive', function ($server, $fd, $from_id, $data) {
  12.         echo "request data : ".$data."\n";
  13.         $server->send($fd, "Server response Data : server response data \n");
  14.     });
  16.     // 监听连接关闭事件
  17.     $server->on('Close', function ($server, $fd) {
  18.         echo "Client And Server : Close.\n";
  19.     });
  21.     // 启动服务器
  22.     $server->start(); 
  23. ?>

执行代码

先打开服务端C, 在打开服务端B, 最后在执行客户端A

  1. [server] php case_server.php 
  3. [ServerAndClient] php case_server_and_client.php 
  5. [client] php case_client.php 
  6. Server response Data : server response data 
  9. ## 服务端 C 结果
  10. [server] php case_server.php 
  11. Client: Connect.
  12. request data : Server and Client request data 
  14. Client And Server : Close.
  16. ## 服务端 B 结果
  17. [ServerAndClient] php case_server_and_client.php 
  18. Client: Connect.
  19. client request data : hello world
  20. Server response Data : server response data 
  22. Client: Close.
  24. ## 客户端 A 结果
  25. [client] php case_client.php 
  26. Server response Data : server response data