答案：基于swoole的异步长连接特性，通过自定义json协议实现rpc服务，包含服务注册、序列化、通信解包与远程调用；服务端监听请求并解析执行，客户端发送带长度头的请求数据并接收响应，支持协程并发调用，可扩展超时、加密等机制。
Swoole 实现一个简单的 RPC 服务，核心是利用其异步、长连接的特性，通过自定义协议在客户端和服务端之间传递方法调用信息。整个流程包括服务注册、数据序列化、网络通信和远程方法执行。下面分步骤说明如何用 Swoole 快速搭建一个基础的 RPC 框架。
1. 设计基本通信协议
RPC 的关键是定义清晰的请求与响应格式。我们可以使用简单的 JSON 协议来传输调用信息：
请求数据结构示例：- method：要调用的方法名
- params：参数数组
- id：请求唯一标识（用于回调匹配）
响应数据结构示例：
- id：对应请求的 id
- result：执行结果
- error：错误信息（无错为 null）
数据发送前需拼接长度头，解决 TCP 粘包问题。比如先发送 4 字节的包长度，再发送实际内容。
2. 编写 RPC 服务端
使用 Swoole\Server 创建 TCP 服务，监听调用请求：
$server = new Swoole\Server('127.0.0.1', 9502);
// 模拟提供的服务类
class UserService {
public function getUser($id) {
return ['id' => $id, 'name' => 'Alice'];
}
}
$services = [
'UserService' => new UserService(),
];
$server->on('Receive', function ($serv, $fd, $reactorId, $data) use ($services) {
// 解包：先读取头部长度，再读取完整 JSON 数据
$length = unpack('N', substr($data, 0, 4))[1];
$json = substr($data, 4, $length);
$request = json_decode($json, true);
$serviceMethod = explode('.', $request['method']); // 格式：ServiceName.methodName
$serviceName = $serviceMethod[0];
$methodName = $serviceMethod[1];
$result = null;
$error = null;
try {
if (!isset($services[$serviceName])) {
throw new Exception("Service not found");
}
$service = $services[$serviceName];
if (!method_exists($service, $methodName)) {
throw new Exception("Method not found");
}
$result = call_user_func_array([$service, $methodName], $request['params']);
} catch (Exception $e) {
$error = $e->getMessage();
}
// 构造响应
$response = json_encode([
'id' => $request['id'],
'result' => $result,
'error' => $error,
]);
$sendData = pack('N', strlen($response)) . $response;
$serv->send($fd, $sendData);
});
$server->start();3. 编写 RPC 客户端
客户端通过 Swoole\Coroutine\Socket 或同步 Socket 连接服务端并发送请求：
function rpcCall($method, $params) {
$client = new Swoole\Coroutine\Client(SWOOLE_SOCK_TCP);
if (!$client->connect('127.0.0.1', 9502, 0.5)) {
throw new Exception("Connect failed");
}
$request = json_encode([
'id' => uniqid(),
'method' => $method,
'params' => $params,
]);
$data = pack('N', strlen($request)) . $request;
$client->send($data);
// 先读 4 字节长度
$head = $client->recv(4);
$bodyLength = unpack('N', $head)[1];
$response = $client->recv($bodyLength);
$result = json_decode($response, true);
$client->close();
if ($result['error']) {
throw new Exception($result['error']);
}
return $result['result'];
}调用示例：
```php try { $user = rpcCall('UserService.getUser', [1001]); var_dump($user); // 输出: ['id' => 1001, 'name' => 'Alice'] } catch (Exception $e) { echo "RPC Error: " . $e->getMessage(); } ```4. 支持协程并发调用
Swoole 的优势在于协程并发。可以同时发起多个 RPC 请求，提升效率：
go(function () {
$ch1 = chan();
$ch2 = chan();
go(function () use ($ch1) {
$ch1->push(rpcCall('UserService.getUser', [1]));
});
go(function () use ($ch2) {
$ch2->push(rpcCall('UserService.getUser', [2]));
});
$user1 = $ch1->pop();
$user2 = $ch2->pop();
var_dump($user1, $user2);
});基本上就这些。一个轻量级的 Swoole RPC 服务就跑起来了。重点是协议设计、解包处理和异常控制。后续可扩展服务发现、超时机制、加密序列化等。不复杂但容易忽略细节。
