README

#介绍 该组件基于hyperf2.0框架，实现了以etcd为服务中心的grpc服务注册,支持于go-micro框架数据交互。

安装组件:

composer require hyperf/grpc-server

#配置： 组件由 config/autoload/services.php 配置文件来驱动，配置文件如下：

return [
 //省略其他配置
 'go_micro_consumers' =>[
 [
 'service_name'=>'userService',
 'path_prefix'=>'/micro/registry',
 'registry' => [
 'protocol' => 'etcd',
 'address' => '127.0.0.1:2379',
 ],
 'protocol' => 'grpc',
 'load_balancer' => 'random',
 'nodes' => [
 ['host' => '127.0.0.1', 'port' => 9504],
 ]
 ],
 ],
]

gRPC server 服务器配置 server.php 文件

'servers' => [
 ....
 [
 'name' => 'grpc',
 'type' => Server::SERVER_HTTP,
 'host' => '0.0.0.0',
 'port' => 9503,
 'sock_type' => SWOOLE_SOCK_TCP,
 'callbacks' => [
 Event::ON_REQUEST => [\Hyperf\GrpcServer\Server::class, 'onRequest'],
 ],
 ],
],

#示例： gRPC server 路由配置： routes.php 文件

Router::addServer('grpc', function () {
 Router::addGroup('/orderService', function () {
 Router::post('/create', 'App\Controller\OrderController@create');
 });
});

新建OrderController.php 文件中的 createOrder 方法:

/**
 * @RpcService(name="orderService", version='latest',protocol="grpc",publishTo="etcd")
 */
public function create(Order $order) 
{
 $message = new OrderReply();
 $message->setMessage("Order created success");
 return $message;
}

.proto 文件中的定义和 gRPC server 路由的对应关系: /{package}.{service}/{rpc}