pauseRecv的问题

salan 更新于2022-09-29

官方的demo:

use Workerman\Worker;
use Workerman\Timer;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('websocket://0.0.0.0:8484');
$worker->onConnect = function(TcpConnection $connection)
{
    // 给connection对象动态添加一个属性，用来保存当前连接发来多少个请求
    $connection->messageCount = 0;
};
$worker->onMessage = function(TcpConnection $connection, $data)
{
    // 每个连接接收100个请求后就不再接收数据
    $limit = 100;
    if(++$connection->messageCount > $limit)
    {
        $connection->pauseRecv();
        // 30秒后恢复接收数据
        Timer::add(30, function($connection){
            $connection->resumeRecv();
        }, array($connection), false);
    }
};
// 运行worker
Worker::runAll();

经测发现接受数据100次以后是每间隔30s接收一次数据问题是出在timer上吗
timer定时器放在onmessages()里是每次接受到数据都启动一个定时器吧这样是不是有问题？

 642  1 0

1个回答

xiuwang 2022-09-29

为啥不格式化下代码，眼睛都看花了？
这种问题很好定位吧，每次请求自己打印下limit，看下是多少。
你以为前端发了50次，没准发了100次

salan 2022-09-29

代码已格式化谢谢前端我是每两秒请求一次的
xiuwang 2022-09-29

每次请求打印下$connection->messageCount的值吧，应该一下子就定位到了。
$connection->messageCount > 100后，每个请求都会执行pauseRecv() 都会添加定时器，感觉是有问题的。