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

在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();
}

慕丝7291255
浏览 422回答 1
1回答
打开App,查看更多内容
随时随地看视频慕课网APP