У меня проблема, я монтирую экспресс-сервер с сокетами (модуль socketcluster-server), но когда я отправляю http-запросы, экспресс блокируется примерно после 20 запросов, в результате чего сокеты (клиент) уведомляют, что у них закончилось соединение.
С тобой кто-нибудь случился? Любые идеи, которые могут помочь мне решить эту проблему?
Спасибо
экспресс.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.info('Express server started on port %s at %s', httpServer.address().port, httpServer.address().address);
});
сокет.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.info('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()
}
})()



![Безумие обратных вызовов в javascript [JS]](https://i.imgur.com/WsjO6zJb.png)


В конце концов, перепробовав множество способов, вы попытаетесь решить эту проблему следующим образом:
// Environment variables
const { env: { HOST, PORT }} = process
//Create http server
const httpServer = require('http')
//Init express
const express = require('express')
const app = express()
// Here would come express configurations and routes
// Attach express to our httpServer
httpServer.on('request', app)
// Init socket with http server
const socket = require('./socket')
socket.init(httpServer, HOST)
// Init http server
httpServer.listen(PORT, HOST)
httpServer.on('listening', async () => {
console.info(`Server started on port ${httpServer.address().port} at ${httpServer.address().address}`)
})
В настоящее время он работает корректно, принимает экспресс-запросы и сокеты без каких-либо блокировок.
Я надеюсь, что это может помочь кому-то.