首先我们用go-micro构建一个服务。（关于go-micro的使用可以参照官方实例或者文档）
//新建一个微服务 micro new --type "srv" user-srv
定义我们的服务，这里定义两个rpc服务，Register和User
1 // 修改proto 2 syntax = "proto3"; 3 4 package go.micro.srv.user; 5 6 service User { 7 rpc Register(RegisterRequest) returns (UserInfo) {} 8 rpc User(UserInfoRequest) returns (UserInfo) {} 9 rpc Stream(StreamingRequest) returns (stream StreamingResponse) {} 10 rpc PingPong(stream Ping) returns (stream Pong) {} 11 } 12 13 14 message UserInfoRequest { 15 int64 userId = 1; 16 } 17 18 message RegisterRequest { 19 string username = 1; 20 string email = 2; 21 string password = 3; 22 } 23 24 message UserInfo { 25 int64 id = 1; 26 string username = 2; 27 string email = 3; 28 } 29 30 31 32 message StreamingRequest { 33 int64 count = 1; 34 } 35 36 message StreamingResponse { 37 int64 count = 1; 38 } 39 40 message Ping { 41 int64 stroke = 1; 42 } 43 44 message Pong { 45 int64 stroke = 1; 46 }
然后生成执行下面命令我们就可以发现在proto文件中多出两个文件。这个proto为我们生成的，后面会用到。
protoc --proto_path=${GOPATH}/src:. --micro_out=. --go_out=. proto/user/user.proto
写我们的业务逻辑，修改handle/user.go文件
1 type User struct{} 2 3 // Call is a single request handler called via client.Call or the generated client code 4 func (e *User) Register(ctx context.Context, req *user.RegisterRequest, rsp *user.UserInfo) error { 5 log.Log("Received User.Register request") 6 rsp.Id = 1 7 rsp.Email = req.Email 8 rsp.Username = req.Username 9 return nil 10 } 11 12 13 func (e *User) User(ctx context.Context, req *user.UserInfoRequest, rsp *user.UserInfo) error { 14 log.Log("Received User.Register request") 15 rsp.Id = 1 16 rsp.Email = "741001560@qq.com" 17 rsp.Username = "chensi" 18 return nil 19 } 20 21 // Stream is a server side stream handler called via client.Stream or the generated client code 22 func (e *User) Stream(ctx context.Context, req *user.StreamingRequest, stream user.User_StreamStream) error { 23 log.Logf("Received User.Stream request with count: %d", req.Count) 24 25 for i := 0; i < int(req.Count); i++ { 26 log.Logf("Responding: %d", i) 27 if err := stream.Send(&user.StreamingResponse{ 28 Count: int64(i), 29 }); err != nil { 30 return err 31 } 32 } 33 34 return nil 35 } 36 37 // PingPong is a bidirectional stream handler called via client.Stream or the generated client code 38 func (e *User) PingPong(ctx context.Context, stream user.User_PingPongStream) error { 39 for { 40 req, err := stream.Recv() 41 if err != nil { 42 return err 43 } 44 log.Logf("Got ping %v", req.Stroke) 45 if err := stream.Send(&user.Pong{Stroke: req.Stroke}); err != nil { 46 return err 47 } 48 } 49 } 50
最后修改我们的main.go文件，服务发现使用时consul。
1 func main() { 2 //initCfg() 3 // New Service 4 5 micReg := consul.NewRegistry() 6 7 service := micro.NewService( 8 micro.Server(s.NewServer()), 9 micro.Name("go.micro.srv.user"), 10 micro.Version("latest"), 11 micro.Registry(micReg), 12 ) 13 14 // Initialise service 15 service.Init() 16 17 // Run service 18 if err := service.Run(); err != nil { 19 log.Fatal(err) 20 } 21 } 22
我们使用consul做微服务发现，当然首先你需要安装consul
wget https://releases.hashicorp.com/consul/1.2.0/consul_1.6.1_linux_amd64.zip unzip consul_1.6.1_linux_amd64.zip mv consul /usr/local/bin/
启动consul的时候由于在是本地虚拟机上面，所以我们可以简单处理
consul agent -dev -client 0.0.0.0 -ui
这时候可以启动consul的ui了，我本地vagrant的虚拟机192.168.10.100，那么我们打开的是http://192.168.10.100:8500/ui/dc1/services
启动user-srv的服务发现consul里面出现 go.micro.srv.user 的服务注册信息了
下面来写hyperf的代码了。按照官方文档安装框架，安装的时候rpc需要选择grpc，需要注意的是你的系统上面需要安装php7.2以上的版本，swoole版本也需要4.3的版本以上，我用的是最新homestead，所以相对而言安装这些依赖比较简单，所以在此强烈推荐。
第一次启动时候官方会要求修改一些php.ini的参数，大家安装要求走就是了。
这部分的流程自己参照官方文档，至于一些扩展的安装可以谷歌或者百度。
安装好框架之后再根目录下面新建一个grpc和proto的目录，把go-micro里面user.proto文件复制到hyperf项目的proto的目录之下。然后在目录下执行命令
protoc --php_out=plugins=grpc:../grpc user.proto
执行成功之后会发现在grpc目录下多出两个文件夹。
接下来我们开始编写client的代码，在hyperf项目的app目录下新建一个Grpc的目录并且新建一个UserClient.php的文件
1 namespace AppGrpc; 2 3 4 use GoMicroSrvUserRegisterRequest; 5 use GoMicroSrvUserUserInfo; 6 use HyperfGrpcClientBaseClient; 7 8 class UserClient extends BaseClient 9 { 10 public function Register(RegisterRequest $argument) 11 { 12 return $this->simpleRequest( 13 '/user.User/Register', 14 $argument, 15 [UserInfo::class, 'decode'] 16 ); 17 } 18
关于这一块的代码，其实官方文档写得特别详细，具体可以参照官方文档。
新建一个路由
Router::addRoute(['GET', 'POST', 'HEAD'], '/grpc', 'AppControllerIndexController@grpc');
编写控制器
1 public function grpc () 2 { 3 4 $client = new AppGrpcUserClient('127.0.0.1:9527', [ 5 'credentials' => null, 6 ]); 7 8 $request = new RegisterRequest(); 9 $request->setEmail("741001560@qq.com"); 10 $request->setUsername("chensi"); 11 $request->setPassword("123456"); 12 13 /** 14 * @var GrpcHiReply $reply 15 */ 16 list($reply, $status) = $client->Register($request); 17 18 $message = $reply->getId(); 19 return [ 20 'id' => $message 21 ]; 22 }
这时候还需要吧根目录下的grpc目录加载进来。修改composer.json文件
``` // psr-4 下面新增两个行 "autoload": { "psr-4": { "App\": "app/", "GPBMetadata\": "grpc/GPBMetadata", "Go\": "grpc/Go" }, "files": [] }
然后执行composer dump-autoload命令。然后启动hyperf项目，打开浏览器输入http://192.168.10.100:9501/grpc回车，这时候我们就能看到结果了。
这时候我们会发现一个问题，那就是consul在client端压根没用到，在代码中我们还是需要指明我们的端口号。然后再看看官方文档其实是支持consul的，那么将代码改造下。
在app下新建一个Register的目录创建一个文件ConsulServices.php，然后开始编写服务发现的代码，安装consul包以后，由于官方提供的consul包没有文档所以需要自己去看源代码。官方在consul提供的api上面做了简单的封装，如KV、Health等，在实例化话的时候需要穿一个客户端过去。下面提供一个简单的实例。
1 <?php 2 declare(strict_types=1); 3 4 namespace AppRegister; 5 6 use HyperfConsulHealth; 7 use PsrContainerContainerInterface; 8 use HyperfGuzzleClientFactory; 9 10 class ConsulServices 11 { 12 13 public $servers; 14 private $container; 15 16 17 public function __construct(ContainerInterface $container) 18 { 19 $this->container = $container; 20 } 21 22 public function getServers() 23 { 24 $health = new Health(function () { 25 return $this->container->get(ClientFactory::class)->create([ 26 'base_uri' => 'http://127.0.0.1:8500', 27 ]); 28 }); 29 $resp = $health->service("go.micro.srv.user"); 30 $servers = $resp->json(); 31 if (empty($servers)){ 32 $this->servers = []; 33 } 34 foreach ($servers as $server) { 35 $this->servers[] = sprintf("%s:%d",$server['Service']['Address'],$server['Service']['Port']); 36 } 37 } 38 }
这时候发现一个问题如果每次请求过来都去请求一次必然给consul造成很大的负荷。既然用到了swoole框架可以在每次swoole启动的时候去请求一次，然后把服务发现的信息存起来。修改配置文件server。
1 'callbacks' => [ 2 // SwooleEvent::ON_BEFORE_START => [HyperfFrameworkBootstrapServerStartCallback::class, 'beforeStart'], 3 SwooleEvent::ON_BEFORE_START => [AppBootstrapServerStartCallback::class, 'beforeStart'], 4 SwooleEvent::ON_WORKER_START => [HyperfFrameworkBootstrapWorkerStartCallback::class, 'onWorkerStart'], 5 SwooleEvent::ON_PIPE_MESSAGE => [HyperfFrameworkBootstrapPipeMessageCallback::class, 'onPipeMessage'], 6 ], 7 可以在ServerStartCallback类里面请求consul进行服务发现 后面拿到参数就好了。 8 9 namespace AppBootstrap; 10 11 use AppRegisterConsulServices; 12 13 class ServerStartCallback 14 { 15 public function beforeStart() 16 { 17 $container = HyperfUtilsApplicationContext::getContainer(); 18 $container->get(ConsulServices::class)->getServers(); 19 } 20 }
改造一下原来的控制器
public function grpc () { $container = HyperfUtilsApplicationContext::getContainer(); $servers = $container->get(ConsulServices::class)->servers; if (empty($servers)) { return [ 'errCode' => 1000, 'msg' => '服务不存在', ]; } $key = array_rand($servers,1); // 哈哈哈一个简单的负载均衡 $hostname = $servers[$key]; $client = new AppGrpcUserClient($hostname, [ 'credentials' => null, ]); $request = new RegisterRequest(); $request->setEmail("741001560@qq.com"); $request->setUsername("chensi"); $request->setPassword("123456"); /** * @var GrpcHiReply $reply */ list($reply, $status) = $client->Register($request); $message = $reply->getId(); return [ 'id' => $message ]; }
重启服务，这时候然后刷新浏览器试试。这时候一个简单基于go rpc server和php client的微服务就搭建完成了。当然了这时候还没有心跳机制，hyperf官网提供了一个定时器的功能，我们定时去刷服务发现就好了。