pauseRecv的问题

salan

官方的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()里是每次接受到数据都启动一个定时器吧 这样是不是有问题?

441 1 0
1个回答

xiuwang

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

  • salan 2022-09-29

    代码已格式化 谢谢 前端我是每两秒请求一次的

  • xiuwang 2022-09-29

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

年代过于久远,无法发表回答
🔝