|
|
@@ -10,7 +10,7 @@ class NingboAction extends Action {
|
|
|
public function dahua( ){
|
|
|
Vendor('Workerman352.Autoloader');
|
|
|
$worker = new \Workerman\Worker("Dahua://0.0.0.0:1234");
|
|
|
- $worker->count = 8;
|
|
|
+ $worker->count = 12;
|
|
|
$worker->onWorkerStart = function($worker){
|
|
|
$timeInterval = 60 * 5;//秒
|
|
|
\Workerman\Lib\Timer::add($timeInterval, function()
|
|
|
@@ -126,7 +126,7 @@ class NingboAction extends Action {
|
|
|
|
|
|
$MAX_K = 2;
|
|
|
$rec = 0;
|
|
|
- while ($rk->getOutQLen() > 0) {//让回调成功或失败生效
|
|
|
+ while ($rk->getOutQLen() > 30000) {//让回调成功或失败生效
|
|
|
$rec++;
|
|
|
if ($rec > $MAX_K) {
|
|
|
break;
|
git