示例

示例 #1 套接字示例：简单的 TCP/IP 服务器

此示例展示了一个简单的回声服务器。更改 address 和 port 变量以适合您的设置并执行。然后，您可以使用类似以下的命令连接到服务器： telnet 192.168.1.53 10000 （其中地址和端口与您的设置匹配）。您键入的任何内容都将在服务器端输出，并回显给您。要断开连接，请输入“quit”。

#!/usr/local/bin/php -q
<?php
error_reporting(E_ALL);

/* 允许脚本挂起等待连接。 */
set_time_limit(0);

/* 打开隐式输出刷新，以便我们看到传入的数据。 */
ob_implicit_flush();

$address = '192.168.1.53';
$port = 10000;

if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
 echo "socket_create() 失败：原因：" . socket_strerror(socket_last_error()) . "\n";
}

if (socket_bind($sock, $address, $port) === false) {
 echo "socket_bind() 失败：原因：" . socket_strerror(socket_last_error($sock)) . "\n";
}

if (socket_listen($sock, 5) === false) {
 echo "socket_listen() 失败：原因：" . socket_strerror(socket_last_error($sock)) . "\n";
}

do {
 if (($msgsock = socket_accept($sock)) === false) {
 echo "socket_accept() 失败：原因：" . socket_strerror(socket_last_error($sock)) . "\n";
 break;
 }
 /* 发送指令。 */
 $msg = "\n欢迎使用 PHP 测试服务器。\n" .
 "要退出，请输入 'quit'。要关闭服务器，请输入 'shutdown'。\n";
 socket_write($msgsock, $msg, strlen($msg));

 do {
 if (false === ($buf = socket_read($msgsock, 2048, PHP_NORMAL_READ))) {
 echo "socket_read() 失败：原因：" . socket_strerror(socket_last_error($msgsock)) . "\n";
 break 2;
 }
 if (!$buf = trim($buf)) {
 continue;
 }
 if ($buf == 'quit') {
 break;
 }
 if ($buf == 'shutdown') {
 socket_close($msgsock);
 break 2;
 }
 $talkback = "PHP: 你说的是 '$buf'.\n";
 socket_write($msgsock, $talkback, strlen($talkback));
 echo "$buf\n";
 } while (true);
 socket_close($msgsock);
} while (true);

socket_close($sock);
?>

示例 #2 套接字示例：简单的 TCP/IP 客户端

此示例展示了一个简单的单次 HTTP 客户端。它只是连接到一个页面，提交一个 HEAD 请求，回显回复，然后退出。

<?php
error_reporting(E_ALL);

echo "<h2>TCP/IP 连接</h2>\n";

/* 获取 WWW 服务的端口。 */
$service_port = getservbyname('www', 'tcp');

/* 获取目标主机的 IP 地址。 */
$address = gethostbyname('www.example.com');

/* 创建一个 TCP/IP 套接字。 */
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
 echo "socket_create() 失败：原因: " . socket_strerror(socket_last_error()) . "\n";
} else {
 echo "OK.\n";
}

echo "尝试连接到 ' "$address' 在端口 ' "$service_port' 上...";
$result = socket_connect($socket, $address, $service_port);
if ($result === false) {
 echo "socket_connect() 失败。\n原因: ( "$result") " . socket_strerror(socket_last_error($socket)) . "\n";
} else {
 echo "OK.\n";
}

$in = "HEAD / HTTP/1.1\r\n";
$in .= "Host: www.example.com\r\n";
$in .= "Connection: Close\r\n\r\n";
$out = '';

echo "发送 HTTP HEAD 请求...";
socket_write($socket, $in, strlen($in));
echo "OK.\n";

echo "读取响应:\n\n";
while ($out = socket_read($socket, 2048)) {
 echo $out;
}

echo "关闭套接字...";
socket_close($socket);
echo "OK.\n\n";
?>

改进此页面

