mservice 可以方便的对资源进行限流。包括Http、Thrift。

## 一、安装

```

composer require clevephp/la-limiting

```

## 二、配置

在配置文件里，加入限流配置

```

"atomic_limit" => [

"resources" => [

[

"count" => 2,

"resource" => "/Web/Home/Limitings::index"

],

//thrift rpc

[

"count" => 2,

"resource" => "Services/Servicehelper::getUsers"

],

[

"count" => 20,

"resource" => "/Web/Home/Index::index"

]

],

"on"=>true

]

```

参数如下：

* [ ] resource 要限制的类。声明规范是：类(需完整的命名空间)::方法

* [ ] count 允许最大QPS

* [ ] env_seconds x秒内触发条件，默认3

* [ ] stop_seconds 限制x秒，默认3

通过上述配置就可以实现限流+熔断了。

## 三、降级

如果需要对限流后的结果进行降级，创建一个带后缀_demotion的相同方法即可。

```

function index(\Core\Common\HttpBase $httpBase)

{

return $httpBase->success([]);

}

// index被限流后，触发的降级逻辑

public function index_demotion()

{

//具体逻辑....

return $this->httpBase->failure("index_demotion");

}

```

## 四、Thrift RPC内使用

在Thrift RPC里，需要手工调取Servce::New方法

```

/**

* 项目名称：CleverPHP 3.x

* 类名称：

* 类描述：实现业务的地方

* 创建人：ceiba

* 创建时间：2019年9月15日

* @version

*/

namespace Services;

class Servicehelper implements \Services\StudentsCarnie\StudentsCarnieIf

{

public function getUsers($userId)

{

$result = \Core\Common\Services::New();

if ($result) {

return $result;

}

// 接入业务

return $userId;

}

// 降级

public function getUsers_demotion()

{

return 22;

}

}

```

## 五、在框架外使用

```

$sourceItemRules=\ClevePHP\LaLimiting\SourceItemRules::New();

$sourceItemRules::$requestEnvSeconds=3; //多X秒内

$sourceItemRules::$requestNumber=10; //多少QPS

$sourceItemRules::$requestStopSeconds=3; //限X秒

$source="http://localhost/index/index/";

$item=\ClevePHP\LaLimiting\SourceItem::New($source,$func,[],$sourceItemRules);

$redis = new \Redis();

$redis->connect( "127.0.0.1",6379)

$object=\ClevePHP\LaLimiting\LaLimiting::getInstance($reids);

$checkResult=$object->start($item);

```