我正在尝试构建一个Symfony 4.3.3命令,我想在其中添加随时可以覆盖回调函数的功能。查看以下代码片段:

namespace App\Command;

use Swoole\Http\Request;
use Swoole\Http\Response;
use Swoole\WebSocket\Server;

final class SwooleWsCommand extends Command
{
    // ...

    protected function execute(InputInterface $input, OutputInterface $output): bool
    {
        $port   = $input->getArgument('port');
        $server = new SwooleServer("127.0.0.1", (int)$port);
        $server->on('request', static function (Request $request, Response $response) {
            $response->end('Hello '.$request->rawcontent());
        });
        $server->start();
        return true;
    }
}

我想将其转换为:

$server->on('request', static function (Request $request, Response $response) {
    $response->end('Hello '.$request->rawcontent());
});

对此(如果可能的话,这不是一件疯狂的事情,或者不可能实现):

$server->on('request', <function>);

我的想法(可能完全错了)是创建一个接口,该接口允许随时覆盖这些方法。以下是其代码片段:

namespace App\Service;

use Swoole\Http\Request;
use Swoole\Http\Response;
use Swoole\WebSocket\Frame;
use Swoole\WebSocket\Server;

interface SwooleWsCallbackInterface
{
    public function request(Request $request, Response $response): void;
    public function message(Server $server, Frame $frame): void;
}

从那里,我应该能够在命令中注入接口,例如:

/** @var SwooleWsCallbackInterface */
private $callback;

public function __construct(SwooleWsCallbackInterface $callback)
{
    $this->callback = $callback;
    parent::__construct();
}

您可能会注意到,功能request()接收两个参数。因此,一旦我从命令中以$server->on('request', $this->callback->request($request, $response));调用该方法,它将尝试访问两个参数。

我已经阅读了如何自动连接接口的Symfony文档,但对我来说仍然不清楚如何正确设置该方法工作所需的参数。

如果我在这里正确理解了文档:

 App\Util\TransformerInterface: '@App\Util\Rot13Transformer'

他们已经覆盖了App\Util\Rot13Transformer上的方法,应该没有任何问题。但是,该示例未显示来自被调用接口TransformerInterface的方法transform

不知道在我的情况下是否正确的自动装配是:

  App\Command\SwooleWsCommand: ~
  sdk.command.swoolews:
    alias: App\Command\SwooleWsCommand

  App\Service\SwooleWsCallbackInterface: ~
  sdk.swoolews:
    alias: App\Service\SwooleWsCallbackInterface

我可以在这里获得一些有关如何实现此目标的想法吗?以及如何工作的一些解释?我可能弄错了:|

Note: if something is not clear or it's confusing just ask me

分析解答

您仍然想要创建一个闭包以传递给$server->on。您可以这样做:

$onRequest = Closure::fromCallable([$this->callback, 'request']);

然后通过:

$server->on('request', $onRequest);