一个使用Koa.js编写的简单错误日志采集服务器的示例代码:
const Koa = require('koa');
const Router = require('koa-router');
const bodyParser = require('koa-bodyparser');
const logger = require('winston');// 配置日志
logger.remove(logger.transports.Console);
logger.add(logger.transports.Console, {colorize: true,prettyPrint: true,handleExceptions: true,json: false,silent: false,timestamp: true
});// 创建Koa实例
const app = new Koa();
const router = new Router();// 使用中间件
app.use(bodyParser());// 错误日志采集接口
router.post('/log', async (ctx) => {try {const logEntry = ctx.request.body;logger.error(logEntry);ctx.status = 200;ctx.body = { message: 'Log entry received.' };} catch (err) {ctx.status = 500;ctx.body = { message: 'Server error.' };}
});// 将路由中间件应用到Koa应用程序
app.use(router.routes());// 启动服务器
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {console.log(`Error logging server listening on port ${PORT}...`);
});
这段代码首先配置了Winston日志库来输出日志到控制台。然后创建了一个Koa实例,并使用了koa-bodyparser中间件来处理POST请求的JSON体。接着定义了一个错误日志采集的接口/log,它会接收JSON格式的日志条目,并使用Winston库记录错误。最后,服务器监听在指定的端口上。