发表新帖

websocket开启大约几天后,fd达到9000左右,进程会挂掉

用swoole搭建了一个websocket服务器,在Linux上开机启动,在运行大约1天后,客户端建立链接请求数据明显变慢很多,杀死这个进程后,重新启动就会正常很快(tp5框架),代码如下,求解
{{{php
<?php
namespace app\Console;

use think\console\Command;
use think\console\Input;
use think\console\Output;
class WebSocket extends Command
{
    protected $server;
    // 命令行配置函数
    protected $timer=array();

protected function configure()
    {
        // setName 设置命令行名称
        // setDescription 设置命令行描述
        $this->setName('websocket:start')->setDescription('Start Web Socket Server!');
    }

// 设置命令返回信息
    protected function execute(Input $input, Output $output)
    {
        $this->server = new \Swoole\WebSocket\Server('0.0.0.0', 9501);

// 设置 server 运行前各项参数
        // 调试的时候把守护进程关闭，部署到生产环境时再把注释取消
        // $this->server->set([composer require topthink/think-swoole
        //     'daemonize' => true,
        // ]);
	$this->server->set(array(
            'worker_num' => 6
       	 ));

// 设置回调函数
        $this->server->on('Open', [$this, 'onOpen']);
        $this->server->on('Message', [$this, 'onMessage']);
        $this->server->on('Close', [$this, 'onClose']);
        $this->server->user = [];
        $this->server->start();
    }

public function onOpen(\Swoole\WebSocket\Server $server, \Swoole\Http\Request $request)
    {
        echo "server: handshake success with fd{$request->fd}\n";
    }

// 收到数据时回调函数
    public function onMessage(\Swoole\WebSocket\Server $server, \Swoole\WebSocket\Frame $frame)
    {
        echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
        if($frame->data){
            //首次直接返回数据
            $data=$this->getMany($frame->data);
	   if($server->exist($frame->fd)){
	       $server->push($frame->fd, json_encode($data));
	   }
            if(array_key_exists($frame->fd,$this->timer)){
                swoole_timer_clear($this->timer[$frame->fd]);
                unset($this->timer[$frame->fd]);
            }
            //后续定时推送
            $time_id=swoole_timer_tick(1000,function() use($server,$frame) {
                //获取需要推送消息的fd列表
                if($server->exist($frame->fd)){
                    $list=$frame->data;
                    $data=$this->getMany($list);
                    $server->push($frame->fd, json_encode($data));
                }
            });
            $this->timer[$frame->fd]=$time_id;
        }else{
            $this->onClose($server,$frame->fd);
        }

}
    // 连接关闭时回调函数
    public function onClose($server, $fd)
    {
        echo "client {$fd} closed\n";
    }

}
}}}

发布于5年前 · 13 次浏览 · 来自提问

钬

use think\console\Command;
use think\console\Input;
use think\console\Output;
class WebSocket extends Command
{
    protected $server;
    // 命令行配置函数
    protected $timer=array();

// 设置命令返回信息
    protected function execute(Input $input, Output $output)
    {
        $this->server = new \Swoole\WebSocket\Server('0.0.0.0', 9501);

public function onOpen(\Swoole\WebSocket\Server $server, \Swoole\Http\Request $request)
    {
        echo "server: handshake success with fd{$request->fd}\n";
    }

}
    // 连接关闭时回调函数
    public function onClose($server, $fd)
    {
        echo "client {$fd} closed\n";
    }

}
}}}