grpc - 使用 golang 带你从头撸一套 RPC 服务（二）

摘要：紧接上一篇，下面用作为客户端调用的服务端。安装插件插件可以帮助我们自动生成客户端封装了的服务接口，方便我们直接引入调用，否则只生成服务请求响应的实体类，用起来不太方便。打包解包客户端发送至服务端服务端接收数据后使用对应的实体解包服务端

紧接上一篇，下面用PHP作为客户端调用Go的服务端。

grpc_php_plugin插件可以帮助我们自动生成client stub客户端(封装了grpc的服务接口)，方便我们直接引入调用，否则只生成服务/请求/响应的实体类，用起来不太方便。

# 下载 grpc 的库到本地
cd ~ && git clone -b $(curl -L https://grpc.io/release) https://github.com/grpc/grpc
# 更新子模块依赖
cd grpc && git submodule update --init
# 这里我们只编译 php 的插件 如果要编译所有的 make && make install
make grpc_php_plugin
# 插件路径
ll ./bins/opt/grpc_php_plugin

PHP只能做C端，且需要安装grpc和protobuf扩展和库。

###生成php客户端库

#不会有 client stub 类
protoc -I. --php_out=plugins=grpc:./user user.proto

# 会有 client stub 类
protoc -I. 
--php_out=./user 
--grpc_out=./user 
--plugin=protoc-gen-grpc=/root/grpc/bins/opt/grpc_php_plugin 
user.proto

# 查看生成的服务类库
[root@localhost grpc]# tree user
user
├── GPBMetadata
│   └── User.php
├── User
│   ├── UserClient.php
│   ├── UserDeleteRequest.php
│   ├── UserDeleteResponse.php
│   ├── UserEntity.php
│   ├── UserIndexRequest.php
│   ├── UserIndexResponse.php
│   ├── UserPostRequest.php
│   ├── UserPostResponse.php
│   ├── UserViewRequest.php
│   └── UserViewResponse.php
└── user.pb.go

#安装扩展
pecl install grpc
pecl install protobuf

使用 composer 管理依赖加载。

mkdir grpc-php-client && cd grpc-php-client
# 使用 composer 管理项目
composer init

# 安装 grpc/protobuf 的客户端库文件
composer require grpc/grpc
composer require google/protobuf

# 新建 grpc 服务库目录 将生成的PHP客户端文件移动至此
mkdir grpc && mv $GOPATH/src/grpc/user/* ./grpc
# 注册 psr4 自动加载服务的客户端文件
vi composer.json
{
    "name": "root/php-client",
    "require": {
        "grpc/grpc": "^1.19",
        "google/protobuf": "^3.7"
    },
    "autoload": {
        "psr-4": {
            "User": "./grpc/User/",
            "GPBMetadata": "./grpc/GPBMetadata/"
        }
    }

}
# 更新 composer 加载器
composer dump-autoload

在安装完php的grpc扩展和依赖库后，我们就可以编写代码了。

 GrpcChannelCredentials::createInsecure()
]);


$userIndexRequest = new UserIndexRequest();
$userIndexRequest->setPage(1);
$userIndexRequest->setPageSize(12);

/* @var $userIndexResponse UserIndexResponse */
/* @var $statusObj stdClass */
list($userIndexResponse, $statusObj) = $userClient->UserIndex($userIndexRequest)->wait();

if (0 != $statusObj->code) {
    throw new Exception($statusObj->details, $statusObj->code);
}

printf("index request end: err %d msg %s" . PHP_EOL, $userIndexResponse->getErr(), $userIndexResponse->getMsg());

/* @var $data UserEntity[] */
$data = $userIndexResponse->getData();
foreach ($data as $row) {
    echo $row->getName() . " " . $row->getAge() . PHP_EOL;
}

// 剩余的就不写了 都很简单的
// $userClient->UserView();
// $userClient->UserPost();
// $userClient->UserDelete();

# 结果
[root@localhost php-client]# php index.php 
index request end: err 0 msg success 
big_cat 28
sqrt_cat 29

Go 服务端和客户端版

grpc使用protobuf作为IDL，声明服务接口，请求实体，响应实体，后续我们将自己业务填充进去，客户端发送请求实体，服务端服务接口处理业务，然后返回响应实体，请求/响应实体的数据传输也使用protobuf进行了打包/解包。

# 打包
//GoogleProtobufInternalMessage::serializeToString
# 解包
//GoogleProtobufInternalMessage::mergeFromString

// 客户端
$message = new Message();
$message->setId(1);
$message->setName("sqrt_cat");
$message->setAddress("shanghai");

$package = $message->serializeToString();

// 发送 $package 至服务端
// 服务端接收数据后使用对应的实体解包

// 服务端
$message = new Message();
$message->mergeFromString($package);

var_dump($message->getId(), $message->getName(), $message->getAddress());