-
Notifications
You must be signed in to change notification settings - Fork 188
/
app.js
145 lines (132 loc) · 4.1 KB
/
app.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
const express = require("express");
const app = express();
const port = process.env.PORT || 3000;
var exec = require("child_process").exec;
const os = require("os");
const { createProxyMiddleware } = require("http-proxy-middleware");
var request = require("request");
//const fetch = require("node-fetch");
const render_app_url = "https://" + process.env.RENDER_EXTERNAL_HOSTNAME;
app.get("/", (req, res) => {
res.send("hello world");
});
app.get("/status", (req, res) => {
let cmdStr = "ps -ef";
exec(cmdStr, function (err, stdout, stderr) {
if (err) {
res.type("html").send("<pre>命令行执行出错:\n" + err + "</pre>");
} else {
res.type("html").send("<pre>命令行执行结果:\n" + stdout + "</pre>");
}
});
});
app.get("/start", (req, res) => {
let cmdStr = "./web.js -c ./config.json >/dev/null 2>&1 &";
exec(cmdStr, function (err, stdout, stderr) {
if (err) {
res.send("命令行执行错误:" + err);
} else {
res.send("命令行执行结果:web.js启动成功!");
}
});
});
app.get("/nezha", (req, res) => {
let cmdStr = "/bin/bash nezha.sh server.abc.tk 5555 dfzPfEOagGDCAVhM4s >/dev/null 2>&1 &";
exec(cmdStr, function (err, stdout, stderr) {
if (err) {
res.send("哪吒客户端部署错误:" + err);
} else {
res.send("哪吒客户端执行结果:" + "启动成功!");
}
});
});
app.get("/info", (req, res) => {
let cmdStr = "cat /etc/*release | grep -E ^NAME";
exec(cmdStr, function (err, stdout, stderr) {
if (err) {
res.send("命令行执行错误:" + err);
} else {
res.send(
"命令行执行结果:\n" +
"Linux System:" +
stdout +
"\nRAM:" +
os.totalmem() / 1000 / 1000 +
"MB"
);
}
});
});
app.use(
"/",
createProxyMiddleware({
target: "http://127.0.0.1:8080/", // 需要跨域处理的请求地址
changeOrigin: true, // 默认false,是否需要改变原始主机头为目标URL
ws: true, // 是否代理websockets
pathRewrite: {
"^/": "/",
},
onProxyReq: function onProxyReq(proxyReq, req, res) {
//console.log("--> ",req.method,req.baseUrl,"->",proxyReq.host + proxyReq.path);
},
})
);
/* keepalive begin */
function keepalive() {
// 1.请求主页,保持唤醒
request(render_app_url, function (error, response, body) {
if (!error) {
console.log("主页发包成功!");
console.log("响应报文:", body);
} else console.log("请求错误: " + error);
});
//2. 本地进程检测,保活web.js
exec("ps -ef", function (err, stdout, stderr) {
if (err) {
console.log("保活web.js-本地进程检测-命令行执行失败:" + err);
} else {
if (stdout.includes("./web.js -c ./config.json"))
console.log("保活web.js-本地进程检测-web.js正在运行");
//命令调起web.js
else startWeb();
if (stdout.includes("/bin/bash nezha.sh"))
console.log("保活哪吒-本地进程检测-哪吒正在运行")
else startNezha();
}
});
}
//保活频率设置为30秒
setInterval(keepalive, 30 * 1000);
/* keepalive end */
function startWeb() {
let startWebCMD = "chmod +x ./web.js && ./web.js -c ./config.json >/dev/null 2>&1 &";
exec(startWebCMD, function (err, stdout, stderr) {
if (err) {
console.log("启动web.js-失败:" + err);
} else {
console.log("启动web.js-成功!");
}
});
}
function startNezha() {
let startNezhaCMD = "/bin/bash nezha.sh server.abc.tk 5555 dfzPfEOagGDCAVhM4s >/dev/null 2>&1 &";
exec(startNezhaCMD, function (err, stdout, stderr) {
if (err) {
console.log("启动哪吒-失败:" + err);
} else {
console.log("启动哪吒-成功!");
}
});
}
/* init begin */
exec("tar -zxvf src.tar.gz", function (err, stdout, stderr) {
if (err) {
console.log("初始化-解压资源文件src.tar.gz-失败:" + err);
} else {
console.log("初始化-解压资源文件src.tar.gz-成功!");
startWeb();
startNezha();
}
});
/* init end */
app.listen(port, () => console.log(`Example app listening on port ${port}!`));