PHP Swoole/WebMan/Laravel Octane 等长驻进程框架内存泄露诊断与解决方案 ​

<?php
final class LeakWatch
{
    /** @var WeakMap<object,array{label:string,createdAt:float,trace?:array}> */
    private WeakMap $seen;

    public function __construct()
    {
        $this->seen = new WeakMap();
    }

    /**
     * 跟踪一个应该短生命周期的对象。
     * @param array $context 例如 ['label' => 'Order DTO', 'trace' => debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS, 5)]
     */
    public function watch(object $o, array $context): void
    {
        $context['createdAt'] = microtime(true);
        $context['label'] ??= get_debug_type($o);
        $this->seen[$o] = $context;
    }

    /** @return array<int,array{label:string,count:int,oldest:float,newest:float}> */
    public function histogram(float $olderThanSeconds = 2.0): array
    {
        $now = microtime(true);
        $buckets = [];

        foreach ($this->seen as $obj => $meta) {
            $age = $now - $meta['createdAt'];
            if ($age < $olderThanSeconds) {
                continue; // 最近创建的；不可疑
            }

            $label = $meta['label'];
            $buckets[$label]['label'] = $label;
            $buckets[$label]['count'] = ($buckets[$label]['count'] ?? 0) + 1;
            $buckets[$label]['oldest'] = isset($buckets[$label]['oldest'])
                ? min($buckets[$label]['oldest'], $meta['createdAt'])
                : $meta['createdAt'];
            $buckets[$label]['newest'] = isset($buckets[$label]['newest'])
                ? max($buckets[$label]['newest'], $meta['createdAt'])
                : $meta['createdAt'];
        }

        // 按数量倒序排列
        usort($buckets, fn($a,$b) => $b['count'] <=> $a['count']);

        return array_values($buckets);
    }
}

$leakWatch = new LeakWatch();

function handleJob(Job $job, LeakWatch $leakWatch) {
    $dto = OrderDto::from($job->payload);
    $leakWatch->watch($dto, [
        'label' => 'OrderDto',
        // 保持回溯小巧；如果需要可以在标志后面添加
    ]);

    // ... 处理 ...
}

if ($i % 30 === 0) {
    $suspicious = $leakWatch->histogram(olderThanSeconds: 5.0);
    foreach ($suspicious as $row) {
        fprintf(STDERR, "[leakwatch] %s stuck x%d (oldest %.1fs ago)\n",
            $row['label'], $row['count'], microtime(true) - $row['oldest']);
    }
}

$listener = function (Order $order) use ($container, $logger) {
    // ...
};
$dispatcher->addListener('order.created', $listener);

// ... 稍后 ...
// $dispatcher 从不移除 $listener 并保持对它的强引用。

$dispatcher->addListener('order.created', static function (Order $o) {
    OrderCreatedHandler::handle($o); // 没有 $this，没有捕获的 $container
});

final class WeakListenerBus
{
    /** @var array<string, array<int, WeakReference>> */
    private array $listeners = [];

    public function listen(string $event, object $listener): void
    {
        $this->listeners[$event][] = WeakReference::create($listener);
    }

    public function dispatch(object $event): void
    {
        $alive = [];
        foreach ($this->listeners[get_class($event)] ?? [] as $ref) {
            if ($obj = $ref->get()) {
                $obj($event);
                $alive[] = $ref;
            }
        }
        $this->listeners[get_class($event)] = $alive; // 清扫死的
    }
}

function heap_snapshot(string $why): void {
    if (!function_exists('meminfo_dump')) {
        return;
    }

    $ts = date('Ymd-His');
    $file = "/tmp/heap-{$ts}-" . preg_replace('/\W+/', '_', $why) . ".json";
    meminfo_dump($file); // 或你的工具期望的格式
    fprintf(STDERR, "[heap] dumped snapshot: %s\n", $file);
}

Closure
└── static $this => Some\LongLived\Service
    └── $container => Pimple\Container
        └── services => array
            └── ...

Doctrine\ORM\UnitOfWork
└── identityMap => array
    └── App\Entity\Order#123 => Order

<?php
final class Worker
{
    public function __construct(
        private MessageQueue $queue,
        private LeakWatch $leakWatch,
        private int $maxJobs = 500,
        private int $softBytes = 256 * 1024 * 1024,
    ) {}

    public function run(): void
    {
        gc_enable(); // 在 workers 中明确启用
        $jobs = 0;

        while (true) {
            $msg = $this->queue->reserve(timeout: 5);
            if (!$msg) {
                $this->housekeeping($jobs);
                continue;
            }

            try {
                $this->handle($msg);
            } finally {
                $this->afterJob($jobs);
                $jobs++;

                if ($jobs >= $this->maxJobs || memory_get_usage(true) > $this->softBytes) {
                    heap_snapshot('soft-exit');
                    fwrite(STDERR, "[worker] Soft exit after {$jobs} jobs; RSS=".memory_get_usage(true)."\n");
                    return; // 让监督器重启我们
                }
            }
        }
    }

    private function handle(Message $msg): void
    {
        // 典型的观察位置
        $dto = PayloadDto::from($msg->body);
        $this->leakWatch->watch($dto, ['label' => 'PayloadDto']);

        // ... 域逻辑 ...
    }

    private function afterJob(int $jobs): void
    {
        // 清洁
        gc_collect_cycles();
        gc_mem_caches();

        // ORM/客户端重置（示例）
        if (isset($this->em)) { $this->em->clear(); }
        if ($this->http) { $this->http->reset(); } // 例如，如果需要，丢弃保持活着的池

        // 定期内省
        if ($jobs % 50 === 0) {
            foreach ($this->leakWatch->histogram(olderThanSeconds: 10.0) as $row) {
                fprintf(STDERR, "[leakwatch] %s stuck x%d (oldest %.1fs)\n",
                    $row['label'], $row['count'], microtime(true) - $row['oldest']);
            }
        }
    }

    private function housekeeping(int $jobs): void
    {
        // 定时任务的地方；空闲时避免漂移
    }
}

final class TopSurvivors
{
    /** @var WeakMap<object,array{label:string,createdAt:float}> */
    private WeakMap $w;

    public function __construct() {
        $this->w = new WeakMap();
    }

    public function mark(object $o, string $label = null): void {
        $this->w[$o] = ['label' => $label ?? get_debug_type($o), 'createdAt' => microtime(true)];
    }

    public function report(int $limit = 10, float $age = 5.0): void {
        $now = microtime(true);
        $rows = [];

        foreach ($this->w as $obj => $m) {
            $a = $now - $m['createdAt'];
            if ($a < $age) continue;
            $rows[] = [$m['label'], $a];
        }

        usort($rows, fn($a,$b) => $b[1] <=> $a[1]);

        foreach (array_slice($rows, 0, $limit) as [$label, $ageSec]) {
            fprintf(STDERR, "[survivor] %-30s %.1fs old\n", $label, $ageSec);
        }
    }
}