Как использовать живое подключение к mysql (Workerman\Mysql\Connection)?

Question

[Abdulla Timershin]

Использую библиотеку walkor/Workerman для создания websocket.
Также у этого разработчика есть библиотека Workerman\Mysql\Connection для живого подключения к бд.
Может кто работал с этим поможет.

require_once("workerman/vendor/autoload.php");
require_once("mysql/vendor/autoload.php");

// SSL context.
$context = array(
    'ssl' => array(
        'local_cert'  => '/your/path/of/server.pem',
        'local_pk'    => '/your/path/of/server.key',
        'verify_peer' => false,
    )
);

// Create a Websocket server with ssl context.
$ws_worker = new Worker('websocket://0.0.0.0:2346', $context);
$db = new Workerman\MySQL\Connection('host', "port", "user", "pass", "dbname");

// Enable SSL. WebSocket+SSL means that Secure WebSocket (wss://). 
// The similar approaches for Https etc.
$ws_worker->transport = 'ssl';

$ws_worker->onMessage = function ($connection, $data) {
    $query = $db->row("query text");
    // Send hello $data
    $connection->send('Hello ' . $data);
};

Worker::runAll();

Так при подключении клиента и получении сообщения, т.е onMessage, выводит ошибку что db = null

require_once("workerman/vendor/autoload.php");
require_once("mysql/vendor/autoload.php");

// SSL context.
$context = array(
    'ssl' => array(
        'local_cert'  => '/your/path/of/server.pem',
        'local_pk'    => '/your/path/of/server.key',
        'verify_peer' => false,
    )
);

// Create a Websocket server with ssl context.
$ws_worker = new Worker('websocket://0.0.0.0:2346', $context);
$db = new Workerman\MySQL\Connection('host', "port", "user", "pass", "dbname");
$query1 = $db->row("query text");

// Enable SSL. WebSocket+SSL means that Secure WebSocket (wss://). 
// The similar approaches for Https etc.
$ws_worker->transport = 'ssl';

$ws_worker->onMessage = function ($connection, $data) {
   $query2 = $db->row("query text");
    // Send hello $data
    $connection->send('Hello ' . $data);
};

Worker::runAll();

Если проверить и сделать запрос вначале, то в query1 он вернет то что нужно, но в функциях(query2) выйдет та же ошибка

Куда правильно его вставить?

Answer 1

[Vladimir Protsenko]

$ws_worker->onMessage = function ($connection, $data) use ($db) {
// ...
});

Comments

[Abdulla Timershin]

Сейчас попробую. Это же не будет при каждом выполнении функции снова открывать соединение с mysql?

[Abdulla Timershin]

Спасибо! Работает!

[Vladimir Protsenko]

Abdulla Timershin, не будет, это всего лишь передача переменной в область видимости анонимной функции.

[Abdulla Timershin]

Vladimir Protsenko, Большое спасибо!

Answer 2

[Dilce989]

У меня вопрос к автору, а где вы взяли эту библиотеку, перерыл весь интернет, даже нашел страницу самого Workerman и документацию, обычный mysql вживить не даёт, pdo запрос на подключение сделал, вводя одно сообщение выводит его а затем просто отключает сервер, поделитесь пожауйста

Comments

[lexspeedkb]

Вот ссылка на composer-пакет.