PHP作为客户端请求GRPC服务

最近要使用别的部门提供的短信服务,用go写的RPC,可能要用到GRPC框架去请求,先了解下,后面对接了再补一篇实战。

php是否支持rpc服务端

支持服务端RPC的语言:Java,C ++,Dart,Python,Objective-C,C#,lite-runtime(Android Java),Ruby和JavaScript
目前PHP自身只能创建客户端
但是,PHP可以依赖swoole扩展来做rpc服务端

准备

安装composer
安装gRPC扩展
下载protoc
http://pecl.php.net/package/gRPC/1.28.0/windows
https://github.com/protocolbuffers/protobuf/releases
protoc和composer都设置好环境变量,方面cmd命令行调用

protoc

默认情况下,gRPC使用protocolbuffers(Google定义的一种数据格式,用于格式化数据,以下简称pb)来结构化数据。
使用pb:在以proto为后缀的文件中使用指定语法来定义数据结构,pb的数据被构造为 message,其中包含一系列被称为字段的键/值对。举一个简单的例子:

//类似类的定义,并且有数据格式描述
message Person{
   string name=1;
   int32 id=2;
   bool has_ponycopter=3;
}

一旦定义了数据结构,就可以使用pb的编译器protoc(刚刚下载的那个工具)从定义中以首选语言生成数据访问类(这也是为什么定义看起来很像一个类,方便转换)。protoc工具为每个字段(例如name)提供了简单的访问器set_name(),get_name,以及将整个结构序列化为原始字节或从原始字节中解析出整个结构的方法。例如,如果您选择的语言是C ++,则在上面的示例中运行编译器将生成一个名为Person的类。然后,可以在应用程序中使用此类来设置和检索类Person的pb message。

编写protoc文件test.proto

syntax = "proto3";
package test;
service Test{
    //定义sayHello方法
    rpc SayHello(HelloRequest) returns (HelloReply){}
}

//HelloRequest 请求结构
message HelloRequest{
    string name = 1;
}

//HelloReply 请求结构
message HelloReply{
    string message = 1;
}

使用protoc工具编译proto文件

C:\test>protoc –php_out=. test.proto
注意:在自己的项目文件夹执行这个命令,=后面有一个点,不要忽略了

编写composer.json文件

{
  "name": "grpc-for-php",
  "require": {
    "grpc/grpc": "^v1.3.0",
    "google/protobuf": "^v3.3.0"
  },
  "autoload":{
    "psr-4":{
      "GPBMetadata\\":"GPBMetadata/",
      "Test\\":"Test/" 
    }
  }
}

执行composer install

composer install

编写Test/TestClient.php文件

<?php
namespace Test;

/**
 * 编写客户端
 */
class TestClient extends \Grpc\Basestub
{
    
    function __construct($hostname,$opts,$channel = null)
    {
        parent::__construct($hostname,$opts,$channel);
    }

    /**
    *
    */

    public function sayHello(\Test\TestRequest $argument,$metadata=[],$options=[]){
        return $this->_simpleRequest('/test.Test/sayHello',$argument,['\Test\TestReply','decode'],$metadata,$options);
    }

}

编写php执行文件

require __DIR__.'/vendor/autoload.php';
//这里的地址是提供服务的地方给的
$client = new \Test\TestClient('127.0.0.1:50052',[
    'credentials'   => Grpc\ChannelCredentials::createInsecure()
]);

//实例化TestRequest类
$request  = new Test\HelloRequest();
$request->setName('1');

//调用远程服务
$get = $client->sayHello($request)->wait();

//返回数据
list($reply,$status) = $get;

var_dump($status);
var_dump($reply);

最后:什么是GRPC?
gRPC是可以在任何环境中运行的现代开源高性能RPC框架。它可以通过可插拔的支持来有效地连接数据中心内和跨数据中心的服务,以实现负载均衡,跟踪,运行状况检查和身份验证。它也适用于分布式计算的最后一英里,以将设备,移动应用程序和浏览器连接到后端服务。
在gRPC中,客户端应用程序可以直接在其他计算机上的服务器应用程序上调用方法,就好像它是本地对象一样,这使您更轻松地创建分布式应用程序和服务。与许多RPC系统一样,gRPC围绕定义服​​务的思想,可指定其远程调用的方法接受参数和返回类型。在服务器端,服务器实现此接口并运行gRPC服务器以处理客户端调用。在客户端,客户端具有一个stub,提供与服务器相同的方法。
(服务端实现接口,定义参数和返回类型以及提供可以远程调用的方法。客户端提供与服务端相同的方法与描述,通过protoc文件确认参数和方法)。

打赏作者

发表评论

电子邮件地址不会被公开。