php socket的一些問題

在php手冊看到了php socket的例子 但有些socket_read的循環判斷有一些問題 造成進程的阻塞

實例是用phpsocket實現 客戶端連接到socket server 發送文本 接受文本 斷開

server端

　　

<?php

set_time_limit(0);

$host = "127.0.0.1";
$port = 12388;

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
    or die("socket_create() failed:". socket_strerror(socket_last_error()));

//設置阻塞模式
socket_set_block($socket)
    or die("socket_set_block() failed:". socket_strerror(socket_last_error()));

// 綁定到端口
socket_bind($socket, $host, $port)
    or die("socket_bind() failed:" . socket_strerror(socket_last_error()));

// 開始監聽
socket_listen($socket, 4)
    or die("socket_listen() failed:" . socket_strerror(socket_last_error()));

echo "Binding the socket on $host:$port ... \n";

while (true) {
    // 接收連接請求並調用一個子連接Socket來處理客戶端和服務器間的信息
    if (($msgsock = socket_accept($socket)) < 0) {
        echo "socket_accept() failed:" . socket_strerror(socket_last_error());
    } else {
        // 讀數據
        $out = '';
        while ($buf = socket_read($msgsock, 1024)) {  #注意 主要是這里 這里用的是默認的 type 這里要讀取1024字節 如果客戶端沒有發送這么多數據就會造成子連接的阻塞 導致程序無法繼續向下執行 所以要執行一些判斷
            if (!$buf) {
                break;
            }
            $out .= $buf;
            if (trim($buf) == "Shut") {
                break;
            }
            if (substr($buf, -1) == "\n") { #這里注意 “\n”換行符是一個字節長度
                break;
            }
        }

        // 寫數據
        $in = "數據是 $out";
        echo $in;
        if (!socket_write($msgsock, $in, strlen($in))) echo "socket_write() failed:" . socket_strerror($socket);
    }
    // 結束通信
    socket_close($msgsock);
}
socket_close($socket);

客戶端

<?php

set_time_limit(0);
$host = "127.0.0.1";
$port = 12388;

// 創建一個tcp流
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
    or die("socket_create() failed:" . socket_strerror(socket_last_error()));

echo "try to connect to $host:$port...\n";
$result = socket_connect($socket, $host, $port)
    or die("socket_connect() failed:" . socket_strerror(socket_last_error()));

$in = "abc \n";
if (!socket_write($socket, $in, strlen($in))) {
    echo "socket_write() failed:" . socket_strerror($socket);
} else {
    echo "發送成功！\n";
}

$out = '';
while ($buf = socket_read($socket, 1024)) { #這里因為服務端socket子進程已經斷開了此次連接所以不會阻塞
    $out .= $buf;
}
echo "接受內容為：$out \n";
socket_close($socket);