websoket test 武汉

set(array('task_worker_num' => 1));$serv->on('Open', function ($server, $req) {static $isTask = false;echo "已连接上{$req->fd}\r\n";if(!$isTask){$task_id = $server->task('1');$isTask = true;}}); 
 $serv->on('Message', function ($server, $frame) {echo "对方[{$frame->fd}]: " . $frame->data . "\r\n";}); $serv->on('Close', function ($server, $fd) {echo "connection close: " . $fd;}); 
 $serv->on('Task', function ($serv, $task_id, $from_id, $data) {while($cdata = trim(fgets(STDIN))){$serv->finish($cdata);} }); $serv->on('Start', function ($serv) {}); $serv->on('Finish', function ($server, $task_id, $data) {//    echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;if($data!==''){foreach($server->connections as $fd){$server->push($fd, $data);}    }}); 
 $serv->start();
   

Testing websockets发送' +"对方:"+ event.data;
}
 
function onOpen(event) {
document.getElementById('messages').innerHTML
= 'Connection established';
}
 
function onError(event) {
alert(event.data);
// alert("error");
}
 
function start() {
var msg = document.getElementById('msg').value;
webSocket.send(msg);
document.getElementById('messages').innerHTML
+= '' +"我："+ msg;
return false;
}" _ue_custom_node_="true">