Node.js Performance Demo
点击上方按钮开始测试...
`);
});
// SSE Endpoint for running the demo
app.get('/api/run-demo', async (req, res) => {
const type = req.query.type;
if (global.isDemoRunning) {
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
res.write(`data: ${JSON.stringify({ type: 'error', message: 'Demo is already running. Please wait.' })}\n\n`);
res.write(`data: ${JSON.stringify({ type: 'end' })}\n\n`);
return res.end();
}
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
global.isDemoRunning = true;
// Helper to send SSE messages
const send = (type, message) => {
res.write(`data: ${JSON.stringify({ type, message })}\n\n`);
};
// Override console methods
const originalConsoleLog = console.log;
const originalConsoleError = console.error;
console.log = (...args) => {
const msg = args.map(arg => (typeof arg === 'object' ? JSON.stringify(arg, null, 2) : String(arg))).join(' ');
send('log', msg);
originalConsoleLog.apply(console, args);
};
console.error = (...args) => {
const msg = args.map(arg => (typeof arg === 'object' ? JSON.stringify(arg, null, 2) : String(arg))).join(' ');
send('error', msg);
originalConsoleError.apply(console, args);
};
try {
switch (type) {
case 'large-file':
await runLargeFileDemo();
break;
case 'xml':
await runXmlDemo();
break;
case 'json':
await runJsonDemo();
break;
case 'core-api':
await runCoreApiDemo();
break;
default:
console.log('未知的任务类型');
}
} catch (e) {
console.error('Unhandled error:', e);
} finally {
// Restore console
console.log = originalConsoleLog;
console.error = originalConsoleError;
global.isDemoRunning = false;
send('end', 'Done');
res.end();
}
});
// API for system info
app.get('/api/system-info', (req, res) => {
exec('uname -a && echo "\\nDisk Usage:" && df -h | head -n 5', (error, stdout, stderr) => {
if (error) {
res.status(500).send(`Error: ${error.message}`);
return;
}
res.send(stdout);
});
});
app.listen(PORT, () => {
console.log(`Server is running on http://localhost:${PORT}`);
});