webman有熔斷器嗎？實(shí)現(xiàn)降級(jí)，找了一個(gè)第3方的但是好像有問題

bigman 更新于2021-09-23

https://github.com/mix-php/micro-hystrix/blob/master/src/CircuitBreaker.php

第106行好像對(duì)并發(fā)沒效果的

// 最大并發(fā)數(shù)，超過并發(fā)返回錯(cuò)誤
'maxConcurrentRequests' => 5,

這個(gè)屬性沒有用

 1958  2 0

2個(gè)回答

不敗少龍 2021-09-23

改成1就會(huì)進(jìn)入錯(cuò)誤信息

bigman 2021-09-23

這個(gè)熔斷器是有問題的對(duì)吧？
不敗少龍 2021-09-23

這個(gè)要基于Swoole才可以吧單獨(dú)用是沒有效果
不敗少龍 2021-09-23

并發(fā)1個(gè)就進(jìn)入返回熔斷頁沒有錯(cuò) 改成其他的就不會(huì)出現(xiàn)熔斷
bigman 2021-09-23

嗯所以想說能否在workerman這邊實(shí)現(xiàn)一個(gè)熔斷器，或者要怎么改？
不敗少龍 2021-09-23

這個(gè)不知道哦 !只是在網(wǎng)上抄襲了節(jié)流, 不知道怎么去弄 ,這個(gè)是我在網(wǎng)上抄的不知道怎么整合到webman了
$host = request()->host();
// 健康檢查
$healthStats = new HealthStats($host, 10, 0.8);
// 熔斷器
$circuitBreaker = new CircuitBreaker($healthStats, 6, 3);
for ($i = 0; $i < 10; ++$i) {
if (!$circuitBreaker->isBreak()) {
$resp = rand(0, 10); // 模擬調(diào)用成功/失敗
if ($resp == 0) {
$healthStats->fail();
} else {
$healthStats->success();
}
} else {
$msg = "觸發(fā)熔斷機(jī)制";
return json(['code' => 500, 'msg' => $msg]);
}
}
bigman 2021-09-23

我找的這個(gè)比較好，如果不考慮并發(fā)的話只考慮timeout是
完全可以的
bigman 2021-09-23

并發(fā)的話他也只能是單個(gè)進(jìn)程的并發(fā)
不敗少龍 2021-09-23

哦!那你除了并發(fā)那個(gè) 其他的都是可以起到效果嗎
bigman 2021-09-23

嗯
bigman 2021-09-23

實(shí)在不行節(jié)流這塊就單獨(dú)拎出來做也可以
bigman 2021-09-23

我是怕麻煩最好一個(gè)小組件解決就比較完美
不敗少龍 2021-09-23

那你怎么測(cè)試的我測(cè)試一直是成功沒有返回熔斷
bigman 2021-09-23

rpc 遠(yuǎn)端弄個(gè)sleep 時(shí)間長點(diǎn) 來測(cè)試
不敗少龍 2021-09-23

哦! 必須是rpc模式才能嗎?
bigman 2021-09-23

對(duì)的

xiuwang 2021-09-23

你咋測(cè)試的并發(fā)沒效果的？

bigman 2021-09-23

開一個(gè)進(jìn)程，然后ab 壓
xiuwang 2021-09-23

一個(gè)進(jìn)程就一個(gè)并發(fā)，壓不出來吧。maxConcurrentRequests改成2，多開幾個(gè)進(jìn)程壓試下
bigman 2021-09-23

？？？并發(fā)請(qǐng)求到一個(gè)進(jìn)程啊！怎么壓不出來啊？
xiuwang 2021-09-23

進(jìn)程里是排隊(duì)一個(gè)一個(gè)處理的，所以同一時(shí)刻只是一個(gè)并發(fā)
bigman 2021-09-23

所以單位時(shí)間內(nèi)看處理幾個(gè)請(qǐng)求