Express服务器被套接字阻塞

问题描述 投票:0回答:1

[我有问题,我正在使用Sockets安装快速服务器(模块socketcluster-server),但是当我发送HTTP请求时,大约20个请求后,Express被阻止,导致Sockets(客户端)通知它们已用完连接。

有人发生在你身上吗?有什么想法可以帮助我解决这个问题吗?

谢谢

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()
    }
})()
javascript node.js sockets express socketcluster
1个回答
0
投票

最后尝试了许多方法之后,您将尝试如下解决此问题:

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

当前,它工作正常,它接收到明确的请求和套接字,没有任何阻塞。

我希望这可以帮助某人。

© www.soinside.com 2019 - 2024. All rights reserved.