sockets模拟通讯

服务器端：

//创建服务器端
$socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP);

//设置配置 - 设置套流的最大超时时间1秒
socket_set_option($socket,SOL_SOCKET, SO_RCVTIMEO, array('sec'=>1, 'usec'=>0));
socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, array('sec'=>6, 'usec'=>0));
$host_ip = 'localhost';
$host_port = '83';
//连接服务器套件
if(socket_connect($socket, $host_ip, $host_port) == false){
    echo 'service bind fail:'.socket_strerror(socket_last_error());
}else{
    //发送命令
    $in = "HEAD / HTTP/1.1
";
    $in .= "Connection: Close

";
    $out = '';
    echo "Send Command..........";
    $in = "sun
";
    socket_write($socket, $in, strlen($in));
    echo "OK.
";
    echo "Reading Backinformatin:

";
    while ($out = socket_read($socket, 2048)) {
        echo $out;
    }
    echo "Close socket........";
    socket_close($socket);
    echo "OK,He He.

";

}

客户端：

//创建服务器端
$socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
$host_ip = 'localhost';
$host_port = '83';
//绑定接收主机与端口
if(socket_bind($socket,$host_ip,$host_port) == false){
    echo 'service bind fail:'.socket_strerror(socket_last_error());
}
//监听套件流
if(socket_listen($socket, 4) == false){
    echo 'service listen fail:'.socket_strerror(socket_last_error());
}
//接收命令
if (($msgsock = @socket_accept($socket)) < 0) {
    echo "命令接收失败原因: " . socket_strerror($msgsock) . "
";
}
$msg = "
PHP Test Server. 
" ."用quit,shutdown,sun...等命令测试.
";
$msg = mb_check_encoding($msg,'GBK','utf-8');

socket_write($msgsock, $msg, strlen($msg));


    if (false === ($buf = socket_read($msgsock, 2048, PHP_NORMAL_READ))) {
        echo "socket_read() failed: reason: " . socket_strerror($ret) . "
";
    }
//    if (!$buf = trim($buf)) {
//        continue;
//    }
    if ($buf == 'quit') {
        exit();
    }
    if ($buf == 'shutdown') {
        socket_close($msgsock);
    }
    if ($buf == 'sun') {
        echo'what are you doing?';
    }
    $talkback = "Backinformation : '$buf'.
";
    socket_write($msgsock, $talkback, strlen($talkback));
    echo "$buf
";

socket_close($socket);