//在服务器上绑定IP和端口

$address = '127.0.0.1';

$port = 1020;

if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) < 0) {

echo "socket_create() failed: reason: " . socket_strerror($sock) . "\n";

}

if (($ret = socket_bind($sock, $address, $port)) < 0) {

echo "socket_bind() failed: reason: " . socket_strerror($ret) . "\n";

}

if (($ret = socket_listen($sock, 5)) < 0) {

echo "socket_listen() failed: reason: " . socket_strerror($ret) . "\n";

}

do {

if (($msgsock = socket_accept($sock)) < 0) {

echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n";

break;

}

/* Send instructions. */

$msg = "\nWelcome to the PHP Test Server. \n" .

"To quit, type 'quit'. To shut down the server type 'shutdown'.\n";

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

do {

if (false === socket_recv($msgsock, $buf , 1024, 0)) {

echo "socket_read() failed: reason: " . socket_strerror($ret) . "\n";

break 2;

}

if (!$buf = trim($buf)) {

continue;

}

if ($buf == 'quit') {

break;

}

if ($buf == 'shutdown') {

socket_close($msgsock);

break 2;

}

$talkback = "PHP: You said '$buf'.\n";

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

echo "$buf\n";

//以下处理接受到的buf

/*eg：例如

$buf=”cmd.exe /c netstat –an”;

$pp = popen('$buf ', 'r');

While($read = fgets($pp, 2096))

echo $read;

pclose($pp);

*/

} while (true);

socket_close($msgsock);

} while (true);

socket_close($sock);

?>

上一页  [1] [2] [3] [4] [5] [6] 下一页