var app = require('express')();
|
var http = require('http').createServer(app);
|
// {cors:true}为设置跨域
|
var io = require('socket.io')(http,{cors:true});
|
|
app.get('/', (req, res) => {
|
res.sendFile(__dirname + '/index.html');
|
});
|
|
|
const sql = require('mysql')
|
// 设置数据库信息
|
const COM_SQL = sql.createConnection({
|
host:'81.68.197.217',
|
user:'root',
|
password:'dba*SN&JCZX@2022',
|
port:'3306',
|
database:'winsom_insole',
|
useConnectionPooling: true
|
})
|
const sql_base = 't_d_insole_data'//要插入的数据表
|
io.on('connection', (socket) => {
|
socket.on('msg',msg=>{
|
// console.log(msg,'data')
|
let data1 = msg.data
|
let time_ = msg.time
|
let serialport = msg.serialport
|
io.emit('output',msg)
|
var sql_ = `INSERT INTO ${sql_base} (posttime,postdata,serialport) VALUES (?,?,?)`
|
COM_SQL.query(sql_,[`${time_}`,`${data1}`,`${serialport}`],(err,result)=>{
|
if(err){
|
console.log(err,"er")
|
}
|
})
|
})
|
socket.on('disconnect',()=>{
|
console.log("123")
|
})
|
});
|
http.listen(3001, () => {
|
console.log('listening。。。。。。。');
|
});
|
|
