PHP   发布时间:2022-04-04  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了go-micro+php+consul实现简单的微服务大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

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

首先我们用go-micro构建一个服务。(关于go-micro的使用可以参照官方实例或者文档)

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

定义我们的服务,这里定义两个rpc服务,Register和User

// 修改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;
}

然后生成执行下面命令我们就可以发现在proto文件多出两个文件。这个proto为我们生成的,后面会用到。

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

写我们的业务逻辑,修改handle/user.go文件

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 < int(req.Count); i++ {
        log.Logf("Responding: %d", i)
        if err := stream.Send(&user.StreamingResponse{
            Count: int64(i),
        }); err != nil {
            return err
        }
    }

    return nil
}

// PingPong is a bidirectional stream handler called via client.Stream or the generated client code
func (e *User) PingPong(ctx context.Context, stream user.user_PingPongStream) error {
    for {
        req, err := stream.Recv()
        if err != nil {
            return err
        }
        log.Logf("Got ping %v", req.stroke)
        if err := stream.Send(&user.Pong{stroke: req.stroke}); err != nil {
            return err
        }
    }
}

最后修改我们的main.go文件,服务发现使用时consul。

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做微服务发现,当然首先你需要安装consul

启动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文件

namespace App\Grpc;


use Go\Micro\Srv\User\Registerrequest;
use Go\Micro\Srv\User\UserInfo;
use Hyperf\GrpcClient\BaseClient;

class UserClient extends BaseClient
{
    public function Register(Registerrequest $argument)
    {
        return $this->simplerequest(
            '/user.User/Register',
            $argument,
            [UserInfo::class, 'decode']
        );
    }

关于这一块的代码,其实官方文档写得特别详细,具体可以参照官方文档。

新建一个路由

Router::addRoute(['GET', 'poST', 'HEAD'], '/grpc', 'App\Controller\IndexController@grpc');

编写控制器

public function grpc ()
{

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

这时候还需要吧根目录下的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等,在实例化话的时候需要穿一个客户端过去。下面提供一个简单的实例。

<?PHP
declare(Strict_types=1);

namespace App\Register;

use Hyperf\Consul\Health;
use Psr\Container\ContainerInterface;
use Hyperf\Guzzle\ClientFactory;

class Consulservices
{

    public $servers;
    private $container;


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

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

这时候发现一个问题如果每次请求过来都去请求一次必然给consul造成很大的负荷。既然用到了swoole框架可以在每次swoole启动的时候去请求一次,然后把服务发现的信息存起来。修改配置文件server。

'callBACks' => [
//        SwooleEvent::ON_BEFORE_START => [Hyperf\Framework\Bootstrap\ServerStartCallBACk::class, 'beforeStart'],
        SwooleEvent::ON_BEFORE_START => [\App\Bootstrap\ServerStartCallBACk::class, 'beforeStart'],
        SwooleEvent::ON_WORKER_START => [Hyperf\Framework\Bootstrap\WorkerStartCallBACk::class, 'onWorkerStart'],
        SwooleEvent::ON_PIPE_messaGE => [Hyperf\Framework\Bootstrap\PipemessageCallBACk::class, 'onPipemessage'],
    ],
可以在ServerStartCallBACk类里面请求consul进行服务发现 后面拿到参数就好了。

namespace App\Bootstrap;
use App\Register\Consulservices;
class ServerStartCallBACk
{
    public function beforeStart()
    {
        $container = \Hyperf\Utils\ApplicationContext::getContainer();
        $container->get(Consulservices::class)->getServers();
    }
}

改造一下原来的控制器

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官网提供了一个定时器的功能,我们定时去刷服务发现就好了。

大佬总结

以上是大佬教程为你收集整理的go-micro+php+consul实现简单的微服务全部内容,希望文章能够帮你解决go-micro+php+consul实现简单的微服务所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签: