在socket服务内，如何调用symfony的doctrine服务操作数据库？

Question

在socket服务内，如何调用symfony的doctrine服务操作数据库？

用symfony框架做的php网站项目，需要用到websocket服务，使用的是socketio写的服务在命令行启动，现在需要在socket服务中进行查询和保存数据库操作，应该怎么实现？

服务器程序如下:
<?php

use Workerman\Worker;
use Workerman\WebServer;
use Workerman\Autoloader;
use PHPSocketIO\SocketIO;
require_once dirname(__DIR__,2).'/vendor/autoload.php';

$io = new SocketIO(2021);
$io->on('connection', function($socket) use($io) {
    $socket->addedUser = false;
    $socket->roleType = '';
    var_dump("connection");
    
    $socket->on("message", function($data) use($socket, $io) {
        var_dump($data);
        //此处需要操作数据库

    });

    // 当断开连接时
    $socket->on('disconnect', function () use($socket, $io, $entityManager) {
        var_dump("disconnect");
    });
});

if (!defined('GLOBAL_START')) {
    Worker::runAll();
}