-
Notifications
You must be signed in to change notification settings - Fork 1
/
jointServer.js
61 lines (52 loc) · 1.53 KB
/
jointServer.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
var spawn = require('child_process').spawn;
var path = require('path');
var childCwd = path.join(__dirname);
const scriptPath = './main.py';
const excute = 'python'
const express = require('express')
const http = require('http');
const socketIO = require('socket.io');
const app = express();
const server = http.createServer(app);
var child = spawn(excute, [scriptPath], { cwd: childCwd, encoding: 'utf8' });
console.log('子进程接入');
let mode=true;
const io = socketIO(server, {
cors: {
origin: '*'
}
});
app.get('/', (request, response) => {
io.emit('message', '服务端向客户端推送消息...');
response.writeHead(200, { "Content-type": "text/plain" });
response.end();
});
io.on('connection', (socket) => {
console.log('user connected');
mode = true
socket.on("User", (msg) => {
console.log('Send was pressed...');
console.log(msg);
if(mode){
console.log('mode 1');
msg="1"+msg;
}
else{
console.log('mode 0');
msg="0"+msg;
}
const encodedData = Buffer.from(msg, 'utf-8');
console.log('网页端发来的数据是:', encodedData);
child.stdin.write(encodedData+'\n');
});
socket.on('Change_mode',()=>{
mode=!mode;
})
child.stdout.on('data', function (output) {
console.log('result:', output.toString());
io.emit('response', output.toString());
});
});
server.listen(3001, () => {
console.log("server is up and running on port 3001");
});