使用 socket_accept() 接收 IoT 设备的数据上传

M66 2025-05-29

在物联网（IoT）项目中，服务端通常需要实时接收设备上传的数据。这些设备可能会使用 TCP 连接将传感器数据、状态信息等发送到服务器。PHP 虽然并不是传统意义上的网络编程首选语言，但通过其内置的 socket 扩展，也可以胜任这一任务。本文将介绍如何使用 socket_accept() 函数来接收 IoT 设备的数据，并进行基本的处理。

一、准备工作

首先，请确保您的 PHP 环境已经启用了 sockets 扩展。可以通过运行 phpinfo(); 来确认是否已启用。

二、创建服务器端 Socket

以下是创建一个基础的 TCP socket 服务器的步骤：

<?php
// 设置服务器地址和端口
$host = '0.0.0.0';
$port = 8888;

// 创建 socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if (!$socket) {
    die("无法创建 socket：" . socket_strerror(socket_last_error()));
}

// 绑定 socket 到 IP 和端口
if (!socket_bind($socket, $host, $port)) {
    die("绑定失败：" . socket_strerror(socket_last_error($socket)));
}

// 开始监听连接
if (!socket_listen($socket)) {
    die("监听失败：" . socket_strerror(socket_last_error($socket)));
}

echo "服务端已启动，等待设备连接...\n";

三、接受设备连接

使用 socket_accept() 接收连接。这个函数会阻塞，直到有设备连接为止：

while (true) {
    $clientSocket = socket_accept($socket);
    if ($clientSocket === false) {
        echo "socket_accept 失败：" . socket_strerror(socket_last_error($socket)) . "\n";
        continue;
    }

    echo "设备已连接。\n";

    // 读取设备发送的数据
    $input = socket_read($clientSocket, 1024);
    if ($input === false) {
        echo "读取失败：" . socket_strerror(socket_last_error($clientSocket)) . "\n";
    } else {
        echo "接收到数据：$input\n";

        // 假设数据为 JSON 格式，进行解码
        $data = json_decode(trim($input), true);
        if (json_last_error() === JSON_ERROR_NONE) {
            // 示例：处理温度传感器数据
            if (isset($data['device_id'], $data['temperature'])) {
                $deviceId = $data['device_id'];
                $temperature = $data['temperature'];

                // 假设保存到数据库或执行其他处理逻辑
                echo "设备 $deviceId 上传温度：$temperature °C\n";

                // 返回处理结果
                $response = json_encode(['status' => 'ok']);
                socket_write($clientSocket, $response);
            } else {
                echo "收到非法数据。\n";
            }
        } else {
            echo "JSON 解码失败。\n";
        }
    }

    // 关闭当前连接
    socket_close($clientSocket);
}

四、关闭 Socket（服务停止时）

socket_close($socket);

五、IoT 设备端示例

IoT 设备端只需建立 TCP 连接并上传 JSON 格式的数据。例如：

{
  "device_id": "sensor_001",
  "temperature": 25.6
}

数据可通过 TCP 客户端（如 ESP8266 的 Arduino 程序、Python socket、甚至 curl）发送至服务器的 m66.net:8888 地址。

六、安全性与扩展

安全性：生产环境建议使用加密（如 TLS）传输数据。
并发处理：考虑使用 pcntl_fork() 创建子进程处理多个连接。
数据持久化：可将设备数据写入 MySQL、Redis 或日志文件中。

结语

尽管 PHP 并非专为 socket 编程设计，但通过内置函数如 socket_accept()，开发者仍能快速搭建一个简单而实用的 IoT 数据接收服务器。在小规模设备通信和测试环境中，使用 PHP 完全是可行的。希望这篇文章能帮助你更好地理解并应用 socket_accept() 来处理 IoT 数据。

socket_accept