php实现socket

PHP 实现 Socket 通信

PHP 可以通过 socket 扩展实现网络通信，支持 TCP/UDP 协议。以下是实现 Socket 通信的核心步骤和代码示例。

创建 TCP 服务器

// 创建 Socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
    die("Socket 创建失败: " . socket_strerror(socket_last_error()));
}

// 绑定 IP 和端口
$bind = socket_bind($socket, '0.0.0.0', 8080);
if ($bind === false) {
    die("绑定失败: " . socket_strerror(socket_last_error()));
}

// 监听连接
$listen = socket_listen($socket, 5);
if ($listen === false) {
    die("监听失败: " . socket_strerror(socket_last_error()));
}

echo "服务器启动，等待客户端连接...\n";

// 接受客户端连接
$client = socket_accept($socket);
if ($client === false) {
    die("接受连接失败: " . socket_strerror(socket_last_error()));
}

// 读取客户端数据
$data = socket_read($client, 1024);
echo "接收到客户端消息: " . $data . "\n";

// 发送响应
$response = "Hello, Client!";
socket_write($client, $response, strlen($response));

// 关闭连接
socket_close($client);
socket_close($socket);

创建 TCP 客户端

// 创建 Socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
    die("Socket 创建失败: " . socket_strerror(socket_last_error()));
}

// 连接服务器
$connect = socket_connect($socket, '127.0.0.1', 8080);
if ($connect === false) {
    die("连接失败: " . socket_strerror(socket_last_error()));
}

// 发送数据
$message = "Hello, Server!";
socket_write($socket, $message, strlen($message));

// 接收响应
$response = socket_read($socket, 1024);
echo "服务器响应: " . $response . "\n";

// 关闭连接
socket_close($socket);

创建 UDP 服务器

// 创建 Socket
$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) {
    die("Socket 创建失败: " . socket_strerror(socket_last_error()));
}

// 绑定 IP 和端口
$bind = socket_bind($socket, '0.0.0.0', 8080);
if ($bind === false) {
    die("绑定失败: " . socket_strerror(socket_last_error()));
}

echo "UDP 服务器启动，等待数据...\n";

// 接收数据
$from = '';
$port = 0;
socket_recvfrom($socket, $buffer, 1024, 0, $from, $port);
echo "接收到来自 {$from}:{$port} 的消息: " . $buffer . "\n";

// 发送响应
$response = "Hello, UDP Client!";
socket_sendto($socket, $response, strlen($response), 0, $from, $port);

// 关闭 Socket
socket_close($socket);

创建 UDP 客户端

// 创建 Socket
$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) {
    die("Socket 创建失败: " . socket_strerror(socket_last_error()));
}

// 发送数据
$message = "Hello, UDP Server!";
socket_sendto($socket, $message, strlen($message), 0, '127.0.0.1', 8080);

// 接收响应
socket_recvfrom($socket, $response, 1024, 0, $from, $port);
echo "服务器响应: " . $response . "\n";

// 关闭 Socket
socket_close($socket);

错误处理

Socket 操作可能因网络问题或配置错误失败，建议通过 socket_last_error() 和 socket_strerror() 捕获并处理错误。

if ($socket === false) {
    $error = socket_strerror(socket_last_error());
    die("操作失败: " . $error);
}

注意事项

• 确保 PHP 已启用 socket 扩展（检查 php.ini 中 extension=sockets）。
• 服务器需开放对应端口（如 8080），防火墙可能拦截连接。
• TCP 是面向连接的协议，需先建立连接；UDP 是无连接的，直接发送数据包。
• 多客户端场景下，服务器需使用循环或异步处理（如 socket_select）。