我试图在一个nodejs react应用程序中上传一个文件。文件的上传工作很好,但我有一些问题,当我想让我的 await.post()
请求。当我上传文件时,我做了一个spinner来显示文件正在上传,我希望这个spinner在上传完成后停止,然后显示一条信息,告知用户加载完成。
我解释一下问题,因为它有点复杂。
当我在本地工作时,.NET Framework 2.0系统会自动运行。
两分钟后(我计时了解),我的浏览器控制台显示错误信息 net::ERR_EMPTY_RESPONSE
.但在服务器端,一切都在继续,请求顺利结束。但在前端,即使请求结束,我的post请求向客户端发送res信息时,我的spinner也没有停止转动。
我想这是我的服务器超时的问题,所以我做了很多测试,在我的服务器中设置了setTimeout。
var server = app.listen(PORT, () =>
console.log(`Server started on port ${PORT}`)
);
server.timeout = 3840000;
也在我的路由请求中。
router.post('/', async (req, res) => {
req.setTimeout(3600000);
甚至我还尝试改变了我的 axios.post
功能在客户端。
const res = await axios.post('/api/students', newFile, {
timeout: 3600000,
});
但是没有任何东西可以处理我的问题。
奇怪的是,当应用程序被托管后,问题就不一样了!事实上,没有任何错误信息,但1分钟后,微调器就无故停止了。
事实上,没有任何错误信息,但1分钟后,微调器无故停止。
我做了很多研究,但没有任何办法解决我的问题,现在我已经用了几天了,我不明白为什么。我想可能是代理问题或者浏览器超时,但我不知道...
如果你有哪怕是一个小的线索,它可以帮助我很多! 谢谢您的帮助!
更新。
我的apistudent路由的代码
const express = require('express');
const router = express.Router();
const fileUpload = require('express-fileupload');
const Student = require('../../models/Student');
const CSVToJSON = require('csvtojson');
const utf8 = require('utf8');
var accents = require('remove-accents');
const NodeGeocoder = require('node-geocoder');
const sleep = require('util').promisify(setTimeout);
let msg = 'Etudiants ajoutés à la base de données';
//The column that we want to keep in the database
const goodColumn = [
'Civilite',
'Nom_patronymique',
'Prenom',
'Date_naissance',
'No_etudiant',
'Libelle_nationalite',
'Telephone_portable',
'Mailum',
'Adresse_fixe_postal',
'Adresse_fixe_ville',
'Libelle_etape',
];
// Set up the environnement for geocoding the adress
const options = {
provider: 'openstreetmap',
};
const geoCoder = NodeGeocoder(options);
//FUNCTION TO VERIFY IF A STRING HAS A NUMBER IN IT
function hasNumber(myString) {
return /\d/.test(myString);
}
router.post('/', (req, res, next) => {
// This should be BEFORE `fileUpload`
req.setTimeout(0);
next();
});
router.use(fileUpload());
//@route POST api/students
//@desc Fill the database with the json information
//@access Public
router.post('/', async (req, res, next) => {
//FORMER FILES ROUTES
//take the information
const buf = Buffer.from(req.files.file.data).toString();
//CONVERSION CSV STRING TO JSON
CSVToJSON()
.fromString(buf)
.then((source) => {
for (let i = 0; i < source.length; i++) {
for (let j = 0; j < Object.keys(source[i]).length; j++) {
const columnName = Object.keys(source[i]);
columnName.forEach((element) => {
if (!goodColumn.includes(element)) {
delete source[i][element];
}
if (element == 'Libelle_etape') {
const str = source[i]['Libelle_etape'];
const result = accents.remove(utf8.decode(str));
source[i]['Libelle_etape'] = result;
}
});
}
}
data = JSON.stringify(source);
datajson = JSON.parse(data);
//USE THE FUNCTION TO PUT THE DATA IN THE DB
insertIntoDataBase(datajson);
});
// CLEAR TABLE BEFORE ADD NEW STUDENTS FROM FILE
Student.deleteMany({}, function (err) {});
//ROUTES STUDENTS - FUNCTION TO PUT THE JSON DATA IN THE DATABASE
async function insertIntoDataBase(jsonString) {
for (let i = 0; i < jsonString.length; i++) {
console.log(`boucle ${i}`);
try {
//READ DATA FROM DE CSV FILE (already convert into json data) AND PUT IT INTO VARIABLES
let {
Civilite,
Nom_patronymique,
Prenom,
Date_naissance,
No_etudiant,
Libelle_nationalite,
Telephone_portable,
Mailum,
Adresse_fixe_postal,
Adresse_fixe_ville,
Libelle_etape,
} = jsonString[i];
console.log(Nom_patronymique + ' ' + Prenom);
// VERIFICATION VILLE STRING FORMAT ( AVOIR NUMBER OR ..EME)
if (hasNumber(Adresse_fixe_ville)) {
Adresse_fixe_ville = Adresse_fixe_ville.replace(/[0-9]/g, '');
if (Adresse_fixe_ville.endsWith(' EME')) {
Adresse_fixe_ville = Adresse_fixe_ville.substring(
0,
Adresse_fixe_ville.length - 4
);
}
}
//VERIFICATION OF THE PHONE NUMBER - if empty attributes a default value
if (Telephone_portable !== undefined && Telephone_portable.length < 1) {
Telephone_portable = '0000000000';
}
// GEOCODING THE ADDRESS TO CONVERT INTO LATITUDE AND LONGITUDE
geoCoder
.geocode({
city: Adresse_fixe_ville,
zipcode: Adresse_fixe_postal,
})
.then(async (res) => {
//TEST
var Latitude;
var Longitude;
if (res[0] !== undefined) {
Latitude = res[0].latitude;
Longitude = res[0].longitude;
} else {
console.log(Adresse_fixe_ville);
Latitude = 0.0;
Longitude = 0.0;
}
//CREATE A STUDENT WITH THE INFO + LAT AND LONG
student = new Student({
Civilite,
Nom_patronymique,
Prenom,
Date_naissance,
No_etudiant,
Libelle_nationalite,
Telephone_portable,
Mailum,
Adresse_fixe_postal,
Adresse_fixe_ville,
Libelle_etape,
Latitude,
Longitude,
});
//VERIFICATION IF ALL THE ATTRIBUTE OF THE STUDENT ARE OK - IF NOT : undefined
if (
!(
student.Civilite === undefined ||
student.Nom_patronymique === undefined ||
student.Prenom === undefined ||
student.Date_naissance === undefined ||
student.No_etudiant === undefined ||
student.Libelle_nationalite === undefined ||
student.Telephone_portable === undefined ||
student.Mailum === undefined ||
student.Adresse_fixe_postal === undefined ||
student.Adresse_fixe_ville === undefined ||
student.Libelle_etape === undefined
)
) {
//SAVE THE STUDENT IN THE DATABASE
await student.save();
} else {
res.status(500);
msg =
'Le fichier csv téléchargé est au mauvais format de données';
}
})
.catch((err) => {
console.log(err);
});
} catch (err) {
console.log(err.message);
res.status(500);
msg =
'Erreur serveur, veuillez réessayer avec un fichier csv au bon format';
return;
}
//WAIT FOR GEOCODER - 1,2 second
await sleep(1200);
}
//COUNT A MANY STUDENT WE HAVE IN THE DATABASE
Student.find().exec(function (err, results) {
var count = results.length;
res.json({ msg: msg, count: count });
});
}
});
//@route GET api/students
//@desc Return all the students in the database (all information / attributes)
//@access Public
router.get('/', function (req, res, next) {
Student.find(function (err, students) {
if (err) {
res.send(err);
}
res.json(students);
});
});
module.exports = router;
在 Node < 13.0.0
默认的套接字超时时间是2分钟,所以两分钟后套接字就会被关闭,你会得到以下信息 ERR_EMPTY_RESPONSE
因为套接字已被关闭,不允许你响应该请求。
从Node 13.0.0
默认超时设置为 0
(没有超时),这也许是你部署应用时能正常工作的原因,你的服务器可能正在运行Node >= 13.0.0
.
如果使用后 req.setTimeout
的值大于2分钟,而你仍然有这个问题,这可能是因为你没有正确地结束请求或者你使用了 req.setTimeout
在错误的地方。
这是一个巨大的文件,它是一个有1300条线的csv文件,大约需要30分钟才能上传。
从你的评论中,我可以告诉你。req.setTimeout
你的路由中没有做你想要的事情,因为你之前有一个中间件,可能是 multer
从您的代码中可以看出,您的代码没有设置 req.setTimeout
到 >30 min
.
所以请求在到达你的路由之前就已经超时了。你应该做这样的事情。
app.post(
'/',
(req, res, next) => {
// Set request setTimeout BEFORE any other middlewares
req.setTimeout(ms('35m')); // using `ms` package
next();
},
upload.single('file'), // or whatever multer setup you have
(req, res, next) => {
// Your route
}
)
使用这段代码,你有35分钟的时间来上传& 结束你的响应,因为它不会超时,在这段时间内 multer
2分钟后的中间件。当然如果你不知道需要多少时间,很可能是这种情况,你可以用 req.setTimeout(0)
或任何您认为合适的值。
更新
对于你的代码,你必须做以下工作。
// or router.use((req, res, next) => ...)
router.post('/', (req, res, next) => {
// This should be BEFORE `fileUpload`
req.setTimeout(0);
next();
});
router.use(fileUpload());
//@route POST api/students
//@desc Fill the database with the json information
//@access Public
router.post('/', async (req, res, next) => {
// ...rest of your code
})