go-micro+php+consul簡單的微服實現

時間 2019-11-07

標籤 micro+php+consul micro php consul 簡單微服實現欄目 PHP 简体版

原文原文鏈接

首先咱們用go-micro構建一個服務。（關於go-micro的使用能夠參照官方實例或者文檔）php

//新建一個微服務
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爲咱們生成的，後面會用到。linux

protoc --proto_path=${GOPATH}/src:. --micro_out=. --go_out=. proto/user/user.proto

寫咱們的業務邏輯，修改handle/user.go文件json

 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。api

 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的時候因爲在是本地虛擬機上面，因此咱們能夠簡單處理swoole

consul agent -dev  -client 0.0.0.0 -ui

這時候能夠啓動consul的ui了，我本地vagrant的虛擬機192.168.10.100，那麼咱們打開的是http://192.168.10.100:8500/ui/dc1/servicesphp7

啓動user-srv的服務發現consul裏面出現 go.micro.srv.user 的服務註冊信息了app

下面來寫hyperf的代碼了。按照官方文檔安裝框架，安裝的時候rpc須要選擇grpc，須要注意的是你的系統上面須要安裝php7.2以上的版本，swoole版本也須要4.3的版本以上，我用的是最新homestead，因此相對而言安裝這些依賴比較簡單，因此在此強烈推薦。composer

第一次啓動時候官方會要求修改一些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 App\Grpc;
 2 
 3 
 4 use Go\Micro\Srv\User\RegisterRequest;
 5 use Go\Micro\Srv\User\UserInfo;
 6 use Hyperf\GrpcClient\BaseClient;
 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', 'App\Controller\IndexController@grpc'); 
  

編寫控制器

 1 public function grpc ()
 2 {
 3 
 4         $client = new \App\Grpc\UserClient('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 \Grpc\HiReply $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 App\Register;
 5 
 6 use Hyperf\Consul\Health;
 7 use Psr\Container\ContainerInterface;
 8 use Hyperf\Guzzle\ClientFactory;
 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 => [Hyperf\Framework\Bootstrap\ServerStartCallback::class, 'beforeStart'],
 3         SwooleEvent::ON_BEFORE_START => [\App\Bootstrap\ServerStartCallback::class, 'beforeStart'],
 4         SwooleEvent::ON_WORKER_START => [Hyperf\Framework\Bootstrap\WorkerStartCallback::class, 'onWorkerStart'],
 5         SwooleEvent::ON_PIPE_MESSAGE => [Hyperf\Framework\Bootstrap\PipeMessageCallback::class, 'onPipeMessage'],
 6     ],
 7 能夠在ServerStartCallback類裏面請求consul進行服務發現 後面拿到參數就行了。
 8 
 9 namespace App\Bootstrap;
10 
11 use App\Register\ConsulServices;
12 
13 class ServerStartCallback
14 {
15     public function beforeStart()
16     {
17         $container = \Hyperf\Utils\ApplicationContext::getContainer();
18         $container->get(ConsulServices::class)->getServers();
19     }
20 }

改造一下原來的控制器

public function grpc ()
{

        $container = \Hyperf\Utils\ApplicationContext::getContainer();
        $servers = $container->get(ConsulServices::class)->servers;
        if (empty($servers)) {
            return [
                'errCode' => 1000,
                'msg'     => '服務不存在',
            ];
        }
        $key = array_rand($servers,1); // 哈哈哈一個簡單的負載均衡
        $hostname = $servers[$key];
        $client = new \App\Grpc\UserClient($hostname, [
            'credentials' => null,
        ]);
        $request = new RegisterRequest();
        $request->setEmail("741001560@qq.com");
        $request->setUsername("chensi");
        $request->setPassword("123456");

        /**
         * @var \Grpc\HiReply $reply
         */
        list($reply, $status) = $client->Register($request);

        $message = $reply->getId();
        return [
            'id' => $message
        ];
    }