/grpc-protobuf

Implement rpc byprotobuf and stream in PHP !!!

Primary LanguagePHP

gRPC+protobuf的调试

protobuf： 谷歌出品的rpc序列化+反序列化的工具，能较高性能的数据交换，与thrift、avro这类属于同类型产品； 同时客户端和服务端都遵循IDL约定，同时需要proto编译工具的提前支持。

gRPC: 谷歌出品的rpc解决方案，默认是依托于protobuf协议；

特性

  1. 基于protobuf，针对消息进行了编码/解码；
  2. 基于composer包方式管控，容易引入到项目中；
  3. 目录结构清晰，职责功能分清;
  4. 串行化的Rpc调用，仅做到了连接复用（后期需要改进的一个点）；

准备工作

1、安装protoc编译器：https://github.com/google/protobuf

2. RPC目录结构说明：

  • 客户端相关；
  • 异常管控；
  • Protobuf相关(Idl、Request、Response响应等)；
  • 模拟RPC服务调试；
  • 传输方式基于(Stream|Socket)等； 
     src/
 └── Rpc
     ├── Autoloader.php
     ├── Client
     │   └── RpcClient.php
     ├── Exceptions		
     │   ├── ClientException.php
     │   ├── MessageException.php
     │   ├── RpcException.php
     │   └── TransportException.php
     ├── Message
     │   ├── InterfaceMessageBox.php
     │   └── SoaMessageBox.php
     ├── Protobuf
     │   ├── GPBMetadata
     │   │   ├── Request.php
     │   │   └── Response.php
     │   ├── Idl
     │   │   ├── Request.proto
     │   │   └── Response.proto
     │   └── Message
     │       └── Payload
     │           ├── Request_Header.php
     │           ├── Request.php
     │           ├── Response_Header.php
     │           └── Response.php
     ├── Response
     ├── Server
     │   └── StreamServerDemon.php
     └── Transport
         ├── Http
         │   └── HttpTransport.php
         ├── InterfaceTransport.php
         ├── Socket
         └── Stream
             ├── SoaStreamTransport.php
             └── StreamTransport.php

3. 执行相关protoc文件的编译（由于只用到到Request.proto和Response.proto，做了预编译，此步骤可以忽略）：

$ cd src/Rpc/Protobuf/
$ protoc -I Idl/ --php_out=. Request.proto Response.proto

4. 调试

模拟起一个RPC服务端，提供数据接收和响应

  1. 启动模拟的rpc server:
vagrant@homestead:~/www/open-platform/grpc-protobuf/public$ php server.php 
LISTEN ON : [ tcp://0.0.0.0:43217 ]
CLIENT FROM: [ 127.0.0.1:57774 ] 
CLIENT FROM: [ 127.0.0.1:57778 ] 
CLIENT FROM: [ 127.0.0.1:57782 ]
  1. 配置域名、请求后解析得到
# rpc protobuf
192.168.10.10  rpc-protobuf.net
  1. web客户端环境配置好（基于vagrant的需要提前做好相关web的部署）
  2. 请求输出
/home/vagrant/www/open-platform/grpc-protobuf/public/index.php:49:
array (size=2)
  'header' => 
    array (size=4)
      'code' => int 200
      'msg' => string 'hi, man' (length=7)
      'mid' => string '1' (length=1)
      'success' => boolean true
  'body' => 
    array (size=2)
      'data' => 
        array (size=3)
          'id' => int 999
          'username' => string 'terry' (length=5)
          'email' => string 'tkstorm@163.com' (length=15)
      'status' => int 200

相关服务

Socket 服务

  • 端口监听脚本：
    • watch -n 1 'netstat -an|grep -E "4321[0-9]"'
    • while true;do netstat -an|grep -E "4321[0-9]"; echo "----------"; sleep 2; done
  • 服务端执行：php public/server.php，开启43210端口；
  • 客户端执行：telnet localhost 43210；

待办

  • 集成到Laravel框架中；
  • 增加Log部分；
  • grpc对接；
  • 连接池以及NIO等相关信息；