socket.io를 사용하여 소켓으로 mysql 데이터베이스에 연결할 때 오류

2 개의 문제를 볼 수 있습니다.

1. DB 서버가 연결을 거부하고 있습니다.
2. 쿼리 개체가 유효하지 않습니다.

먼저 MySQL 자격 증명이 올바른지, MySQL이 실행 중인지 확인하십시오. 사용자가 지정된 호스트 이름에서 연결할 수 있습니까?

위의 문제가 해결되면 다음 문제는 "connection.query"입니다.

io.sockets.on('connection', (socket){

위의 라이브 "연결"에서 이벤트는 MySQL 쿼리와 관련이 없습니다.

귀하의 쿼리는

db.query(query, (err, rows, fields) => {

'db'Object는 MySQL의 연결 정보를 담고 있습니다.

다음은 서버 측 및 클라이언트 측의 전체 작업 코드입니다.

// server.js
const HTTP = require('http');
const mysql = require('mysql');
server = HTTP.createServer();
var io = require('socket.io')(server,{
    pingInterval: 5000,
    pingTimeout: 2500,
    cookie: false
});
server.listen(8080);

var MySQLConnection = mysql.createConnection({
    host: "localhost",
    user: "yourusername",
    password: "yourpassword",
    database: "mydb"
});

MySQLConnection.connect(function(err) {
    if (err) {
        console.log('MySQL COnnection Error --> ' + err);
    }
    else{
        console.log("MySQL Connected Successfully");
    }
});

io.on('connection',function(socket){
    socket.emit('greeting', 'Hello');
    socket.on('checkUser', (data) => {
        const email = data['email'];
        const query = "SELECT * FROM table1 WHERE email ='" +email+"'";
        MySQLConnection.query(query, (err, result, fields) => {
            if (err) {
                console.log('MySQL Query Error --> '+ err);
            }
            else{
                console.log(result);
            }
        });
    });
});

그리고 여기 클라이언트입니다

<!-- client.html -->
<script src="http://SERVERIP:8080/socket.io/socket.io.js"></script>
<script>
var socket = io('http://SERVERIP:8080', {
    transports: [ 'websocket' ],
    'reconnection': true,
    'reconnectionDelay': 500,
    'reconnectionDelayMax': 1000,
    'reconnectionAttempts': 100
});

socket.on('connect', onConnect);
socket.on('greeting', onGreeting);


function onConnect(){
    console.log('Connected Successully...'); 
}
function onGreeting(DATA){
    console.log('onGreeting --> DATA --> ' + DATA); 
    var sendData = {
        email: '[email protected]'
    }
    socket.emit('checkUser',sendData);
}

</script>