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

牛角包 發表於 2019-11-7 14:13:00

<div>
首先我们用go-micro构建一个服务。（关于go-micro的使用可以参照官方实例或者文档）
<div class="highlight">
<div class="cnblogs_code">
<pre>//新建一个微服务
micro new --type "srv" user-srv</pre>
</div>
 
<pre>定义我们的服务，这里定义两个rpc服务，Register和User</pre>
</div>
<div class="highlight">
<div class="cnblogs_code">
<pre> 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 int64id =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 }</pre>
</div>
 
</div>
然后生成执行下面命令我们就可以发现在proto文件中多出两个文件。这个proto为我们生成的，后面会用到。
<div class="highlight">
<div class="cnblogs_code">
<pre>protoc --proto_path=${GOPATH}/src:. --micro_out=. --go_out=. proto/user/user.proto</pre>
</div>
 
</div>
写我们的业务逻辑，修改handle/user.go文件
<div class="highlight">
<div class="cnblogs_code">
<pre> 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</pre>
</div>
 
</div>
最后修改我们的main.go文件，服务发现使用时consul。
<div class="highlight">
<div class="cnblogs_code">
<pre> 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</pre>
</div>
 
</div>
我们使用consul做微服务发现，当然首先你需要安装consul
<div class="highlight">
<div class="cnblogs_code">
<pre>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/</pre>
</div>
 
</div>
启动consul的时候由于在是本地虚拟机上面，所以我们可以简单处理
<div class="highlight">
<div class="cnblogs_code">
<pre>consul agent -dev-client 0.0.0.0 -ui</pre>
</div>
 
</div>
这时候可以启动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的目录之下。然后在目录下执行命令
<div class="highlight">
<div class="cnblogs_code">
<pre>protoc --php_out=plugins=grpc:../grpc user.proto</pre>
</div>
 
</div>
执行成功之后会发现在grpc目录下多出两个文件夹。
接下来我们开始编写client的代码，在hyperf项目的app目录下新建一个Grpc的目录并且新建一个UserClient.php的文件
<div class="highlight">
<div class="cnblogs_code">
<pre> 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
16 );
17 }
18 </pre>
</div>
 
</div>
关于这一块的代码，其实官方文档写得特别详细，具体可以参照官方文档。
新建一个路由
<div class="highlight">
<div class="cnblogs_code">
<pre>Router::addRoute(['GET', 'POST', 'HEAD'], '/grpc', 'App\Controller\IndexController@grpc');</pre>
</div>
</div>
编写控制器
<div class="highlight">
<div class="cnblogs_code">
<pre> 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 }</pre>
</div>
 
</div>
这时候还需要吧根目录下的grpc目录加载进来。修改composer.json文件
<div class="cnblogs_code">
<pre>```

// psr-4 下面新增两个行
"autoload": {
 "psr-4": {
 "App\\": "app/",
 "GPBMetadata\\": "grpc/GPBMetadata",
 "Go\\": "grpc/Go"
 },
 "files": []
}</pre>
</div>
 
然后执行composer dump-autoload命令。然后启动hyperf项目，打开浏览器输入http://192.168.10.100:9501/grpc回车，这时候我们就能看到结果了。
这时候我们会发现一个问题，那就是consul在client端压根没用到，在代码中我们还是需要指明我们的端口号。然后再看看官方文档其实是支持consul的，那么将代码改造下。
在app下新建一个Register的目录创建一个文件ConsulServices.php，然后开始编写服务发现的代码，安装consul包以后，由于官方提供的consul包没有文档所以需要自己去看源代码。官方在consul提供的api上面做了简单的封装，如KV、Health等，在实例化话的时候需要穿一个客户端过去。下面提供一个简单的实例。
<div class="highlight">
<div class="cnblogs_code">
<pre> 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 }</pre>
</div>
 
</div>
这时候发现一个问题如果每次请求过来都去请求一次必然给consul造成很大的负荷。既然用到了swoole框架可以在每次swoole启动的时候去请求一次，然后把服务发现的信息存起来。修改配置文件server。
<div class="highlight">
<div class="cnblogs_code">
<pre> 1 'callbacks' => [
 2 // SwooleEvent::ON_BEFORE_START => ,
 3 SwooleEvent::ON_BEFORE_START => [\App\Bootstrap\ServerStartCallback::class, 'beforeStart'],
 4 SwooleEvent::ON_WORKER_START => ,
 5 SwooleEvent::ON_PIPE_MESSAGE => ,
 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 }</pre>
</div>
 
</div>
 
改造一下原来的控制器
<div class="highlight">
<div class="cnblogs_code">
<pre>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
 ];
}</pre>
</div>
 
</div>
重启服务，这时候然后刷新浏览器试试。这时候一个简单基于go rpc server和php client的微服务就搭建完成了。当然了这时候还没有心跳机制，hyperf官网提供了一个定时器的功能，我们定时去刷服务发现就好了。
</div> 
来源：https://www.cnblogs.com/a609251438/p/11811761.html

頁: [1]

琼殿技术论坛's Archiver

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