[我有问题,我正在使用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()
}
})()
最后尝试了许多方法之后,您将尝试如下解决此问题:
// 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}`)
})
当前,它工作正常,它接收到明确的请求和套接字,没有任何阻塞。
我希望这可以帮助某人。