了解如何改进此页面 • 提交拉取请求 • 报告错误

＋添加注释

用户贡献的注释 3 注释

向上

向下

javier,javiern at gmail dot com ¶

11 年前

您可以轻松地扩展第一个示例以处理任意数量的连接，而不仅仅是一个连接。

#!/usr/bin/env php
<?php
error_reporting(E_ALL);

/* 允许脚本等待连接。 */
set_time_limit(0);

/* 启用隐式输出缓冲，这样我们就可以看到我们得到的内容
 * 在它到达之前。 */
ob_implicit_flush();

$address = '127.0.0.1';
$port = 10000;

if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
 echo "socket_create() 失败：原因: " . socket_strerror(socket_last_error()) . "\n";
}

if (socket_bind($sock, $address, $port) === false) {
 echo "socket_bind() 失败：原因: " . socket_strerror(socket_last_error($sock)) . "\n";
}

if (socket_listen($sock, 5) === false) {
 echo "socket_listen() 失败：原因: " . socket_strerror(socket_last_error($sock)) . "\n";
}

// 客户端数组
$clients = array();

do {
 $read = array();
 $read[] = $sock;
 
 $read = array_merge($read,$clients);
 
 // 设置对 socket_select 的阻塞调用
 if(socket_select($read,$write = NULL, $except = NULL, $tv_sec = 5) < 1)
 {
 // SocketServer::debug("Problem blocking socket_select?");
 continue;
 }
 
 // 处理新连接
 if (in_array($sock, $read)) { 
 
 if (($msgsock = socket_accept($sock)) === false) {
 echo "socket_accept() 失败：原因: " . socket_strerror(socket_last_error($sock)) . "\n";
 break;
 }
 $clients[] = $msgsock;
 $key = array_keys($clients, $msgsock);
 /* 发送指令。 */
 $msg = "\n欢迎来到 PHP 测试服务器。\n" .
 "您是客户端编号: {$key[0]}\n" .
 "要退出，请输入 'quit'。 要关闭服务器，请输入 'shutdown'。\n";
 socket_write($msgsock, $msg, strlen($msg));
 
 }
 
 // 处理输入
 foreach ($clients as $key => $client) { // 对于每个客户端 
 if (in_array($client, $read)) {
 if (false === ($buf = socket_read($client, 2048, PHP_NORMAL_READ))) {
 echo "socket_read() 失败：原因: " . socket_strerror(socket_last_error($client)) . "\n";
 break 2;
 }
 if (!$buf = trim($buf)) {
 continue;
 }
 if ($buf == 'quit') {
 unset($clients[$key]);
 socket_close($client);
 break;
 }
 if ($buf == 'shutdown') {
 socket_close($client);
 break 2;
 }
 $talkback = "客户端 {$key}: 您说 ' "$buf'。\n";
 socket_write($client, $talkback, strlen($talkback));
 echo "$buf\n";
 }
 
 } 
} while (true);

socket_close($sock);
?>

向上

向下

Timofey Bugaevsky ¶

1 年前

Javier 的好例子。

要在 Docker 容器中使用，可以使用 0 作为地址
$address = '0';

要向所有客户端广播消息，可以使用 socket_write() 向所有需要的客户端发送消息
...
// 处理输入
foreach ($clients as $key => $client) {
if (in_array($client, $read)) {
            ...
if ($buf == 'message') {
$talkback = "$buf $key\n";
foreach ($clients as $curClient) {
socket_write($curClient, $talkback, strlen($talkback));
                }
continue;
            }
            ...
        }
    }
...

向上

向下

-2

zital at riseup dot net ¶

7 年前

由于 PHP 标准，修改代码为
<?php
//...
 $write = NULL;
 $except = NULL;
 $tv_sec = 5;

 // 设置一个阻塞调用到 socket_select
 if(socket_select($read, $write, $except, $tv_sec) < 1)
//...
?>

＋添加注释