// client // 设置错误处理error_reporting (e_all);// 设置处理时间set_time_limit (0);$ip = ; // ip 地址$port = 1000; // 端口号$socket = socket_create (af_inet, sock_stream, sol_tcp); // 创建一个socketif ($socket) echo socket_create() 成功!
\n;else echo socket_create() 失败:.socket_strerror ($socket).
\n;$conn = socket_connect ($socket, $ip, $port); // 建立socket的连接if ($conn) echo 成功连接到[.$ip.:.$port.]
\n;else echo socket_connect() 失败:.socket_strerror ($conn).
\n;echo socket_read ($socket, 1024).
;$stdin = fopen ('php://stdin', 'r');$ar = array(hello,help,test,quit);$i = 0;while (true){// $command = trim (fgets ($stdin, 1024));// socket_write ($socket, $command, strlen ($command));echo 发送 $ar[$i]
; socket_write ($socket, $ar[$i], strlen($ar[$i]));$i++; $msg = trim (socket_read ($socket, 1024)); echo 收到:$msg
\n; if ($msg == bye-bye) break;}fclose ($stdin);socket_close ($socket);
?
?
?
?
?
?
?
?
======================================
?
?
// server// 设置错误处理error_reporting (e_all);// 设置运行时间set_time_limit (0);// 起用缓冲ob_implicit_flush ();$ip = ; // ip地址$port = 1000; // 端口号$socket = socket_create (af_inet, sock_stream, sol_tcp); // 创建一个socketif ($socket) echo socket_create() successed!\n;else echo socket_create() failed:.socket_strerror ($socket).\n;$bind = socket_bind ($socket, $ip, $port); // 绑定一个socketif ($bind) echo socket_bind() successed!\n;else echo socket_bind() failed:.socket_strerror ($bind).\n;$listen = socket_listen ($socket); // 间听socketif ($listen) echo socket_listen() successed!\n;else echo socket_listen() failed:.socket_strerror ($listen).\n;while (true){ $msg = socket_accept ($socket); // 接受一个socket if (!$msg) { echo socket_accept() failed:.socket_strerror ($msg).\n; break; } $welcome = 服务端收到:welcome to php server!\n; socket_write ($msg, $welcome, strlen ($welcome)); while (true) { $command = strtoupper (trim (socket_read ($msg, 1024))); if (!$command) break; switch ($command) { case hello: $writer = hello everybody!; break; case quit: $writer = bye-bye; break; case help: $writer = hello\tquit\thelp; break; default: $writer = error command!; } socket_write ($msg, $writer, strlen ($writer)); if ($command == quit) break; } socket_close ($msg); if ($command == quit) break;}socket_close ($socket); // 关闭socket
?
?