PHP实现Socket服务器的代码

下面是PHP实现Socket服务器代码的完整攻略：

知识储备

在阅读本攻略之前，您需要掌握以下几个知识点：

• Socket编程相关知识；
• PHP编程基础；
• Linux命令行基础。

实现过程

1. 创建Socket连接

PHP可以通过socket_create()函数创建Socket连接。在创建时需要指定Socket类型、传输协议、地址族等参数，常见的参数组合包括：

socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

• AF_INET表示使用IPv4地址族；
• SOCK_STREAM表示使用TCP协议；
• SOL_TCP表示使用TCP传输协议。

2. 绑定Socket地址

创建好Socket连接之后，需要通过socket_bind()函数将Socket连接绑定到指定的IP和端口。

socket_bind($socket, '0.0.0.0', 9999);

这里将Socket连接绑定到了0.0.0.0地址和9999端口。

3. 监听连接请求

绑定好Socket地址之后，需要通过socket_listen()函数开始监听连接请求。

socket_listen($socket);

这里的$socket参数是之前创建好的Socket连接。

4. 接受连接请求

监听连接之后，需要通过socket_accept()函数接受连接请求，并返回一个新的Socket连接进行处理。

$newSocket = socket_accept($socket);

注意，在使用socket_accept()函数时，当前程序会阻塞等待客户端的连接请求。

5. 处理连接请求

在接受到新的连接请求之后，可以通过socket_read()函数读取客户端发送的数据，通过socket_write()函数向客户端发送数据。

$clientData = socket_read($newSocket, 1024);
socket_write($newSocket, "Hello, client!");

这里读取客户端发送的最多1024字节数据，返回给客户端“Hello, client!”字符串。

6. 关闭Socket连接

处理完连接请求之后，需要通过socket_close()函数关闭Socket连接。

socket_close($newSocket);

完整的代码示例：

<?php
// 创建Socket连接
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

// 绑定Socket地址
socket_bind($socket, '0.0.0.0', 9999);

// 监听连接请求
socket_listen($socket);

// 接受连接请求
$newSocket = socket_accept($socket);

// 处理连接请求
$clientData = socket_read($newSocket, 1024);
socket_write($newSocket, "Hello, client!");

// 关闭Socket连接
socket_close($newSocket);
socket_close($socket);
?>

示例说明

下面是两个PHP实现Socket服务器的示例说明。

示例1：实现多客户端连接

在上述示例中，我们只能处理一个客户端连接。如果需要实现多客户端连接，可以使用以下代码：

<?php
$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($server, '0.0.0.0', 9999);
socket_listen($server);

while (true) {
    $client = socket_accept($server);

    $clientData = socket_read($client, 1024);
    socket_write($client, "Hello, client!");

    socket_close($client);
}
socket_close($server);
?>

这里使用了一个循环来处理多个连接请求，每次接受到连接请求后，创建一个新的Socket连接进行处理。

示例2：实现广播功能

在上述示例中，我们只能向客户端发送固定的字符串。如果需要向多个客户端广播消息，可以使用以下代码：

<?php
$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($server, '0.0.0.0', 9999);
socket_listen($server);

// 存储所有客户端Socket连接
$clients = array();

while (true) {
    $readSocks = array();

    // 将$server和所有客户端Socket连接添加到读取集合中
    array_push($readSocks, $server);
    foreach ($clients as $client) {
        array_push($readSocks, $client);
    }

    // 监听读取集合中Socket连接的事件
    socket_select($readSocks, $write = NULL, $except = NULL, NULL);

    // 对所有触发事件的Socket连接进行处理
    foreach ($readSocks as $socket) {
        if ($socket == $server) {
            // 如果是$server触发事件，则表示有新的连接请求
            $client = socket_accept($server);
            array_push($clients, $client);
        } else {
            // 如果是客户端Socket连接触发事件，则表示有数据可读
            $clientData = socket_read($socket, 1024);

            // 广播客户端消息给所有客户端
            foreach($clients as $client) {
                if ($client != $socket) {
                    socket_write($client, $clientData);
                }
            }
        }
    }
}

// 关闭所有Socket连接
foreach ($clients as $client) {
    socket_close($client);
}
socket_close($server);
?>

这里使用了一个循环来监听连接请求和读取客户端发送的数据。对于新的连接请求，将新连接添加到客户端连接数组中；而读取到客户端发送的数据后，向所有客户端广播这个消息。