0

我有一个问题，我正在使用套接字（模块 socketcluster-server）安装一个快速服务器，但是当我发送 http 请求时，快速在大约 20 个请求后被阻止，导致套接字（客户端）通知它们已经用完连接。

有人遇到过你吗？有什么想法可以帮助我解决这个问题吗？

谢谢

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()
    }
})()
4

1 回答 1

1

最后在尝试了很多方法之后，你会尝试如下解决这个问题：

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

目前它工作正常，它接收快速请求和套接字而没有任何阻塞。

我希望这可以帮助某人。

于 2019-12-07T14:02:19.987 回答