摘要：緊接上一篇，下面用作為客戶端調(diào)用的服務(wù)端。安裝插件插件可以幫助我們自動(dòng)生成客戶端封裝了的服務(wù)接口，方便我們直接引入調(diào)用，否則只生成服務(wù)請(qǐng)求響應(yīng)的實(shí)體類，用起來不太方便。打包解包客戶端發(fā)送至服務(wù)端服務(wù)端接收數(shù)據(jù)后使用對(duì)應(yīng)的實(shí)體解包服務(wù)端

緊接上一篇，下面用PHP作為客戶端調(diào)用Go的服務(wù)端。

grpc_php_plugin插件可以幫助我們自動(dòng)生成client stub客戶端(封裝了grpc的服務(wù)接口)，方便我們直接引入調(diào)用，否則只生成服務(wù)/請(qǐng)求/響應(yīng)的實(shí)體類，用起來不太方便。

# 下載 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擴(kuò)展和庫。

###生成php客戶端庫

#不會(huì)有 client stub 類
protoc -I. --php_out=plugins=grpc:./user user.proto

# 會(huì)有 client stub 類
protoc -I. 
--php_out=./user 
--grpc_out=./user 
--plugin=protoc-gen-grpc=/root/grpc/bins/opt/grpc_php_plugin 
user.proto

# 查看生成的服務(wù)類庫
[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

#安裝擴(kuò)展
pecl install grpc
pecl install protobuf

使用 composer 管理依賴加載。

mkdir grpc-php-client && cd grpc-php-client
# 使用 composer 管理項(xiàng)目
composer init

# 安裝 grpc/protobuf 的客戶端庫文件
composer require grpc/grpc
composer require google/protobuf

# 新建 grpc 服務(wù)庫目錄 將生成的PHP客戶端文件移動(dòng)至此
mkdir grpc && mv $GOPATH/src/grpc/user/* ./grpc
# 注冊(cè) psr4 自動(dòng)加載服務(wù)的客戶端文件
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擴(kuò)展和依賴庫后，我們就可以編寫代碼了。

 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();

# 結(jié)果
[root@localhost php-client]# php index.php 
index request end: err 0 msg success 
big_cat 28
sqrt_cat 29

Go 服務(wù)端和客戶端版

grpc使用protobuf作為IDL，聲明服務(wù)接口，請(qǐng)求實(shí)體，響應(yīng)實(shí)體，后續(xù)我們將自己業(yè)務(wù)填充進(jìn)去，客戶端發(fā)送請(qǐng)求實(shí)體，服務(wù)端服務(wù)接口處理業(yè)務(wù)，然后返回響應(yīng)實(shí)體，請(qǐng)求/響應(yīng)實(shí)體的數(shù)據(jù)傳輸也使用protobuf進(jìn)行了打包/解包。

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

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

$package = $message->serializeToString();

// 發(fā)送 $package 至服務(wù)端
// 服務(wù)端接收數(shù)據(jù)后使用對(duì)應(yīng)的實(shí)體解包

// 服務(wù)端
$message = new Message();
$message->mergeFromString($package);

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