phpconsul架构,手把手教你搭建Swoole微服务（基于consul和simps框架）

## 安装consul

&＃96;consul&＃96;具体的原理这里不做介绍&＃xff0c;只需要记得consul中有两个角色&＃xff0c;&＃96;server&＃96;和&＃96;client&＃96;&＃xff0c;我们首先需要一个consul的&＃96;server&＃96;集群&＃xff0c;生产环境推荐3台机器以上的consul集群保证高可用&＃xff0c;server集群间采用&＃96;raft&＃96;强一致性算法协调&＃xff0c;&＃96;client&＃96;是性能很高的轻量级进程&＃xff0c;client和server集群间通过&＃96;gossip&＃96;协议同步数据&＃xff0c;我们需要在微服务的&＃96;rpc调用端&＃96;和&＃96;rpc服务端&＃96;的机器上都安装consul的&＃96;client&＃96;。

&＃96;rpc调用端&＃96;通过请求本机的consul&＃96;client&＃96;来&＃96;发现服务&＃96;。

&＃96;rpc服务端&＃96;通过请求本机的consul&＃96;client&＃96;来&＃96;注册服务&＃96;。

这里推荐采用docker来安装&＃96;consul&＃96;。

#### consul server集群安装

&＃96;&＃96;&＃96;bash

一. docker pull consul

#CONSUL_BIND_INTERFACE 是内网的网卡名&＃xff0c;consul服务将绑定到这个网卡上

#server&＃61;true 表示这个consul进程是server角色

#bootstrap-expect&＃61;1 表示只需要1个server就可以对外提供服务&＃xff0c;推荐3个&＃xff0c;我这里为了演示写1

二. docker run -d --name&＃61;consul1 --net&＃61;host -e CONSUL_BIND_INTERFACE&＃61;eth0 consul agent --server&＃61;true --bootstrap-expect&＃61;1 --client&＃61;0.0.0.0 -ui

&＃96;&＃96;&＃96;

#### 在rpc的客户端和服务端安装consul client

&＃96;&＃96;&＃96;bash

一. docker pull consul

#server&＃61;false 表示这是个client进程

#join&＃61;192.168.2.132&＃xff0c;这个ip是consul server那台机器的ip&＃xff0c;由于server是集群部署&＃xff0c;即使这个ip机器宕机&＃xff0c;也会自动选主到新ip

二. docker run -d --name&＃61;client --net&＃61;host -e CONSUL_BIND_INTERFACE&＃61;eth0 consul agent --server&＃61;false --client&＃61;0.0.0.0 -ui -join&＃61;192.168.2.132

&＃96;&＃96;&＃96;

## 安装simps的rpc组件

