Tengo una solicitud web que a veces se completa en 0,1 segundos y, a veces, se completa en 20 segundos. Mi solución es enviar solicitudes con un tiempo de espera. Cuando se activa el tiempo de espera, quiero enviar otra solicitud. Sin embargo, quiero dejar abierta la solicitud anterior y competir con la nueva solicitud. Quiero hacer esto hasta que se complete una de las solicitudes abiertas, finalizando la carrera para todas las solicitudes abiertas.
También estoy abierto a sugerencias para un enfoque alternativo a este problema.
const timeoutLimit = 300; const timeoutMessage = 'Response timed out'; /** Executes a request, retrying on timeouts, until it returns successfully. */ export default async function requestWithTimeout(request, count) { const timeout = new Promise((resolve, reject) => { setTimeout(() => reject(timeoutMessage), timeoutLimit); }); const apiCall = new Promise((resolve, reject) => { request .catch((err) => reject(err)) .then((resp) => resolve(resp)); }); count += 1; const result = await Promise.race([apiCall, timeout]) .catch((err) => { console.log(err, count); return (err === timeoutMessage) ? Promise.race([apiCall, requestWithTimeout(request, count)]) : err; }) .then((val) => { console.log('returned', count); return val; }); console.log(count, result); return result; }Aquí hay un ejemplo de la salida de la consola: declaraciones de impresión que indican el tiempo de espera y el orden de respuesta
Siempre imprimo las cosas en este orden:
Response timed out 1 Response timed out 2 returned 1 returned 2 returned 3 data 1 data 2 data 3Pero quiero que mi respuesta sea algo como esto:
Response timed out 1 Response timed out 2 returned 1 data 1 returned 3 data 3 returned 2 data 2Mi solución fue usar una matriz para realizar un seguimiento de las promesas pendientes. De esta manera, puedo abrir una solicitud y competir contra las solicitudes anteriores aún pendientes que perdieron una carrera contra una promesa de tiempo de espera. Las carreras terminarán cada vez que se cumpla una de las promesas de solicitud pendientes. Esto creará lentamente una serie de solicitudes cada período de tiempo de espera, hasta que se cumpla una de ellas. Al aumentar lentamente la cantidad de solicitudes simultáneas en lugar de descartarlas después del período de tiempo de espera, quiero aumentar la probabilidad de que mi servidor cumpla con una de las solicitudes con un tiempo de respuesta errático.
const timeoutLimit = 250; const timeoutLimitMessage = 'Response timed out, retrying'; const requestLimit = 20; const RequestLimitMessage = 'Too many requests'; /** Executes a request, retrying on timeouts, until it returns successfully. */ export default async function requestWithTimeout(request, promises = []) { const timeout = new Promise((resolve, reject) => { setTimeout(() => reject(timeoutLimitMessage), timeoutLimit); }); const apiCall = new Promise((resolve, reject) => { request .catch((err) => reject(err)) .then((resp) => resolve(resp)); }); promises.push(apiCall); const result = await Promise.race([...promises, timeout]) .catch((err) => { if (err !== timeoutLimitMessage) { return err; } console.log(timeoutLimitMessage); if (promises.length > requestLimit) { throw new Error(RequestLimitMessage); } return Promise.race([...promises, requestWithTimeout(request, promises)]); }) .then((resp) => resp); return result; }