鍍金池/ 問答/PHP  網(wǎng)絡(luò)安全/ php 使用 Event 進(jìn)行 socket 通信時如何添加多個事件??

php 使用 Event 進(jìn)行 socket 通信時如何添加多個事件??

這邊使用的是 PHPEvent 擴(kuò)展,使用事件的方式而不是使用 stream_select 的方式來進(jìn)行 socket 通信:

$tcp = '127.0.0.1:9005';
$server = stream_socket_server($tcp);

// 超時時間設(shè)置一千年
$time = 1000 * 365 * 24 * 3600;

$base = new EventBase();
$event = new Event($base , $server , Event::READ|Event::PERSIST , function($socket , $flag , $base) use($time){
    $client = stream_socket_accept($socket);
    
    stream_set_blocking($client , false);
    
    $event = new Event($base , $client , Event::READ|Event::WRITE|Event::PERSIST , function($socket , $flag){
        // 這個回調(diào)函數(shù)永遠(yuǎn)不會觸發(fā) .....
        // 郁悶 .....
        // 導(dǎo)致,我只能利用 Event 監(jiān)聽 client 連接
        // 卻無法監(jiān)聽客戶端消息,或向客戶端發(fā)送消息
        // 不知道該如何解決??
        $msg = fread($socket , 65535);
        
        var_dump($msg);
    });
   
    // 注冊到 event 
    $event->add($time);
    
    // 這個能正常輸出
    var_dump("接收到客戶端連接");
} , $base);

$event->add($time);
$base->loop(EventBase::LOOP_NONBLOCK);
$base->dispatch();

本來是打算使用 libevent 擴(kuò)展的,但是 php version >=6 的就沒法使用了,發(fā)覺 Event 這個擴(kuò)展基本和 libevent 擴(kuò)展一樣,于是使用,結(jié)果碰到上面的坑(問題在上面貼出來的代碼中,請耐心閱讀),不知道有沒有人使用過 Event 擴(kuò)展的,能否說下,如何利用 Event 擴(kuò)展替換 stream_select 提高 socket 通信 性能??

回答
編輯回答
蝶戀花

代碼沒看出問題, 是不是 EventBase::LOOP_ONCE 設(shè)錯了?
是每個客戶端連接都能觸發(fā)么? 還是連上一個程序就退了?

2018年7月18日 19:18
編輯回答
雨萌萌
2018年3月11日 16:13