socket_accept()
函数用于接受客户端的连接请求。它通常用在服务器端,当服务器监听一个端口等待客户端连接时,可以使用 socket_accept()
函数来接受客户端的连接。以下是一个简单的示例,展示了如何使用 socket_accept()
函数:
<?php
// 创建套接字
$server_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if (!$server_socket) {
echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
exit;
}
// 绑定套接字到地址和端口
$server_address = "127.0.0.1";
$server_port = 8080;
$result = socket_bind($server_socket, $server_address, $server_port);
if (!$result) {
echo "socket_bind() failed.\nReason: " . socket_strerror(socket_last_error($server_socket)) . "\n";
exit;
}
// 开始监听连接
$max_waiting_connections = 5;
$socket_listening = socket_listen($server_socket, $max_waiting_connections);
if (!$socket_listening) {
echo "socket_listen() failed: reason: " . socket_strerror(socket_last_error($server_socket)) . "\n";
exit;
}
echo "Server is listening on port " . $server_port . "\n";
while (true) {
// 接受客户端连接
$client_socket = socket_accept($server_socket);
if (!$client_socket) {
echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error($server_socket)) . "\n";
continue;
}
// 读取客户端发送的数据
$client_data = socket_read($client_socket, 1024);
if ($client_data === false) {
echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($client_socket)) . "\n";
break;
}
// 处理客户端请求(这里只是简单地返回 "Hello from server!")
$response = "Hello from server!";
// 向客户端发送响应
socket_write($client_socket, $response);
// 关闭套接字连接
socket_close($client_socket);
}
// 关闭服务器套接字
socket_close($server_socket);
?>
这个示例中,服务器首先创建一个套接字,然后绑定到本地地址和端口。接着开始监听连接请求,当有客户端发起连接请求时,socket_accept()
函数会返回一个新的套接字,用于与客户端进行通信。之后,服务器可以读取客户端发送的数据,处理请求并向客户端发送响应。最后,记得关闭套接字连接。