php中grpc请求⽅式,PHP中使⽤gRPC客户端
因为⼯作需要使⽤gRPC,本⼈使⽤的是windows10,不过linux的操作流程基本⼀样。
直接进⼊主题,分为了⼏部分
1、下载Protoc
解压后得到,在bin⽂件夹下的 。我放到 D:\Program Files\protoc-3.7.1-win64\bin 下,并加⼊到系统环境变量 Path 中,就可以使⽤ protoc 命令了,可以⽤ protoc --version 来查看是否成功。(这⼀步很重要⽤于⽣成 protobuf ⽂件对应的 PHP代码 ⽤的)
2、编写 protocol buffers ⽂件
如何编写请看 Protobuf3语⾔指南 写得不错,⾸先创建⼀个为 testgrpc_com 项⽬,我这的位置是 E:\www\testgrpc_com ,在项⽬下简单写了⼀个 xuexitest.proto
syntax = "proto3"; // 指定proto版本
package xuexitest; // 指定包名
//定义 Xuexitest 服务
service Xuexitest {
//定义 SayTest ⽅法
rpc SayTest(TestRequest) returns (TestReply) {}
}
//TestRequest 请求结构
message TestRequest {
int64 typeid = 1;
}
//TestReply 响应结构
message TestReply {
//返回数据类型
message GetData {
int64 id = 1;
string name = 2;
}
repeated GetData getdataarr = 1;
}
3、下载 PHP的gRPC扩展和protobuf扩展
注:1、PHP的protobuf扩展没有windows版本的,但不影响使⽤⽆⾮就是运⾏速度慢点。(使⽤ composer 加载 protobuf 类库,请看下⾯的 composer.json 配置⽂件)
注:2、如何安装PHP扩展,这⾥就不讲了。
4、编译 protocol buffers ⽂件
编译 xuexitest.proto 使⽤ protoc --php_out=. xuexitest.proto 会⽣成得到:
5、使⽤ PHP 的 composer
⾸先 安装 composer 来管理和加载PHP的类库,如何安装这⾥就不讲了。(这⼀步也很重要⽤于解决 Grpc和 protobuf 的PHP类库依赖)
在项⽬下编写 composer.json 放到刚刚编译 protocol buffers ⽂件同级下
{
"name": "grpc-go-php",
"require": {
"grpc/grpc": "^v1.3.0",
"google/protobuf": "^v3.3.0"
},
"autoload":{
"psr-4":{
"GPBMetadata\\":"GPBMetadata/",
"Xuexitest\\":"Xuexitest/"如何运行php项目
}
}
}
6、使⽤ Composer 下载 PHP 代码
1.进⼊到项⽬的⽬录,如:E:\www\testgrpc_com 中在地址栏输⼊cmd回车即可
2.在命令提⽰符(⿊窗⼝)下输⼊ composer install 回车,等待下载完成。
7、定义PHP的gRPC端户端
在项⽬的 Xuexitest ⽂件夹中,新建 XuexitestClient.php ⽂件
namespace Xuexitest;
/**
* service Xuexitest{}
* 编写 (gprc 定义 Xuexitest 服务)的客户端
*/
class XuexitestClient extends \Grpc\BaseStub{
public function __construct($hostname, $opts, $channel = null) {
parent::__construct($hostname, $opts, $channel);
}
/**
* rpc SayTest(TestRequest) returns (TestReply) {}
* ⽅法名尽量和 (gprc 定义 Xuexitest 服务)的⽅法⼀样
* ⽤于请求和响应该服务
*/
public function SayTest(\Xuexitest\TestRequest $argument,$metadata=[],$options=[]){ // (/xuexitest.X
uexitest/SayTest) 是请求服务端那个服务和⽅法,基本和 proto ⽂件定义⼀样// (\Xuexitest\TestReply) 是响应信息(那个类),基本和 proto ⽂件定义⼀样
return $this->_simpleRequest('/xuexitest.Xuexitest/SayTest',
$argument,
['\Xuexitest\TestReply', 'decode'],
$metadata, $options);
}
}
8、编写PHP执⾏⽂件
在项⽬下 新建 xuexitest.php
php
//引⼊ composer 的⾃动载加
require __DIR__ . '/vendor/autoload.php';
//⽤于连接 服务端
$client = new \Xuexitest\XuexitestClient('127.0.0.1:50052', [ 'credentials' => Grpc\ChannelCredentials::createInsecure() ]);
//实例化 TestRequest 请求类
$request = new \Xuexitest\TestRequest();
$request->setTypeid(1);
//调⽤远程服务
$get = $client->SayTest($request)->wait();
//返回数组
//$reply 是 TestReply 对象
//$status 是数组
list($reply, $status) = $get;
//数组
$getdata = $reply->getGetdataarr();
foreach ($getdata as $k=>$v){
echo $v->getId(),'=>',$v->getName(),"\n\r";
}
9、赶快执⾏下

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。