consul具体的原理这里不做介绍，只需要记得consul中有两个角色，server和client，我们首先需要一个consul的server集群，生产环境推荐3台机器以上的consul集群保证高可用，server集群间采用raft强一致性算法协调，client是性能很高的轻量级进程，client和server集群间通过gossip协议同步数据，我们需要在微服务的rpc调用端和rpc服务端的机器上都安装consul的client。
rpc调用端通过请求本机的consulclient来发现服务。
rpc服务端通过请求本机的consulclient来注册服务。
这里推荐采用docker来安装consul。
一. docker pull consul
#CONSUL_BIND_INTERFACE 是内网的网卡名，consul服务将绑定到这个网卡上
#server=true 表示这个consul进程是server角色
#bootstrap-expect=1 表示只需要1个server就可以对外提供服务，推荐3个，我这里为了演示写1
二. docker run -d --name=consul1 --net=host -e CONSUL_BIND_INTERFACE=eth0 consul agent --server=true --bootstrap-expect=1 --client=0.0.0.0 -ui一. docker pull consul
#server=false 表示这是个client进程
#join=192.168.2.132，这个ip是consul server那台机器的ip，由于server是集群部署，即使这个ip机器宕机，也会自动选主到新ip
二. docker run -d --name=client --net=host -e CONSUL_BIND_INTERFACE=eth0 consul agent --server=false --client=0.0.0.0 -ui -join=192.168.2.132首先安装swoole扩展，参考此文档
安装simps脚手架和rpc组件
composer create-project simple-swoole/skeleton
cd skeleton
composer require simple-swoole/rpc-multiplexrpc-multiplex组件采用单连接复用的方式，不需要连接池，性能极高，感谢@李铭昕小伙伴的贡献。
在app/Service目录下面，填充你的业务代码
namespace App\Service;
class RpcService
{
public function hello(string $name): string
{
return 'Hello ' . $name;
}
}在config/routes.php定义一个Health接口给consul探活用
return [
['GET', '/Health', function ($request, $response) {
$response->end('Im ok');//定义健康监测接口给consul调用
}],
];修改config/servers.php
<?php
return [
'main' => [
'class_name' => \Swoole\Http\Server::class,
'ip' => '0.0.0.0',
'port' => 9501,//主服务用来接收consul的心跳请求
'sock_type' => SWOOLE_SOCK_TCP,
'callbacks' => [
'request' => [\App\Events\Http::class, 'onRequest'],
'start' => [Simps\RpcMultiplex\TcpServer::class, 'onStart'],
'workerStart' => [Simps\RpcMultiplex\TcpServer::class, 'onWorkerStart'],
],
'settings' => [
'worker_num' => swoole_cpu_num(),
],
'sub' => [
//定义rpc服务，注册服务到consul
[
'callbacks' => [
"receive" => [Simps\RpcMultiplex\TcpServer::class, 'onReceive'],
],
'port' => 9503,//rpc服务监听9503端口
'sock_type' => SWOOLE_SOCK_TCP,
//注册到consul时候，'0.0.0.0'默认会拿第一块网卡的ip注册到consul
'ip' => '0.0.0.0',
//服务名称
'service_name' => ['rpc1','rpc2'],
//有`consul`配置的时候会自动注册到consul
'consul' => [
'publish_to' => 'http://127.0.0.1:8500', //本机的consul client地址
"checks" => [
[
"name" => "rpc1",
"http" => "http://127.0.0.1:9501/Health", //consul请求这个地址 连通就证明服务可用，checks的更多配置请参考consul官方文档。
"interval" => "5s",
],
[
"name" => "rpc2",
"http" => "http://127.0.0.1:9501/Health", //consul请求这个地址 连通就证明服务可用，checks的更多配置请参考consul官方文档。
"interval" => "5s",
]
]
],
'settings' => [
// 以下参数不允许修改
'open_length_check' => true,
'package_length_type' => 'N',
'package_length_offset' => 0,
'package_body_offset' => 4,
'package_max_length' => 1024 * 1024 * 2,
],
],
]
]
];
class IndexController
{
public function index($request, $response)
{
$serviceName = 'rpc1';
$consulUri = 'http://127.0.0.1:8500';//本机的consul client地址，框架会通过这个consul client找到所有可用的机器，随机找到一台机器进行rpc调用，如果所有机器都挂了会抛异常
$data = CallWithConsul::getInstance($serviceName, $consulUri)->call('App\Service\RpcService', 'hello', 'World'); //call(类名，方法，参数)
$response->end(
json_encode(
[
'method' => $request->server['request_method'],
'message' => 'Hello Simps. ' . $data->getResult(),
]
)
);
}
}当然微服务是个很大的话题，这里只解决了服务发现和注册，还有服务监控，限流等，监控这里推荐专门针对php的监控产品 Swoole Tracker