The server to receive data after a number of database connections will become more, eventually leading to error.

[cnsms]

6 clients send data once per minute. About twenty and twenty minutes after the server is being given.

[walkor]

Creating mysql connections without closing them can cause this too many connections error.
So the simple way is just close all mysql connection at the end of onMessage.
The best way is to create a global mysql connection and all requests reuse this connection. It looks like this.

$worker = new Worker(...);
// Global db connection.
$db_connection = null;
$worker->onWorkerStart = function($worker) {
    // Create global db connection.
    global $db_connection;
    $db_connection = new your\db\Connection(....);
};
$worker->onMessage = function($client_connection, $data) {
    // Reuse global db connection.
    global $db_connection;
    $db->connection->query(....);
};

[cnsms]

ok,i'll try it.

[cnsms]

Is not the database can not use tp5?
You write this is a separate re-connected to the database slightly.

[taozywu]

@cnsms

$worker = new Worker(...);
// Global db connection.
$db_connection = null;
$db_configs = [
     "host" => "localhost",
     "user" => "root",
     "dbtable" => "test",
     "password" => "123456!@#",
     "charset" => "",
];
$worker->onWorkerStart = function($worker) {
    // Create global db connection.
    global $db_connection, $db_configs;
    require_once your_path . "/think/db/connector/mysql.php";
    // $db_connection = new \think\db\connector\MySQL($db_configs);
    $db_connection = Db::connect($db_configs);
};

$worker->onMessage = function($client_connection, $data) {
    // Reuse global db connection.
    global $db_connection ;
    $result = $db_connection ->table('')->select();
    file_put_contents("/tmp/tmp.log", var_export($result, true)."\n", FILE_APPEND));
};

--
like this!

[cnsms]

@taozywu ok,i'll try it.