Узел + Mysql + Socket IO + PROTOCOL_CONNECTION_LOST

Peeka спросил: 11 июня 2018 в 10:35 в: mysql

Версии:

Узел JS: 7.2.1

Экспресс: 4.15.3

MySQL NPM: 2.14.1

Socket IO: 2.1.1

Мы только что представили сокеты в нашем приложении в попытке запустить уведомления. Но с тех пор моя база данных просто не подключается.

Я продолжаю получать ошибку PROTOCOL_CONNECTION_LOST : Connection lost: The server closed the connection.. Я пробовал это и это . Они, похоже, не работают.

Соединение установлено не в первый раз, но если я установилInterval на событие ошибки и попытаюсь повторно подключиться через какое-то время, он подключится .. но некоторые из них, как новый объект подключения не используется.

Я переключаю свою ветку. соединение работает безупречно. Есть и другие члены команды, которые работают одновременно, и у них нет никаких проблем с подключением. Поэтому я предполагаю, что это связано с тем, как я реализовал уведомления.

Это мои файлы ниже:

// socket.js

import server from './../../server.js';
import SocketIO from "socket.io";
import nconf from "nconf";
import eventService from "../../events/service.js";module.exports.initSocket = (IO) => {
    let event = eventService(IO);
    let notificationEmissionInterval = nconf.get('NOTIFICATION_INTERVAL_MILLISECONDS');    IO.on("connection", (socket) => {
        setInterval(() => {
            event.emitNotifications(socket);
        }, notificationEmissionInterval);
    });
};if (server) {
    let IO = new SocketIO(server);
    module.exports.initSocket(IO);
}

// service.js

import path from 'path';
import logger from '../config/lib/logger.js';
import notificationController from "../module/notification/controller/notification.controller.js";module.exports = (IO) => {
    let emitNotifications = (socket) => {   
        notificationController.getUnreadNotifications(params)
        .then((notifications) => {
        //Do something
        )
    };    return {
        emitNotifications: emitNotifications,
    }
};

// Model.js

import connection from '../../../config/lib/db.js';
import logger from 'logger';
import Promise from 'bluebird';class NotificationModel {    getUnreadNotifications = () => {
        return new Promise((resolve, reject) => {
            let query = `CALL GetUnreadNotification()`;
            connection.query(query, (err, result) => {
                if (err) {
                    logger.error('Sql error in NotificationModel.getUnreadNotifications : ', err);
                    reject(err);
                }
                else {
                    logger.info('Unread notifications fetched successfully');
                    resolve(result);
                }
            });
        });
    };}
export default new NotificationModel();

В настоящий момент файл базы данных [ после много отладки] выглядит ниже. Комментирование этого файла из импорта в модели уведомления устраняет ошибку.

// db.js

import mysql from 'mysql';
import nconf from 'nconf';
import logger from './logger.js';
import path from 'path';nconf.argv()
    .env()
    .file({
        file: path.resolve('./config.json')
    });let dbConfig = {
    "host": nconf.get('MYSQL_HOST'),
    "port": nconf.get('MYSQL_PORT'),
    "user": nconf.get('MYSQL_USER'),
    "password": nconf.get('MYSQL_PASSWORD'),
    "database": nconf.get('MYSQL_DATABASE'),
    "stringifyObjects":true,
    "multipleStatements": true,
    "dateStrings" : 'DATETIME',
    "connectTimeout" : 60000
};function connectToDatabase() {
    logger.info('Trying to connect to the database');
    let _conn = mysql.createConnection(dbConfig);    _conn.connect((err) => {
        if (err) {
            logger.error('Error connecting to the database');
            logger.debug(err.code + ' : ' + err.message);
            setTimeout(connectToDatabase, 3000);
        }
        else {
            logger.info('Connected to the database via threadId : ' + _conn.threadId);
            return _conn;
        }
    });    _conn.on('error', (err) => {
        logger.error('Error connecting to the database');
        logger.debug(err.code + ' : ' + err.message);
        setTimeout(connectToDatabase, 3000);
    });
}let connection = connectToDatabase();export default connection;

Любая помощь приветствуется.

0 ответов