90 lines
2.4 KiB
TypeScript
90 lines
2.4 KiB
TypeScript
import http from 'http'
|
|
import express from 'express'
|
|
import cors from 'cors'
|
|
import { RedisPresence, Server } from 'colyseus'
|
|
import { monitor } from '@colyseus/monitor'
|
|
import rateLimit from 'express-rate-limit'
|
|
import { GeneralRoom } from './rooms/GeneralRoom'
|
|
import { initData } from './common/GConfig'
|
|
import { Config } from './cfg/Config'
|
|
import { RankedLobbyRoom } from './rooms/RankedLobbyRoom'
|
|
import { MongooseDriver } from 'colyseus/lib/matchmaker/drivers/MongooseDriver'
|
|
import { Service } from './service/Service'
|
|
import { RedisClient } from './redis/RedisClient'
|
|
|
|
require('./rooms/MSender')
|
|
require('./rooms/RoomExtMethod')
|
|
require('./common/Extend')
|
|
|
|
const isProd = process.env.NODE_ENV === 'production'
|
|
|
|
let config: Config = require('../config/config.json')
|
|
|
|
const app = express()
|
|
|
|
|
|
app.use(cors())
|
|
app.use(express.json())
|
|
initData()
|
|
global.isProd = isProd
|
|
const server = http.createServer(app)
|
|
let port: number
|
|
let gameServer: Server
|
|
if (isProd) {
|
|
port = Number(process.env.PORT) + Number(process.env.NODE_APP_INSTANCE)
|
|
gameServer = new Server({
|
|
server,
|
|
driver: new MongooseDriver(config.mongodb),
|
|
presence: new RedisPresence({ url: config.redis })
|
|
})
|
|
} else {
|
|
port = Number(process.env.PORT || 2567)
|
|
gameServer = new Server({
|
|
server
|
|
})
|
|
}
|
|
|
|
|
|
// register your room handlers
|
|
gameServer.define('general_room', GeneralRoom)
|
|
gameServer
|
|
.define('match_room', RankedLobbyRoom)
|
|
.filterBy(['numClientsToMatch'])
|
|
/**
|
|
* Register @colyseus/social routes
|
|
*
|
|
* - uncomment if you want to use default authentication (https://docs.colyseus.io/server/authentication/)
|
|
* - also uncomment the import statement
|
|
*/
|
|
// app.use("/", socialRoutes);
|
|
|
|
// register colyseus monitor AFTER registering your room handlers
|
|
app.use('/colyseus', monitor())
|
|
|
|
// 限制每2分钟最多连接 max次, 防止恶意的创建空房间
|
|
const apiLimiter = rateLimit({
|
|
windowMs: 2 * 60 * 1000, // 2 minutes
|
|
max: 20
|
|
})
|
|
app.use('/matchmake/', apiLimiter)
|
|
|
|
// 设置反向代理后, 须设置该值
|
|
// see https://expressjs.com/en/guide/behind-proxies.html
|
|
app.set('trust proxy', 1)
|
|
|
|
let opts = { url: config.redis }
|
|
new RedisClient(opts)
|
|
const services = new Service()
|
|
gameServer.onShutdown(function () {
|
|
console.log('master process is being shut down!')
|
|
//TODO:: 保存所有数据至db, 重启时恢复
|
|
})
|
|
services.registSelf(port)
|
|
.then(() => {
|
|
return gameServer.listen(port)
|
|
}).then(() => {
|
|
console.log(`Listening on ws://localhost:${ port }`)
|
|
})
|
|
|
|
|