首先安装swoole扩展&＃xff0c;[参考此文档](https://wiki.swoole.com/#/environment)

安装simps脚手架和rpc组件

&＃96;&＃96;&＃96;php

composer create-project simple-swoole/skeleton

cd skeleton

composer require simple-swoole/rpc-multiplex

&＃96;&＃96;&＃96;

&＃96;rpc-multiplex&＃96;组件采用单连接复用的方式&＃xff0c;不需要连接池&＃xff0c;性能极高&＃xff0c;感谢&＃96;&＃64;李铭昕&＃96;小伙伴的贡献。

## 添加rpc服务端代码

在&＃96;app/Service&＃96;目录下面&＃xff0c;填充你的业务代码

&＃96;&＃96;&＃96;php

namespace App\Service;

class RpcService

{

public function hello(string $name): string

{

return &＃39;Hello &＃39; . $name;

}

}

&＃96;&＃96;&＃96;

在&＃96;config/routes.php&＃96;定义一个&＃96;Health&＃96;接口给consul探活用

&＃96;&＃96;&＃96;php

return [

[&＃39;GET&＃39;, &＃39;/Health&＃39;, function ($request, $response) {

$response->end(&＃39;Im ok&＃39;);//定义健康监测接口给consul调用

}],

];

&＃96;&＃96;&＃96;

## 修改rpc服务端的配置

修改&＃96;config/servers.php&＃96;

&＃96;&＃96;&＃96;php

return [

&＃39;main&＃39; &＃61;> [

&＃39;class_name&＃39; &＃61;> \Swoole\Http\Server::class,

&＃39;ip&＃39; &＃61;> &＃39;0.0.0.0&＃39;,

&＃39;port&＃39; &＃61;> 9501,//主服务用来接收consul的心跳请求

&＃39;sock_type&＃39; &＃61;> SWOOLE_SOCK_TCP,

&＃39;callbacks&＃39; &＃61;> [

&＃39;request&＃39; &＃61;> [\App\Events\Http::class, &＃39;onRequest&＃39;],

&＃39;start&＃39; &＃61;> [Simps\RpcMultiplex\TcpServer::class, &＃39;onStart&＃39;],

&＃39;workerStart&＃39; &＃61;> [Simps\RpcMultiplex\TcpServer::class, &＃39;onWorkerStart&＃39;],

],

&＃39;settings&＃39; &＃61;> [

&＃39;worker_num&＃39; &＃61;> swoole_cpu_num(),

],

&＃39;sub&＃39; &＃61;> [

//定义rpc服务&＃xff0c;注册服务到consul

[

&＃39;callbacks&＃39; &＃61;> [

"receive" &＃61;> [Simps\RpcMultiplex\TcpServer::class, &＃39;onReceive&＃39;],

],

&＃39;port&＃39; &＃61;> 9503,//rpc服务监听9503端口

&＃39;sock_type&＃39; &＃61;> SWOOLE_SOCK_TCP,

//注册到consul时候&＃xff0c;&＃39;0.0.0.0&＃39;默认会拿第一块网卡的ip注册到consul

&＃39;ip&＃39; &＃61;> &＃39;0.0.0.0&＃39;,

//服务名称

&＃39;service_name&＃39; &＃61;> [&＃39;rpc1&＃39;,&＃39;rpc2&＃39;],

//有&＃96;consul&＃96;配置的时候会自动注册到consul

&＃39;consul&＃39; &＃61;> [

&＃39;publish_to&＃39; &＃61;> &＃39;http://127.0.0.1:8500&＃39;, //本机的consul client地址

"checks" &＃61;> [

[

"name" &＃61;> "rpc1",

"http" &＃61;> "http://127.0.0.1:9501/Health", //consul请求这个地址 连通就证明服务可用&＃xff0c;checks的更多配置请参考consul官方文档。

"interval" &＃61;> "5s",

],

[

"name" &＃61;> "rpc2",

"http" &＃61;> "http://127.0.0.1:9501/Health", //consul请求这个地址 连通就证明服务可用&＃xff0c;checks的更多配置请参考consul官方文档。

"interval" &＃61;> "5s",

]

]

],

&＃39;settings&＃39; &＃61;> [

// 以下参数不允许修改

&＃39;open_length_check&＃39; &＃61;> true,

&＃39;package_length_type&＃39; &＃61;> &＃39;N&＃39;,

&＃39;package_length_offset&＃39; &＃61;> 0,

&＃39;package_body_offset&＃39; &＃61;> 4,

&＃39;package_max_length&＃39; &＃61;> 1024 * 1024 * 2,

],

],

]

]

];

&＃96;&＃96;&＃96;

## 添加rpc调用端代码

&＃96;&＃96;&＃96;php

class IndexController

{

public function index($request, $response)

{

$serviceName &＃61; &＃39;rpc1&＃39;;

$consulUri &＃61; &＃39;http://127.0.0.1:8500&＃39;;//本机的consul client地址&＃xff0c;框架会通过这个consul client找到所有可用的机器&＃xff0c;随机找到一台机器进行rpc调用&＃xff0c;如果所有机器都挂了会抛异常

$data &＃61; CallWithConsul::getInstance($serviceName, $consulUri)->call(&＃39;App\Service\RpcService&＃39;, &＃39;hello&＃39;, &＃39;World&＃39;); //call(类名&＃xff0c;方法&＃xff0c;参数)

$response->end(

json_encode(

[

&＃39;method&＃39; &＃61;> $request->server[&＃39;request_method&＃39;],

&＃39;message&＃39; &＃61;> &＃39;Hello Simps. &＃39; . $data->getResult(),

]

)

);

}

}

&＃96;&＃96;&＃96;

## 微服务其他东西

当然微服务是个很大的话题&＃xff0c;这里只解决了服务发现和注册&＃xff0c;还有服务监控&＃xff0c;限流等&＃xff0c;监控这里推荐专门针对php的监控产品 [Swoole Tracker](https://business.swoole.com/tracker/index)