Workerman如何实现自动化测试？Workerman测试框架集成？

kill

onConnect

onMessage

onClose

Worker

Connection

// 核心业务逻辑类
class MessageProcessor
{
    public function process(string $data, ConnectionInterface $connection): string
    {
        // 假设这里是处理消息的业务逻辑
        // 比如解析JSON，查询数据库，然后返回结果
        if ($data === 'ping') {
            $connection->send('pong'); // 这里模拟了发送，实际测试时我们会mock connection
            return 'pong';
        }
        return 'unknown command';
    }
}

// Workerman onMessage 回调（简化版）
class MyWorkerCallback
{
    protected MessageProcessor $processor;

    public function __construct(MessageProcessor $processor)
    {
        $this->processor = $processor;
    }

    public function onMessage(TcpConnection $connection, string $data)
    {
        $result = $this->processor->process($data, $connection);
        // connection->send($result); // 实际中会发送，但在单元测试中我们只关注processor的返回值
    }
}

createMock()

TcpConnection

$connection->send()

send

use PHPUnit\Framework\TestCase;
use Workerman\Connection\TcpConnection; // 假设你用的是Workerman的Connection

class MessageProcessorTest extends TestCase
{
    public function testProcessPingCommand()
    {
        $mockConnection = $this->createMock(TcpConnection::class);
        // 期望 connection->send('pong') 被调用一次
        $mockConnection->expects($this->once())
                       ->method('send')
                       ->with('pong');

        $processor = new MessageProcessor();
        $result = $processor->process('ping', $mockConnection);

        $this->assertEquals('pong', $result);
    }

    public function testProcessUnknownCommand()
    {
        $mockConnection = $this->createMock(TcpConnection::class);
        // 期望 connection->send() 不被调用，或者我们不关心
        $mockConnection->expects($this->never())
                       ->method('send');

        $processor = new MessageProcessor();
        $result = $processor->process('hello', $mockConnection);

        $this->assertEquals('unknown command', $result);
    }
}

// test_worker_server.php
<?php
require_once __DIR__ . '/vendor/autoload.php';

use Workerman\Worker;
use Workerman\Connection\TcpConnection;

// 确保在测试模式下运行，避免与生产环境冲突
if (!defined('IS_TEST_MODE')) {
    define('IS_TEST_MODE', true);
}

// 假设你的Workerman应用入口
$worker = new Worker('websocket://0.0.0.0:8081'); // 使用一个测试端口
$worker->count = 1; // 测试时通常只需要一个进程

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

$worker->onMessage = function(TcpConnection $connection, $data) {
    // 假设这是你的应用逻辑，这里可以调用你的核心业务处理器
    $connection->send("Echo: " . $data);
};

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

Worker::runAll();

setUpBeforeClass()

setUp()

proc_open

symfony/process

use Symfony\Component\Process\Process;
use PHPUnit\Framework\TestCase;

class WorkermanIntegrationTest extends TestCase
{
    protected static ?Process $workerProcess = null;
    protected static string $workerHost = '127.0.0.1';
    protected static int $workerPort = 8081;

    public static function setUpBeforeClass(): void
    {
        // 启动Workerman测试服务
        self::$workerProcess = new Process(['php', __DIR__ . '/test_worker_server.php', 'start', '-d']); // -d 后台运行
        self::$workerProcess->start();

        // 等待服务启动，可能需要一点时间
        sleep(2); // 简单的等待，实际可能需要更健壮的检查机制
    }

    public static function tearDownAfterClass(): void
    {
        // 停止Workerman测试服务
        if (self::$workerProcess && self::$workerProcess->isRunning()) {
            self::$workerProcess->stop();
        }
    }

    // ... 后续测试方法
}

use PHPUnit\Framework\TestCase;
use WebSocket\Client; // 使用 textalk/websocket 库

class WorkermanIntegrationTest extends TestCase
{
    // ... setUpBeforeClass, tearDownAfterClass (如上所示)

    public function testWebSocketEchoService()
    {
        $client = new Client("ws://".self::$workerHost.":".self::$workerPort);
        $client->send("Hello Workerman!");
        $message = $client->receive();
        $client->close();

        $this->assertEquals("Echo: Hello Workerman!", $message);
    }

    public function testAnotherWebSocketMessage()
    {
        $client = new Client("ws://".self::$workerHost.":".self::$workerPort);
        $client->send("How are you?");
        $message = $client->receive();
        $client->close();

        $this->assertEquals("Echo: How are you?", $message);
    }
}