Estoy aprendiendo socketIO y configuré y ejecuté un servidor básico de nodejs . Mi problema es que cuando intento conectarme al servidor con mi aplicación nextJS no sucede nada. No se producen errores y no aparecen los mensajes que quiero que se impriman en la conexión.
Mi código :
server.js en la carpeta back-end
const express = require('express'); const app = express(); const server = require('http').Server(app); const { v4: uuidV4 } = require('uuid'); const cors = require('cors'); const io = require('socket.io')(server, { cors: true, origins:["http://localhost:3000"] }); app.use(cors()); app.options('*', cors()); io.on('connection', socket => { socket.on('test',()=>{ console.log(' i am a test') //does not appear }) }) //I ALSO TRIED //io.on('test',()=>{ //console.log('I am a test'); //}) server.listen(5000); Luego, en mi aplicación nextJS en mi carpeta frontend en index.js
import {useEffect} from 'react'; import io from 'socket.io-client'; const ENDPOINT = "http://localhost:5000"; const socket = io.connect(ENDPOINT); export default function Home() { useEffect(()=>{ socket.emit('test'); },[]); ...rest of code }Entonces, en mi aplicación frontend, emito el evento 'prueba' al servidor y el servidor no consoló. Registre la respuesta en la conexión
Agradecería su ayuda ya que soy nuevo en socketIO
Puede crear una función auxiliar en un archivo separado para administrar las conexiones, escuchar eventos y emitir eventos. Aquí hay un ejemplo para lo mismo:
export const socketConnection = io => { io.on("connection", socket => { console.log("Started socket connection!"); socket.on("message", receivedMessage => { console.log("Socket message received", receivedMessage); }); socket.on("subscribe", async room => { try { console.log(`In room`, socket.rooms); await socket.join(room); console.log(`[socket] Room Joined Successfully : ${room}`, room); await io.to(room).emit("subscribeSuccess", `Subscribed successfully ${socket.id}: room - ${socket.rooms}`); } catch (e) { console.log(`[socket] Error in Room Joining : ${room} : ${e}`, e); socket.emit("error", "couldnt perform requested action"); } }); socket.on("unsubscribe", async room => { try { await socket.leave(room); console.log(`[socket] Room Left Successfully : ${room}`, room); } catch (e) { console.log(`[socket] Error in Room Leaving : ${room} : ${e}`, e); socket.emit("error", "couldnt perform requested action"); } }); }); }; Y luego en app.js puede importar e iniciar un servidor de socket.
import { socketConnection } from "@helpers"; const io = new Server(server, { transports: ["websocket", "polling"], allowEIO3: true }); socketConnection(io);Y para conectarse al socket desde el cliente, use esto:
import io from 'socket.io-client'; const ENDPOINT = "http://localhost:5000"; const socket = io(ENDPOINT);