Belajar Swoole - Timers & Process

#Pendahuluan

Setelah di episode 9 kita membangun aggregator API yang memanggil banyak upstream secara parallel — pada episode kali ini kita berurusan dengan waktu dan proses. Dua hal yang sering diabaikan developer PHP-FPM, karena FPM tidak pernah memberi kalian kontrol atas keduanya.

Mengapa episode ini penting? Karena aplikasi realtime tidak bisa menunggu cron menit demi menit. Membersihkan koneksi basi, mengirim heartbeat, merotasi log, menjadwalkan batch — semuanya harus hidup di dalam server. Dan saat beban tumbuh, kalian juga harus tahu cara menambah proses di luar arsitektur worker standar.

#Swoole Timer: Tick dan After

Swoole menyediakan dua jenis timer:

Contoh dasar:

use Swoole\Timer;
 
// Setiap 2 detik, log counter
$timerId = Timer::tick(2000, function () {
    echo date('H:i:s') . " tick\n";
});
 
// Setelah 10 detik, hentikan timer tick
Timer::after(10000, function () use ($timerId) {
    Timer::clear($timerId);
    echo "Timer dihentikan\n";
});

Timer::clear($id) membatalkan timer — sangat penting untuk mencegah kebocoran timer saat worker direcycle atau koneksi ditutup.

#Pola Cron-Like Scheduling

Timer memungkinkan penjadwalan yang lebih fleksibel daripada cron. Pola umumnya: hitung selisih ke target berikutnya, lalu after():

use Swoole\Timer;
 
function scheduleNextHourly(callable $job): void
{
    $now = time();
    $next = (intdiv($now, 3600) + 1) * 3600; // jam berikutnya tepat
    $delayMs = ($next - $now) * 1000;
 
    Timer::after($delayMs, function () use ($job) {
        $job();
        scheduleNextHourly($job); // jadwalkan lagi
    });
}
 
scheduleNextHourly(fn () => echo "Laporan jam " . date('H') . "\n");

Pola ini lebih akurat daripada men-set tick(3600000) karena tidak menggeser fase seiring waktu. Untuk kebutuhan kompleks, pertimbangkan library penjadwalan seperti cron-expression + Timer.

#Swoole Process: Proses Tambahan

Swoole\Process memberi kalian fork proses eksternal dari dalam server. Ini berguna untuk tugas yang tidak cocok di worker biasa maupun task worker — misal consumer MQ, atau proses daemon pelengkap.

use Swoole\Process;
 
$process = new Process(function (Process $worker) {
    $worker->write("Halo dari child!\n");
});
 
$pid = $process->start();
echo "Parent menerima: " . $process->read();
$process->wait();

Alur eksekusi: start() mem-fork — kode di callback berjalan di proses anak, sedangkan start() di proses induk mengembalikan PID anak. read()/write() berkomunikasi lewat pipe.

#Menambahkan Proses ke Server

Server Swoole juga bisa mengelola proses custom lewat addProcess() — proses ini hidup di bawah Master dan ikut di-manage (restart saat mati):

<?php
use Swoole\Server;
use Swoole\Process;
 
$server = new Server('0.0.0.0', 9501);
 
$custom = new Process(function (Process $proc) use ($server) {
    while (true) {
        $message = $proc->read();
        if ($message !== false) {
            $server->sendMessage("Custom: $message", 0); // kirim ke worker 0
        }
    }
}, false, SOCK_DGRAM);
 
$server->addProcess($custom);
 
$server->on('Receive', function ($server, $fd, $reactorId, $data) {
    echo "Terima: $data\n";
});
 
$server->start();

Proses custom sangat berguna untuk consumer antrian yang berjalan terus-menerus di samping server — kita pakai lagi di episode 14 (message brokers).

#Inter-Process Communication (IPC)

Worker-worker Swoole perlu saling bicara dalam beberapa skenario:

Contoh broadcast ke semua worker dari satu worker:

use Swoole\Server;
 
$server->on('WorkerStart', function (Server $server, int $workerId) {
    if ($workerId === 0) {
        // worker pertama mengumumkan ke worker lain
        for ($i = 1; $i < $server->setting['worker_num']; $i++) {
            $server->sendMessage('reload-cache', $i);
        }
    }
});
 
$server->on('PipeMessage', function (Server $server, int $srcWorkerId, $message) {
    echo "Worker {$srcWorkerId}: $message\n";
});

#Common Pitfalls

#Penutup

Pada episode 10 ini, kalian telah menguasai timer dan pengelolaan proses.

Inti yang harus dibawa pulang:

• Timer::tick untuk interval; Timer::after untuk sekali; Timer::clear untuk membatalkan.
• Pola cron-like: hitung selisih ke target lalu after() — fase tidak bergeser.
• Timer global hanya di satu worker agar tidak dobel.
• Swoole\Process untuk fork; addProcess() menempatkan proses custom di bawah Master.
• IPC antar worker lewat sendMessage/on('PipeMessage').

Di episode 11 selanjutnya, kita membawa pekerjaan berat keluar dari worker: Task Worker untuk CPU-bound work — image processing, PDF, dan pengiriman email async lewat task pool. Sampai jumpa di episode 11!