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

//新建一个微服务
micro new --type "srv" user-srv

// 修改proto
syntax = "proto3";

package go.micro.srv.user;

service user {
    rpc register(registerrequest) returns (userinfo) {}
    rpc user(userinforequest) returns (userinfo) {}
    rpc stream(streamingrequest) returns (stream streamingresponse) {}
    rpc pingpong(stream ping) returns (stream pong) {}
}


message userinforequest {
    int64 userid  = 1;
}

message registerrequest {
    string username  = 1;
    string email     = 2;
    string password  = 3;
}

message userinfo {
    int64  id       =  1;
    string username =  2;
    string email    =  3;
}



message streamingrequest {
    int64 count = 1;
}

message streamingresponse {
    int64 count = 1;
}

message ping {
    int64 stroke = 1;
}

message pong {
    int64 stroke = 1;
}

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

type user struct{}

// call is a single request handler called via client.call or the generated client code
func (e *user) register(ctx context.context, req *user.registerrequest, rsp *user.userinfo) error {
    log.log("received user.register request")
    rsp.id    = 1
    rsp.email = req.email
    rsp.username = req.username
    return nil
}


func (e *user) user(ctx context.context, req *user.userinforequest, rsp *user.userinfo) error {
    log.log("received user.register request")
    rsp.id    = 1
    rsp.email = "741001560@qq.com"
    rsp.username = "chensi"
    return nil
}

// stream is a server side stream handler called via client.stream or the generated client code
func (e *user) stream(ctx context.context, req *user.streamingrequest, stream user.user_streamstream) error {
    log.logf("received user.stream request with count: %d", req.count)

    for i := 0; i <p> </p><p>最后修改我们的main.go文件，服务发现使用时consul。</p><pre class="brush:php;toolbar:false">func main() {
    //initcfg()
    // new service

    micreg := consul.newregistry()

    service := micro.newservice(
        micro.server(s.newserver()),
        micro.name("go.micro.srv.user"),
        micro.version("latest"),
        micro.registry(micreg),
    )

    // initialise service
    service.init()

    // run service
    if err := service.run(); err != nil {
        log.fatal(err)
    }
}

consul agent -dev  -client 0.0.0.0 -ui

protoc --php_out=plugins=grpc:../grpc user.proto

namespace appgrpc;


use gomicrosrvuserregisterrequest;
use gomicrosrvuseruserinfo;
use hyperfgrpcclientbaseclient;

class userclient extends baseclient
{
    public function register(registerrequest $argument)
    {
        return $this->simplerequest(
            '/user.user/register',
            $argument,
            [userinfo::class, 'decode']
        );
    }

public function grpc ()
{

        $client = new appgrpcuserclient('127.0.0.1:9527', [
            '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
        ];
    }

```

// psr-4 下面新增两个行
"autoload": {
        "psr-4": {
            "app\": "app/",
            "gpbmetadata\": "grpc/gpbmetadata",
            "go\": "grpc/go"
        },
        "files": []
    }

<?php declare(strict_types=1);

namespace appregister;

use hyperfconsulhealth;
use psrcontainercontainerinterface;
use hyperfguzzleclientfactory;

class consulservices
{

    public $servers;
    private $container;


    public function __construct(containerinterface $container)
    {
        $this->container = $container;
    }

    public function getservers()
    {
        $health = new health(function ()  {
            return $this-&gt;container-&gt;get(clientfactory::class)-&gt;create([
                'base_uri' =&gt; 'http://127.0.0.1:8500',
            ]);
        });
        $resp = $health-&gt;service("go.micro.srv.user");
        $servers = $resp-&gt;json();
        if (empty($servers)){
            $this-&gt;servers = [];
        }
        foreach ($servers as $server) {
            $this-&gt;servers[] = sprintf("%s:%d",$server['service']['address'],$server['service']['port']);
        }
    }
}

'callbacks' => [
//        swooleevent::on_before_start => [hyperfframeworkbootstrapserverstartcallback::class, 'beforestart'],
        swooleevent::on_before_start => [appbootstrapserverstartcallback::class, 'beforestart'],
        swooleevent::on_worker_start => [hyperfframeworkbootstrapworkerstartcallback::class, 'onworkerstart'],
        swooleevent::on_pipe_message => [hyperfframeworkbootstrappipemessagecallback::class, 'onpipemessage'],
    ],
可以在serverstartcallback类里面请求consul进行服务发现 后面拿到参数就好了。

namespace appbootstrap;
use appregisterconsulservices;
class serverstartcallback
{
    public function beforestart()
    {
        $container = hyperfutilsapplicationcontext::getcontainer();
        $container->get(consulservices::class)->getservers();
    }
}

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
        ];
    }