要在 PHP 中集成 gRPC 服务,您需要遵循以下步骤:
安装 gRPC 和 Protocol Buffers:
a. 首先,确保您已经安装了 gRPC 和 Protocol Buffers。您可以在官方文档中找到详细的安装说明:https://grpc.io/docs/languages/php/quickstart/
创建 .proto
文件:
a. 使用 Protocol Buffers 语言定义您的服务接口和消息结构。例如,创建一个名为 example.proto
的文件,其中包含以下内容:
syntax = "proto3";
package Example;
service ExampleService {
rpc SayHello (HelloRequest) returns (HelloResponse);
}
message HelloRequest {
string name = 1;
}
message HelloResponse {
string message = 1;
}
生成 PHP 代码:
a. 使用 protoc
编译器生成 PHP 代码。确保将 --php_out
和 --grpc_out
选项设置为您的项目目录。例如:
protoc --php_out=. --grpc_out=. --plugin=protoc-gen-grpc=`which grpc_php_plugin` example.proto
实现服务器:
a. 创建一个 PHP 类,实现您在 .proto
文件中定义的服务接口。例如:
<?php
require_once 'GPBMetadata/Example.php';
require_once 'Example/ExampleServiceClient.php';
require_once 'Example/ExampleServiceServer.php';
require_once 'Example/HelloRequest.php';
require_once 'Example/HelloResponse.php';
use Example\ExampleServiceImpl;
use Example\HelloRequest;
use Example\HelloResponse;
use Grpc\Server;
use Grpc\ServerContext;
class ExampleService extends ExampleServiceImpl
{
public function SayHello(ServerContext $context, HelloRequest $request): HelloResponse
{
$response = new HelloResponse();
$response->setMessage("Hello, " . $request->getName() . "!");
return $response;
}
}
$server = new Server([
'host' => '0.0.0.0:50051',
]);
$server->addService(ExampleService::class, new ExampleService());
$server->start();
运行服务器:
a. 在命令行中运行您的服务器脚本。例如:
php server.php
实现客户端:
a. 创建一个 PHP 类,用于调用您在 .proto
文件中定义的服务接口。例如:
<?php
require_once 'GPBMetadata/Example.php';
require_once 'Example/ExampleServiceClient.php';
require_once 'Example/ExampleServiceServer.php';
require_once 'Example/HelloRequest.php';
require_once 'Example/HelloResponse.php';
use Example\ExampleServiceClient;
use Example\HelloRequest;
use Grpc\ChannelCredentials;
$client = new ExampleServiceClient('localhost:50051', [
'credentials' => ChannelCredentials::createInsecure(),
]);
$request = new HelloRequest();
$request->setName("World");
list($response, $status) = $client->SayHello($request)->wait();
if ($status->code === \Grpc\STATUS_OK) {
echo "Response: " . $response->getMessage() . PHP_EOL;
} else {
echo "Error: " . $status->details . PHP_EOL;
}
运行客户端:
a. 在命令行中运行您的客户端脚本。例如:
php client.php
现在,您应该能够看到客户端输出 “Response: Hello, World!”,表示您已成功地在 PHP 中集成了 gRPC 服务。