Получать данные из базы данных в реальном времени, используя javascript - PullRequest
Новая
       2

Получать данные из базы данных в реальном времени, используя javascript

0 голосов
/ 06 мая 2020

Я создаю многопользовательскую игру и хочу получать данные из своей базы данных в реальном времени, но я не хочу использовать ajax, я хочу использовать socket.io, node.js ... Но как я мог вижу, что это небезопасно (вход в базу данных находится на стороне клиента, так что поймите, я могу потерять данные в своей базе данных). Итак, как я могу это сделать? .. Например, я хочу получить координаты игроков, а затем отправить их каждому игроку в игре. Спасибо за любые идеи! 

var mysql = require('mysql')
// Let’s make node/socketio listen on port 3000
var io = require('socket.io').listen(3000)
// Define our db creds
var db = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    database: 'node'
})

// Log any errors connected to the db
db.connect(function(err){
    if (err) console.log(err)
})

// Define/initialize our global vars
var notes = []
var isInitNotes = false
var socketCount = 0

io.sockets.on('connection', function(socket){
    // Socket has connected, increase socket count
    socketCount++
    // Let all sockets know how many are connected
    io.sockets.emit('users connected', socketCount)

    socket.on('disconnect', function() {
        // Decrease the socket count on a disconnect, emit
        socketCount--
        io.sockets.emit('users connected', socketCount)
    })

    socket.on('new note', function(data){
        // New note added, push to all sockets and insert into db
        notes.push(data)
        io.sockets.emit('new note', data)
        // Use node's db injection format to filter incoming data
        db.query('INSERT INTO notes (note) VALUES (?)', data.note)
    })

    // Check to see if initial query/notes are set
    if (! isInitNotes) {
        // Initial app start, run db query
        db.query('SELECT * FROM notes')
            .on('result', function(data){
                // Push results onto the notes array
                notes.push(data)
            })
            .on('end', function(){
                // Only emit notes after query has been completed
                socket.emit('initial notes', notes)
            })

        isInitNotes = true
    } else {
        // Initial notes already exist, send out
        socket.emit('initial notes', notes)
    }
})
...