当前位置：首页 > PHP

php实现grpc

2026-02-28 15:21:44PHP

PHP 实现 gRPC 的方法

安装 gRPC 扩展和工具

确保系统已安装 PHP 7.0 或更高版本。通过 pecl 安装 gRPC 扩展：

pecl install grpc

在 php.ini 中添加 extension=grpc.so。安装 Protocol Buffers 编译器（protoc）和 PHP 插件：

# 安装 protoc（以 Linux 为例）
wget https://github.com/protocolbuffers/protobuf/releases/download/v3.15.8/protoc-3.15.8-linux-x86_64.zip
unzip protoc-3.15.8-linux-x86_64.zip -d /usr/local

# 安装 PHP 插件
git clone https://github.com/grpc/grpc.git
cd grpc/src/php/ext/grpc
phpize
./configure
make
sudo make install

定义 Protocol Buffers 文件

创建 .proto 文件定义服务接口。例如 example.proto：

syntax = "proto3";
package example;

service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}

生成 PHP 代码

使用 protoc 生成 PHP 客户端和服务端代码：

protoc --php_out=. --grpc_out=. --plugin=protoc-gen-grpc=/usr/local/bin/grpc_php_plugin example.proto

生成的文件包括 Example/GreeterClient.php 和 Example/GreeterServer.php。

实现 gRPC 服务端

创建服务端实现类：

require_once __DIR__ . '/vendor/autoload.php';
require_once __DIR__ . '/Example/GreeterServer.php';

class GreeterService extends \Example\GreeterServer {
    public function SayHello(\Example\HelloRequest $request): \Example\HelloReply {
        $reply = new \Example\HelloReply();
        $reply->setMessage("Hello " . $request->getName());
        return $reply;
    }
}

$server = new \Grpc\RpcServer();
$server->addHttp2Port('0.0.0.0:50051');
$server->handle(new GreeterService());
$server->run();

实现 gRPC 客户端

创建客户端调用代码：

require_once __DIR__ . '/vendor/autoload.php';
require_once __DIR__ . '/Example/GreeterClient.php';

$client = new \Example\GreeterClient('localhost:50051', [
    'credentials' => \Grpc\ChannelCredentials::createInsecure(),
]);

$request = new \Example\HelloRequest();
$request->setName('World');

list($response, $status) = $client->SayHello($request)->wait();
if ($status->code === \Grpc\STATUS_OK) {
    echo $response->getMessage(); // 输出 "Hello World"
}