php中socket的使用

<?php
error_reporting(E_ALL);
set_time_limit(0);
//ob_implicit_flush();

$address='127.0.0.1';
$port=10005;
//创建端口
if(($sock=socket_create(AF_INET,SOCK_STREAM,SOL_TCP))===false){
echo"socket_create()failed:reason:".socket_strerror(socket_last_error())."\n";
}

//绑定
if(socket_bind($sock,$address,$port)===false){
echo"socket_bind()failed:reason:".socket_strerror(socket_last_error($sock))."\n";
}

//监听
if(socket_listen($sock,5)===false){
echo"socket_bind()failed:reason:".socket_strerror(socket_last_error($sock))."\n";
}

do{
//得到一个链接
if(($msgsock=socket_accept($sock))===false){
echo"socket_accepty()failed:reason:".socket_strerror(socket_last_error($sock))."\n";
break;
}
//welcome发送到客户端
$msg="<fontcolor='red'>serversend:welcome</font><br/>";
socket_write($msgsock,$msg,strlen($msg));
echo'readclientmessage\n';
$buf=socket_read($msgsock,8192);
$talkback="receivedmessage:$buf\n";
echo$talkback;
if(false===socket_write($msgsock,$talkback,strlen($talkback))){
echo"socket_write()failedreason:".socket_strerror(socket_last_error($sock))."\n";
}else{
echo'sendsuccess';
}
socket_close($msgsock);
}while(true);
//关闭socket
socket_close($sock);

?>

<?php
//error_reporting(E_ALL);
echo"<h2>tcp/ipconnection</h2>\n";
$service_port=10005;
$address='127.0.0.1';

$socket=socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
if($socket===false){
echo"socket_create()failed:reason:".socket_strerror(socket_last_error())."\n";
}else{
echo"OK.\n";
}

echo"Attemptingtoconnectto'$address'onport'$service_port'...";
$result=socket_connect($socket,$address,$service_port);
if($result===false){
echo"socket_connect()failed.\nReason:($result)".socket_strerror(socket_last_error($socket))."\n";
}else{
echo"OK\n";
}
$in="HEAD/http/1.1\r\n";
$in.="HOST:localhost\r\n";
$in.="Connection:close\r\n\r\n";
$out="";
echo"sendinghttpheadrequest...";
socket_write($socket,$in,strlen($in));
echo"OK\n";

echo"Readingresponse:\n\n";
while($out=socket_read($socket,8192)){
echo$out;
}
echo"closeingsocket..";
socket_close($socket);
echo"ok.\n\n";

执行结果：

server: