Экспресс-сервер заблокирован сокетами

У меня проблема, я монтирую экспресс-сервер с сокетами (модуль 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.log('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.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()
    }
})()

node.js javascript sockets express socketcluster
person planta4    schedule 20.07.2019    source источник

Ответы (1)


arrow_upward
1
arrow_downward

В конце концов, перепробовав множество способов, вы попытаетесь решить эту проблему следующим образом:

// 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}`)
})

В настоящее время он работает корректно, принимает экспресс-запросы и сокеты без каких-либо блокировок.

Я надеюсь, что это может помочь кому-то.

person planta4    schedule 07.12.2019