Workerman怎么进行数据序列化？Workerman数据打包格式？

onMessage

send

serialize

unserialize

onMessage

$connection->send()

// 假设这是你的Workerman服务启动文件
use Workerman\Worker;
use Workerman\Connection\TcpConnection;

require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('tcp://0.0.0.0:2345');

$worker->onConnect = function(TcpConnection $connection) {
    echo "New connection from " . $connection->remoteAddress . "\n";
};

$worker->onMessage = function(TcpConnection $connection, $data) {
    // 接收到数据，尝试JSON解码
    $decodedData = json_decode($data, true); // true表示解码为关联数组

    if (json_last_error() === JSON_ERROR_NONE) {
        echo "Received JSON data: " . print_r($decodedData, true);

        // 假设我们要回应一个成功消息
        $response = ['status' => 'success', 'message' => 'Data received!', 'data' => $decodedData];
        $connection->send(json_encode($response));
    } else {
        echo "Received non-JSON data or invalid JSON: " . $data . "\n";
        $connection->send(json_encode(['status' => 'error', 'message' => 'Invalid JSON format.']));
    }
};

$worker->onClose = function(TcpConnection $connection) {
    echo "Connection closed\n";
};

Worker::runAll();

serialize

unserialize

serialize

serialize

serialize

Worker

// Protocols/MyProtocol.php
namespace Protocols;

class MyProtocol
{
    // 假设我们用4个字节来存储包的长度（无符号长整型）
    const PACKAGE_LENGTH_BYTE = 4;

    /**
     * 判断当前缓冲区中是否包含一个完整的包。
     * 如果是，返回包的长度（包括头部）；否则返回0。
     * @param string $buffer
     * @return int
     */
    public static function len($buffer)
    {
        // 如果连包头都不够，肯定不是一个完整的包
        if (strlen($buffer) < self::PACKAGE_LENGTH_BYTE) {
            return 0;
        }
        // 从缓冲区头部解析出包的长度
        // 'N' 表示无符号长整型（32位），网络字节序
        $length = unpack('N', substr($buffer, 0, self::PACKAGE_LENGTH_BYTE))[1];
        // 如果缓冲区中的数据长度小于包头声明的长度+包头自身长度，说明数据不完整
        if (strlen($buffer) < $length + self::PACKAGE_LENGTH_BYTE) {
            return 0;
        }
        // 返回完整包的长度
        return $length + self::PACKAGE_LENGTH_BYTE;
    }

    /**
     * 将原始的包数据解码成PHP数据
     * @param string $buffer 已经是一个完整的包（包含头部）
     * @return mixed
     */
    public static function decode($buffer)
    {
        // 截取掉头部，获取实际的数据部分
        $data = substr($buffer, self::PACKAGE_LENGTH_BYTE);
        // 这里可以根据你的实际需求进行反序列化，例如JSON
        return json_decode($data, true);
    }

    /**
     * 将PHP数据编码成符合协议格式的二进制字符串
     * @param mixed $data
     * @return string
     */
    public static function encode($data)
    {
        // 将PHP数据序列化成字符串，例如JSON
        $body = json_encode($data);
        // 计算数据体的长度
        $length = strlen($body);
        // 将长度打包成4字节的网络字节序
        $head = pack('N', $length);
        // 拼接头部和数据体
        return $head . $body;
    }
}

// ...
use Protocols\MyProtocol;

$worker = new Worker('tcp://0.0.0.0:2345');
// 注册自定义协议
$worker->protocol = MyProtocol::class; 
// ...

MyProtocol

len

decode

encode

onMessage

len

TcpConnection

InputBuffer

len

InputBuffer

len

len