官方的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()里是每次接受到数据都启动一个定时器吧 这样是不是有问题?
为啥不格式化下代码,眼睛都看花了?
这种问题很好定位吧,每次请求自己打印下limit,看下是多少。
你以为前端发了50次,没准发了100次
代码已格式化 谢谢 前端我是每两秒请求一次的
每次请求打印下
$connection->messageCount
的值吧,应该一下子就定位到了。$connection->messageCount
> 100后,每个请求都会执行pauseRecv()
都会添加定时器,感觉是有问题的。