共计 9146 个字符，预计需要花费 23 分钟才能阅读完成。
在 windows 应用 docker 环境搭建 hyperf 微服务
创立 hyperf 我的项目环境
docker run -d --name hyperfrpc -v d/dataproject/hyperfrpc:/hyperf-skeleton -p 9501:9501 -it --entrypoint /bin/sh hyperf/hyperf:7.4-alpine-v3.11-swoole参数解释：
-d 示意在后盾运行
–name 示意给容器取个名字
-v 示意挂载到本机的目录
-p 示意映射到主机的端口，冒号前的是本机，前面是 docker 容器端口
-it 终端
–entrypoint 通过这个来笼罩 dockerfile 里定义的 entrypoint
镜像容器运行后，而后进入容器中，在容器内装置 Composer
# 下载 composer.phar 文件
wget https://github.com/composer/composer/releases/download/1.8.6/composer.phar
#给 composer.phar 文件加可执行权限
chmod u+x composer.phar
#挪动该文件到 /usr/local/bin/composer
mv composer.phar /usr/local/bin/composer
将 Composer 镜像设置为阿里云镜像，减速国内下载速度
composer config -g repo.packagist composer https://mirrors.aliyun.com/composer
通过 Composer 装置 hyperf/hyperf-skeleton 我的项目
composer create-project hyperf/hyperf-skeleton
进入装置好的 Hyperf 我的项目目录，linux 目录
cd hyperf-skeleton
测试 Hyperf 环境是否胜利
php bin/hyperf.php start
在 powshell 关上一个 cli
docker exec -it hyperfrpc /bin/bash
进行测试
curl 127.0.0.1:9501
看到输入
{"method":"GET","message":"Hello Hyperf."}
环境胜利在 hyperf-skeleton 目录下创立消费者和提供者
删除刚刚创立的 hyperf 我的项目
rm -rf hyperf-skeleton
创立 provider
composer create-project hyperf/hyperf-skeleton hyperf-skeleton/provider
创立时，选项只抉择一个 JSON-PRC with Service Governance，其余都选 n
创立 consumer
cd hyperf-skeleton
复制 provider 为 consumer
cp -r provider consumer
在 windows 应用编辑器编辑 provider
随便应用一个编辑器而后关上我的项目，目录是你创立 docker 容器时挂载的中央，咱们下面挂载了 d /dataproject/hyperfrpc
咱们能够在目录看到存在 provider、consumer
编写 provider
咱们在 app 目录下创立一个文件夹，叫 Rpc，在 Rpc 下创立 CalculatorService 和 CalculatorServiceInterface
服务端口
CalculatorServiceInterface 是服务接口
<?php
namespace AppRpc;
interface CalculatorServiceInterface
{public function add(int $a, int $b);
public function minus(int $a, int $b);
}服务实现类
CalculatorService 就是咱们服务提供者的服务实现类, 咱们只须要服务实现类上增加注解 @RpcService 就能够将服务公布
name，给服务起个名字
protocol，应用的协定，这里个别应用 jsonrpc-http
server，绑定的 server
<?php
namespace AppRpc;
use HyperfRpcServerAnnotationRpcService;
/**
* Class CalculatorService
* @package AppRpc
* @RpcService(name="CalculatorService",protocol="jsonrpc-http",server="jsonrpc-http")
*/
class CalculatorService implements CalculatorServiceInterface
{
public function add(int $a,int $b)
{return $a+$b;}
public function minus(int $a,int $b)
{return $a-$b;}
}增加对应 server
接下来，咱们去 config/autoload/server.php 下，增加刚刚在注解 @RpcService 上写的 server=“jsonrpc-http”的这个 server
咱们找到 servers
而后发现曾经存在一个 name 是 http 的 server 了，咱们复制一个 name 是 http 的 server，之后增加在 http 这个 server 的上面，而后批改一下
咱们把 name 批改成 jsonrpc-http
咱们把 port 批改成 9502
咱们把 callbacks 批改一下，把 HyperfHttpServerServer::class 批改成 HyperfJsonRpcHttpServer::class, 如上面
'servers' => [
[
'name' => 'http',
'type' => Server::SERVER_HTTP,
'host' => '0.0.0.0',
'port' => 9501,
'sock_type' => SWOOLE_SOCK_TCP,
'callbacks' => [Event::ON_REQUEST => [HyperfHttpServerServer::class, 'onRequest'],
],
],
[
'name' => 'jsonrpc-http',
'type' => Server::SERVER_HTTP,
'host' => '0.0.0.0',
'port' => 9502,
'sock_type' => SWOOLE_SOCK_TCP,
'callbacks' => [Event::ON_REQUEST => [HyperfJsonRpcHttpServer::class, 'onRequest'],
],
],编写 consumer
咱们就在 consumer 我的项目的 controller 调用一下刚刚写的 CalculatorService 把。
对应接口
在调用之前咱们须要把服务接口从 provider 哪里复制一份过去
咱们在 consumer 的 app 目录下创立 Rpc 目录，在 Rpc 目录下创立刚刚复制的 CalculatorServiceInterface
<?php
namespace AppRpc;
interface CalculatorServiceInterface
{public function add(int $a, int $b);
public function minus(int $a, int $b);
}应用 controller 调用
咱们就在 IndexController 外面的 index 办法调用服务, 然而当初还无奈生产胜利，咱们还须要一些配置。
<?php
declare(strict_types=1);
/**
* This file is part of Hyperf.
*
* @link https://www.hyperf.io
* @document https://hyperf.wiki
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace AppController;
use HyperfDiAnnotationInject;
class IndexController extends AbstractController
{
/**
* @Inject
* @var AppRpcCalculatorServiceInterface
*/
private $calculatorService;
public function index()
{return $this->calculatorService->add(1,2);
}
}
创立 services 的配置文件
咱们须要去到 /config/autoload 目录下创立 services.php 文件，文件配置如下
<?php
use AppRpcCalculatorServiceInterface;
return [
'consumers'=>[
[
'name'=>'CalculatorService',
'service'=>CalculatorServiceInterface::class,
'nodes'=>[['host'=>'127.0.0.1','port'=>9502],
],
],
],
];这个服务的 name 和咱们编写注解的 name 是统一的
服务的 service 对应 consumer 的 CalculatorServiceInterface，
因为咱们没有应用注册核心，所以咱们间接应用节点地址，对应下面代码中的 nodes
批改 consumer 的启用端口
因为 consumer 复制过去的，所以咱们须要批改一下端口
在 /config/autoload 下的 server.php 文件下
咱们找到 server，定位到 name 是 http 的 server，将端口批改成 9503
'servers' => [
[
'name' => 'http',
'type' => Server::SERVER_HTTP,
'host' => '0.0.0.0',
'port' => 9503,
'sock_type' => SWOOLE_SOCK_TCP,
'callbacks' => [Event::ON_REQUEST => [HyperfHttpServerServer::class, 'onRequest'],
],
],
],consumer 编写实现
启动 provider
进入终端
cd hyperf-skeleton/
cd provider/
php bin/hyperf.php start启动 consumer
cd hyperf-skeleton/
cd consumer/
php bin/hyperf.php start发动申请
在关上一个终端
curl 127.0.0.1:9503咱们应该能够看到输入了
3应用 consul
咱们这里应用的是 consul
咱们在终端 provider 目录试下装置 hyperf 的服务治理
composer hyperf/service-governance
装置 consul 组件
composer require hyperf/consul
公布一下对应的配置文件
php bin/hyperf.php vendor:publish hyperf/consul
咱们能够看到 consul 的配置文件就曾经生成胜利了
能够到 cogfig/autoload 目录下的 consul.php 文件查看
return [
'uri' => 'http://127.0.0.1:8500',
'token' => '',
];默认是到本地的 8500 端口
下载并启动 consul 服务
# 下载并解压 consul
cd /opt/
mkdir consul
chmod 777 consul
cd consul
wget https://releases.hashicorp.com/consul/1.3.0/consul_1.3.0_linux_amd64.zip
unzip consul_1.3.0_linux_amd64.zip
cp consul /usr/local/bin/
#查看是否装置胜利
consul
consul version
#启动 consul 服务
consul agent -dev -ui -node=consul-dev -client=127.0.0.1
#3. 再开一个终端，输出查看 8500 端口
curl 127.0.0.1:8500
#看见 <a href="/ui/">Moved Permanently</a>. 就胜利了将 provider 的实现类注册进 consul
在注解上增加 publishTo=”consul”
<?php
namespace AppRpc;
use HyperfRpcServerAnnotationRpcService;
/**
* Class CalculatorService
* @package AppRpc
* @RpcService(name="CalculatorService",protocol="jsonrpc-http",server="jsonrpc-http",publishTo="consul")
*/
class CalculatorService implements CalculatorServiceInterface
{
public function add(int $a,int $b)
{return $a+$b;}
public function minus(int $a,int $b)
{return $a-$b;}
}将 consumer 的 services 批改
这里的 services 是 config/autoload 下的
<?php
use AppRpcCalculatorServiceInterface;
return [
'consumers'=>[
[
'name'=>'CalculatorService',
'service'=>CalculatorServiceInterface::class,
'registry'=>[
'protocol'=>'consul',
'address'=>'http://127.0.0.1:8500',
],
// 'nodes'=>[// ['host'=>'127.0.0.1','port'=>9502],
// ],
],
],
];registry 将去 consul 外面取服务，咱们须要先将 nodes 正文
重启 provider
CTRL+C
php bin/hyperf.php start重启 consumer
CTRL+C
php bin/hyperf.php start终端测试
curl 127.0.0.1:9503
#能够看到还是输入，咱们曾经把 nodes 正文了
3服务熔断
为什么要熔断
分布式系统中常常会呈现因为某个根底服务不可用造成整个零碎不可用的状况，这种景象被称为服务雪崩效应。为了应答服务雪崩，一种常见的做法是服务降级。
比方咱们须要到另外服务中查问用户列表，用户列表须要关联很多的表，查问效率较低，但平时并发量不高的时候，响应速度还说得过去。一旦并发量激增，就会导致响应速度变慢，并会使对方服务呈现慢查。
在比方咱们进行一些 Db 查问的时候，须要查问多个表，在这种状况下，平时并发量不高的时候，相应速度还能够说得过去。一旦并发量激增得时候，就可能呈现服务不可用的状况，最初导致整个零碎都不可用，这种景象被称为服务雪崩效应。为了应答服务雪崩，一种常见的做法是服务降级。
降级是指本人的待遇降落了，从 RPC 调用环节来讲，就是去拜访一个本地的伪装者而不是实在的服务。
应用熔断器
熔断器的应用非常简略，只须要退出 HyperfCircuitBreakerAnnotationCircuitBreaker 注解，就能够依据规定策略，进行熔断。
这个时候，咱们只须要配置一下熔断超时工夫 timeout 为 0.05 秒，失败计数 failCounter 超过 1 次后熔断，相应 fallback 为 AppServiceUserService 类的 searchFallback 办法。这样当响应超时并触发熔断后，就不会再申请对端的服务了，而是间接将服务降级从以后我的项目中返回数据，即依据 fallback 指定的办法来进行返回。
创立应用熔断器的 Service
咱们在服务提供者 provider 里的 appService 下创立一个 UserService 来进行应用,
首先，咱们先在 APP 目录下创立目录 Service
而后再 Service 目录下创立 UserService，具体如下：
<?php
namespace AppService;
use HyperfCircuitBreakerAnnotationCircuitBreaker;
class UserService
{
/**
* @return string[]
* @CircuitBreaker(timeout="0.05",failCounter=1,successCounter=1,fallback="AppSerViceUserService::searchFallback")
*/
public function search()
{for ($i=1;$i<=3;$i++){sleep(1);
$a=$i;
print $a."n";
}
return ['message'=>"失常",];
}
public static function searchFallback()
{
return ['message'=>"流量过大，熔断",];
}
}在咱们须要的服务上加上 @CircuitBreaker 这个注解就能够进行服务熔断了，接下来我阐明一下几个参数
timeout=”0.05″ 熔断超时工夫
failCounter= 1 失败记数，超过次数后熔断
successCounter= 1 胜利记数
fallback=”AppSerViceUserService::searchFallback” 发送熔断后调用的办法
在控制器中应用
咱们编写一个控制器，就叫做 UserController 吧。
咱们在 UserController 中注入刚刚编写的 UserService，我为了不便就没有形象成接口了
而后再 UserController 外面编写一个办法来调用 UserService 的办法
代码如下：
<?php
namespace AppController;
use HyperfCircuitBreakerAnnotationCircuitBreaker;
use HyperfDiAnnotationInject;
use HyperfHttpServerAnnotationAutoController;
use AppServiceUserService;
/**
* Class UserController
* @package AppController
* @AutoController()
*/
class UserController extends AbstractController
{
/**
* @Inject
* @var UserService
*/
private $UserService;
public function search()
{return $this->UserService->search();
}
}测试
因为咱们之前在创立 docker 绑定了 9501，所以咱们在 windows 上能够用浏览器拜访 9501 端口
咱们关上浏览器
拜访, 多刷新几次就能够看见服务熔断这个返回，或者你关上 2 个拜访窗口
`
127.0.0.1:9501/user/search
`
或者咱们能够在终端上拜访，不过须要屡次拜访
curl curl 127.0.0.1:9501/user/search
curl curl 127.0.0.1:9501/user/search
curl curl 127.0.0.1:9501/user/search服务限流
限流的目标是通过对并发拜访 / 申请进行限速或者一个工夫窗口内的申请进行限速爱护零碎，一旦达到限度速率就能够拒绝服务（定向到谬误页或告知资源没有了），排队等待（比方秒杀、评论和下单）、降级（返回兜底数据和默认数据，如商品详情页默认有货）。上面咱们将应用到令牌桶限流器。
装置
咱们先进入 provider 目录
`
composer require hyperf/rate-limit
`
公布配置
php bin/hyperf.php vendor:publish hyperf/rate-limit
应用
<?php
namespace AppController;
use HyperfDiAopProceedingJoinPoint;
use HyperfHttpServerAnnotationController;
use HyperfHttpServerAnnotationRequestMapping;
use HyperfRateLimitAnnotationRateLimit;
/**
* @Controller(prefix="rate-limit")
* @RateLimit(limitCallback={RateLimitController::class, "limitCallback"})
*/
class RateLimitController
{
/**
* @RequestMapping(path="test")
* @RateLimit(create=1, capacity=3)
*/
public function test()
{return ["QPS 1, 峰值 3"];
}
public static function limitCallback(float $seconds, ProceedingJoinPoint $proceedingJoinPoint)
{
// $seconds 下次生成 Token 的距离, 单位为秒
// $proceedingJoinPoint 此次申请执行的切入点
// 能够通过调用 `$proceedingJoinPoint->process()` 继续执行或者自行处理
echo "限流中";
return $proceedingJoinPoint->process();}
}create
1
每秒生成令牌数
consume
1
每次申请耗费令牌数
capacity
2
令牌桶最大容量
limitCallback
[]
触发限流时回调办法
waitTimeout
1
排队超时工夫
参考文档：
https://hyperf.wiki/2.1/#/zh-cn/microservice
https://blog.csdn.net/weixin_40670060/article/details/109582821