目的:
瀏覽器和服務(wù)端建立websocket長連接
服務(wù)端同時(shí)作為websocket客戶端跟第三方接口保持長連接
拿到第三方數(shù)據(jù)后,將結(jié)果 返回給指定的客戶端用戶
envent.php代碼:
class Events
{
public static $connection_to_8989 = null;
public static function onConnect($client_id){
self::$connection_to_8989 = new AsyncTcpConnection("ws://127.0.0.1:8989");
self::$connection_to_8989->onMessage = function($connection_to_8989, $buffer)use($client_id)
{
Gateway::sendToClient($client_id,$client_id." said 【".$buffer."】 from 8787");
};
self::$connection_to_8989->connect();
}
public static function onMessage($client_id, $message){
sleep(mt_rand(1,3));
self::$connection_to_8989->send($message);
}
public static function onClose(){
self::$connection_to_8989->close();
}
}
請(qǐng)問這段代碼能實(shí)現(xiàn)我的需求嗎?