Tengo un problema, estoy montando un servidor express con Sockets (modulo socketcluster-server) pero cuando estoy atacando con peticiones http se me queda bloqueado el express al cabo de 20 peticiones aproximadamente, provocando que los Sockets (cliente) avisen de que se han quedado sin conexion.
¿Ha alguien le ha ocurrido? ¿alguna idea que me pueda ayudar resolver este problema?
Adjunto el código de express y como gestiono el Socket en el back:
express.js
const http = require('http'),
express = require('express'),
socket = require('./socket'),
HOST = 'localhost',
PORT = 8000,
bodyParser = require('body-parser');
const app = express()
const httpServer = http.createServer(app);
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: true }));
app.get('/',(req,res)=>res.send({status:"ok"}))
socket.init(httpServer,HOST,PORT)
httpServer.listen(PORT,HOST);
httpServer.on('listening', () =>{
console.log('Express server started on port %s at %s', httpServer.address().port, httpServer.address().address);
});
socket.js
const socketClusterServer = require('socketcluster-server')
module.exports = (() => {
let scServer
const createInstance = (httpServer, host, port) => {
if (!scServer)
scServer = socketClusterServer.attach(httpServer, {host, port});
scServer.on('connection', function (socket) {
console.log('socker: ', scServer.clientsCount)
socket.on('client',getMessageByClient)
})
}
const getMessageByClient = (data) => {
if (data.channel)
sendMessage(data.channel, data)
scServer.removeListener('client', getMessageByClient)
}
const sendMessage = (channel, message) => scServer.exchange.publish(channel, JSON.stringify(message))
const close = () => scServer.close()
return {
init: (httpServer, host, port) => createInstance(httpServer, host, port),
sendMessage: (channel, message) => sendMessage(channel, message),
close: () => close()
}
})()
Muchas gracias de antemano!!!