
Golang 服务端,PHP客户端 的 GRPC 示例代码
博客地址:https://www.xhyonline.com/?p=1416
一、安装环境我们需要编写 .proto 文件,然后通过 protoc 命令编译,因此需要安装 protoc
地址:https://github.com/protocolbuffers/protobuf/releases
我是 windows 环境,因此就下载了这个压缩包,然后将 bin 目录下的 exe 添加至环境变量
命令行需要重启
重启之后在命令行窗口执行 protoc --version,当你看到下面这个界面时,代表安装成功了
(一)、Golang 相关插件此时正式进入 Golang 相关插件的安装,涉及到 Golang 的其实只有一个,protoc-gen-go 。它是用来配合 protoc 命令来生成 go 文件的。
安装方式如下:
地址:github.com/golang/protobuf/
下载整个项目,然后进入上图中 protoc-gen-go 目录中,自行使用 go build 进行编译,编译完成的 二进制文件 protoc-gen-go.exe 请一定放在 $GOPATH/bin 目录中,因为编译器protoc必须在$PATH中能找到它。
$GOPATH 找不到的话去环境变量里看
(二)、PHP 相关扩展PHP 必须安装 grpc 扩展。
地址如下:http://pecl.php.net/package/gRPC
由于我在 windows 环境下我就直接安装了 windows 下PHP的扩展,并且选择自己PHP对应的版本
下载完毕后,我们只需要 PHP_grpc.dll 文件,如下所示
我们将其拷贝到PHP的扩展目录 D:\PHPstudy_pro\Extensions\PHP\PHP7.3.4nts\ext,然后在PHP.ini文件中添加extension=grpc ,然后重启 PHP-fpm 后使用命令行 PHP -m 查看扩展是否安装成功。
其次我们必须安装 composer ,因为可以通过 composer 自动加载来发现类。
composer 的安装方式这里就不展示了。
二、正式开始(一)、编写 proto 文件目录结构如下所示
user.proto 文件内容如下
Syntax = "proto3";package user;option go_package="github.com/xhyonline/main/proto/user";import "basic/basic.proto";message User { string name =1; int64 Age =2;}service UserService { // 调用 SayHello 方法,不需要传参,但是由于入参和返回必须是个 message 类型 // 因此我们可以把它拆出来 rpc SayHello(basic.Empty) returns (basic.Empty); rpc AddUser(User) returns (User);} basic.proto 文件如下
Syntax = "proto3";package basic;option go_package="github.com/xhyonline/main/proto/basic";message Empty {}(二)、编译服务端文件然后在 proto 目录下执行如下命令,用于编译 user 模块下与 basic 模块下的 proto 文件 (**请注意:我非常建议你切换到 proto 目录下 ,否则会因为路径依赖问题导致编译失败 **,)
protoc --go_out=plugins=grpc,paths=source_@R_403_4614@:. ./user/*.protoprotoc --go_out=plugins=grpc,paths=source_@R_403_4614@:. ./basic/*.proto经过上面两个命令,我们就能生成如下述所示的两个文件
(三)、编写服务端文件:main.go
package mainimport ( "fmt" "github.com/xhyonline/main/proto/basic" "github.com/xhyonline/main/proto/user" "context" "Google.golang.org/grpc" "log" "net")type User struct {}// 实现 proto 文件中 SayHello 的接口func (s *User) SayHello (ctx context.Context, in *basic.Empty) (*basic.Empty,error){ fmt.Println("你好世界") return nil,nil}// 实现 proto 文件中 AddUser 的接口func (s *User) AddUser(ctx context.Context,user *user.User)(*user.User ,error){ fmt.Printf("新增一个用户的基本信息是 %+v\n",user) user.name="强行修改了用户的名字" return user,nil}func main() { // 实例化一个 grpc 服务 g := grpc.NewServer() // 绑定 user.RegisterUserServiceServer(g,new(User)) // grpc 监听在 8080 端口 l, err := net.Listen("tcp", "0.0.0.0:8080") if err != nil { log.Fatal(err) } // 服务启动 err=g.Serve(l) if err!=nil { panic(err) }}使用 go run main.go 启动服务端
(四)、编译客户端文件幸运的是 PHP 编译 proto 文件其实不用装类似于 protoc-gen-go 这种 Go扩展,他可以直接通过命令就可以编译。
先看 PHP 项目的目录结构(请注意 gen 目录此时还为空)
执行命令:编译出 PHP 文件 (与Go编译一样,请注意路径,我都是切换到 proto 目录下进行编译)
先编译 user 模块
protoc --PHP_out=. ./user/*.proto再编译 basic 模块
protoc --PHP_out=. ./basic/*.proto编译后,生成的文件如下所示
为了养成编码规范,我比较喜欢将文件分开存放,因此上面的 gen 目录在此就派上了用场,迁移生成好的文件如下所示。
其实也就是将 proto/user 目录下编译的文件放到 gen/user 中,将 basic 目录下编译的文件,放到 gen/basic 中,最后一个公共目录 GPBMetadata 也将它迁移至 gen 目录下。
首先,我们先需要使用 composer init 在根目录下生成 composer.Json 文件,其次我们还需依赖几个库。
分别是: "grpc/grpc": "^v1.3.0" 与 "Google/protobuf": "^v3.3.0"
其次我们要把刚生成的PHP文件添加到 composer 中,使其自动加载
{ "name": "edz/PHP", "authors": [ { "name": "兰陵美酒郁金香", "email": "383164014@qq.com" } ], "require": { "grpc/grpc": "^v1.3.0", "Google/protobuf": "^v3.3.0" }, "autoload":{ "psr-4":{ "GPBMetadata\": "gen/GPBMetadata/", "User\":"gen/user/", "Basic\":"gen/basic/" } }}执行 composer install 安装扩展
autoload 解释:
psr-4 是一个自动加载的规范,我们拿上述文件中的 "User\":"gen/user/" 举例:User 代表它的命名空间, gen/User/代表该命名空间的真实路径。因此如果我们下次在index.PHP文件中引用了 vendor/autoload.PHP 文件后,就可以直接使用 \User\类名::静态方法() 的方式调用了。
再插一嘴 : 在 composer 中的 autoload 区域更新类的配置信息,需要 composer dump-autoload,否则类加载不到。
其次我们要编写客户端文件,因此我们需要在 gen/user/目录下再新建一个 UserClIEnt.PHP
编写内容如下
<?PHPnamespace User;class UserClIEnt extends \Grpc\BaseStub{ public function __construct($hostname, $opts, $channel = null) { parent::__construct($hostname, $opts, $channel); } // 编写 AddUser 方法 public function AddUser(\User\User $argument,$Metadata=[],$options=[]){ // user.UserService/AddUser 是请求了服务端对应的方法 // 格式: proto 对应的包名.service 服务名/服务中的方法名 return $this->_simpleRequest('user.UserService/AddUser', $argument, // \User\User 是返回参数,proto文件编译后,自动生成了这个类型,由于 composer autoload 的存在,我们可 // 以直接加载到 \User\User 类,这个类有点类似于 Golang 的结构体(讲道理其实就是.....) ['\User\User', 'decode'], $Metadata, $options); } // 编写 SayHello 方法 public function SayHello(\Basic\PBEmpty $argument,$Metadata=[],$options=[]){ // user.UserService/SayHello 调用了proto 中 user包下的UserService 中的 SayHello 方法 return $this->_simpleRequest('user.UserService/SayHello', $argument, // \User\User 是返回参数 ['\Basic\PBEmpty', 'decode'], $Metadata, $options); }}然后开始编写 index.PHP 入口代码
<?PHPrequire_once 'vendor/autoload.PHP';// 由于我们在 composer.Json 中定义了 autoload ==> "User\":"gen/user/",// 因此它在看到 User 这个命名空间后,会自动去 gen/user 目录下寻找 UserClIEnt 类$clIEnt=new \User\UserClIEnt("127.0.0.1:8080",[ 'credentials' => \Grpc\ChannelCredentials::createInsecure()]);//实例化 TestRequest 请求类$request = new \User\User();$request->setAge(24);$request->setname("小陈");// 调用远程服务$get = $clIEnt->AddUser($request)->wait();List($reply, $status) = $get;var_dump($reply->getname());$request=new Basic\PBEmpty();// 远程调用 SayHello 方法$clIEnt->SayHello($request);最后执行命令 PHP index.PHP 你就能看到这个效果
总结以上是内存溢出为你收集整理的go-php-grpc-example全部内容,希望文章能够帮你解决go-php-grpc-example所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)