Как использовать mysql + web socket?

Question

[generate]

При подключении и выполнении каких то действий пользователя на сервер отправляются данные с помощью webscoket. Но после 3-10 минут скрипт выдает ошибку и все отключается.
Текст ошибки

node:events:491
      throw er; // Unhandled 'error' event
      ^

Error: Connection lost: The server closed the connection.
    at Protocol.end (C:\Users\netli\node_modules\mysql\lib\protocol\Protocol.js:112:13)
    at Socket.<anonymous> (C:\Users\netli\node_modules\mysql\lib\Connection.js:94:28)
    at Socket.<anonymous> (C:\Users\netli\node_modules\mysql\lib\Connection.js:526:10)
    at Socket.emit (node:events:525:35)
    at endReadableNT (node:internal/streams/readable:1359:12)
    at process.processTicksAndRejections (node:internal/process/task_queues:82:21)
Emitted 'error' event on Connection instance at:
    at Connection._handleProtocolError (C:\Users\netli\node_modules\mysql\lib\Connection.js:423:8)
    at Protocol.emit (node:events:513:28)
    at Protocol._delegateError (C:\Users\netli\node_modules\mysql\lib\protocol\Protocol.js:398:10)
    at Protocol.end (C:\Users\netli\node_modules\mysql\lib\protocol\Protocol.js:116:8)
    at Socket.<anonymous> (C:\Users\netli\node_modules\mysql\lib\Connection.js:94:28)
    [... lines matching original stack trace ...]
    at process.processTicksAndRejections (node:internal/process/task_queues:82:21) {
  fatal: true,
  code: 'PROTOCOL_CONNECTION_LOST'
}

Как сделать чтобы не было ошибок ? При каждом выполнении sql запроса открывать новое соединение к mysql и закрывать его ?

Подскажите в каком месте открывать и закрывать соединение в данном случае в базе данных.

const { Server } = require('ws');
const querystring = require('querystring');
const url = require('url');
const mysql = require('mysql');



const server = new Server({ port: 3000 });

var clients = {};

server.on('connection', function connection(ws, request, client) {
    
    const connection = mysql.createConnection({host: '127.0.0.1', user: 'root', password: 'root', database: 'base'});
    
    const q = url.parse(request.url);
    const output = querystring.decode(q.query);
    
    
    if(output.id === undefined) {
        return false;
    }
    
    let id = output.id;
    
    connection.query("UPDATE `user_pay` SET `online` = 1 WHERE `id` = ?", [id]);
    
    clients[id] = id;


    server.clients[id] = ws;

    
    ws.on('message', function message(data) {
        //
    });

    //Закрытие сокета
    ws.on('close', () => {
        connection.query("UPDATE `user_pay` SET `online` = 0 WHERE `id` = ?", [id]);
    });

});

Comments

[szQocks]

Есть ещё какая-то логика на стороне сервере кроме этого файла с сокет подключением ?

[generate]

szQocks, Конечно есть когда приходят сообщения от пользователя записывать в базу данных и отправлять данные пользователю. Но пока что нужно разобраться с завершением соединения mysql

[szQocks]

generate, мне кажется что соединение закрывается потому что mysql соединение работает в рамках сессии то есть с одного сервера ты можешь сделать лишь одно подключение, хоть и максимальное подключение к бд = 151, но если это в рамках разных сессий, хм. Это просто мои мысли, могу и ошибаться.

[generate]

szQocks, Да прогуглив нашел что соединения нужно закрывать быстро и не стоит держать открытыми долгое время. Не знаю правильно ли но решил создать функцию которая будет выполнять sql запросы и с помощью его выполнять мои запросы. Вроде работает нормально

function query(sql, array) {
    const connection = mysql.createConnection({host: '127.0.0.1', user: 'root', password: 'root', database: 'base'})
    connection.connect();
    connection.query(sql, array);
    connection.end();
}

[szQocks]

generate, если этот способ тебя устроит, то пойдёт как вариант.

[szQocks]

generate, так вот я кстати там недоговорил, когда ты отправляешь запрос например на смену имени пользователя - в этот момент у тебя открыто соединение с бд по сокетам, а раз можно иметь только 1 соединение то - когда запрос твой обрабатывается на бэке и пытаешься в базу данных занести что-то ( открывая новое соединение ) - в этот момент , сокет соединение закрывается, проверь и дай пожалуйста обратную связь, так ли это.

[generate]

szQocks, Соединение бд всегда закрыто, открывается только в момент выполнения какого то запроса и сразу закрывается. А сокет соединение всегда открыто если только пользователь не закроет страницу

[szQocks]

generate,

Соединение бд всегда закрыто, открывается только в момент выполнения какого то запроса и сразу закрывается. А сокет соединение всегда открыто если только пользователь не закроет страницу

- да, я знаю, прочитай пожалуйста ещё раз что я попросил)

Я попросил во время открытого соединения сокетов с базой данных - открыть новое соединение с бд, что бы проверить закроется ли сокет соединение с бд.

[generate]

szQocks, а понял, там моментально выполняются запросы ничего не закрывается даже если 100 запросов отправить с клиента на сервер и в каждом из них выполнять sql запросы на добавления. Все добавляется и ничего не закрыватся

[szQocks]

generate, понял, ну тогда я ляпнул чушь про 1 соединение, видимо пора идти спать мне)

отключение инициирует mysql из-за неактивности скорее всего , ответы я так полагаю ты найдёшь здесь - link + здесь link

Answer 1

[mitya_k]

Используй pool для работы с mysql

Pool создается один раз для всего приложения, как правило, но точно не на каждое клиентское соединение по вебсокетам

Comments

[generate]

спасибо годно