php 监听端口数据

<?php
$host = '0.0.0.0'; // 监听所有网络接口
$port = 12345;     // 监听端口

// 创建 socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
    die("socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n");
}

// 绑定 socket 到指定地址和端口
if (!socket_bind($socket, $host, $port)) {
    die("socket_bind() failed: reason: " . socket_strerror(socket_last_error($socket)) . "\n");
}

// 开始监听
if (!socket_listen($socket, 5)) {
    die("socket_listen() failed: reason: " . socket_strerror(socket_last_error($socket)) . "\n");
}

echo "Server listening on $host:$port...\n";

while (true) {
    // 接受客户端连接
    $client = socket_accept($socket);
    if ($client === false) {
        echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error($socket)) . "\n";
        continue;
    }

    // 读取客户端数据
    $data = socket_read($client, 1024, PHP_NORMAL_READ);
    if ($data === false) {
        echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($client)) . "\n";
        socket_close($client);
        continue;
    }

    echo "Received data: $data\n";

    // 发送响应给客户端
    $response = "Server received your message.";
    if (!socket_write($client, $response, strlen($response))) {
        echo "socket_write() failed: reason: " . socket_strerror(socket_last_error($client)) . "\n";
    }

    // 关闭客户端连接
    socket_close($client);
}

// 关闭服务器 socket
socket_close($socket);
?>