socket.js

const SocketIO = require('socket.io')

module.exports = (server) =>{
    const io = SocketIO(server, {path: '/socket.io'})
    io.on('connection', (socket) => {
        const req = socket.request;
        const ip = req.headers['x-forwarded-for'] || req.connection.remoteAddress;
        console.log('새로운 클라이언트 접속!', ip, socket.id, req.ip)
        socket.on('disconnect', ()=>{
            console.log('클라이언트 접속 해제', ip, socket.id)
            clearInterval(socket.interval)
        })
        socket.on('error', (error) =>{
            console.error(error)
        })
        socket.on('reply',(data)=>{
            console.log(data)
        })
        socket.interval = setInterval(()=>{
            socket.emit('news','Hello Socket.IO')
        })
    })


    // const wss = new webSocket.Server({server})
    // wss.on('connection', (ws, req) => {
    //     const ip = req.headers['x-forwarded-for'] || req.connection.remoteAddress;
    //     console.log('새로운 클라이언트 접속', ip);
    //     ws.on('message', (message)=>{
    //         console.log(message)
    //     })
    //     ws.on('errpr', (error)=>{
    //         console.log(error)
    //     })
    //     ws.on('close', ()=>{
    //         console.log('클라이언트 접속 해제', ip)
    //         clearInterval(ws.interval)
    //     })
    //     ws.interval = setInterval(() =>{
    //         if(ws.readyState === ws.OPEN){
    //             ws.send('서버에서 클라이언트로 메시지를 보냅니다.')
    //         }
    //     },3000)
    // })
}