欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

go-micro+php+consul简单的微服实现

程序员文章站 2022-05-22 21:49:45
首先我们用go-micro构建一个服务。(关于go-micro的使用可以参照官方实例或者文档) //新建一个微服务 micro new --type "srv" user-srv 定义我们的服务,这里定义两个rpc服务,Register和User 1 // 修改proto 2 syntax = "p ......

 

首先我们用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,那么我们打开的是

启动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 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项目,打开浏览器输入回车,这时候我们就能看到结果了。

这时候我们会发现一个问题,那就是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
        ];
    }

 

重启服务,这时候然后刷新浏览器试试。这时候一个简单基于go rpc server和php client的微服务就搭建完成了。当然了这时候还没有心跳机制,hyperf官网提供了一个定时器的功能,我们定时去刷服务发现就好了。