workerman/tests/Feature/UdpConnectionTest.php

<?php

use Symfony\Component\Process\PhpProcess;
use Workerman\Worker;

$serverAddress = 'udp://127.0.0.1:6789';
beforeAll(function () use ($serverAddress) {
    $process = new PhpProcess(<<<PHP
        <?php    
        if(!defined('STDIN')) define('STDIN', fopen('php://stdin', 'r'));
        if(!defined('STDOUT')) define('STDOUT', fopen('php://stdout', 'w'));
        if(!defined('STDERR')) define('STDERR', fopen('php://stderr', 'w'));
        require './vendor/autoload.php';
        use Workerman\Worker;
        
        \$server = new Worker('$serverAddress');
        \$server->onMessage = function (\$connection, \$data) {
            if(str_starts_with(\$data, 'bye')) {
                terminate_current_process();
            }
            \$connection->send('received: '.\$data);
        };
        Worker::\$command = 'start';
        Worker::runAll();
    PHP
    );
    $process->start();
    sleep(5);
});

afterAll(function () use ($serverAddress) {
    $socket = stream_socket_client(self::$serverAddress, timeout: 1);
    fwrite($socket, 'bye');
    fclose($socket);
});

it('tests udp connection', function () use ($serverAddress) {
    $socket = stream_socket_client($serverAddress, $errno, $errstr, 1);
    expect($errno)->toBeInt(0);
    fwrite($socket, 'xiami');
    $data = fread($socket, 1024);
    expect($data)->toBeString('received: xiami');
    fclose($socket);
})
    ->skipOnWindows(); //require posix