2

Tengo n nombres que simulan clientes lo que quiero hacer es iterar sobre cada uno de ellos y me envie n peticiones a un endpoint en nodejs

aqui tengo la parte del codigo correspondiente a lo que les digo

  sensors=["Rimac","Cercado"];

  for (sensor in sensors){
  var date = new Date().toJSON();

  var datos={
    name:sensors[sensor],
    valor:Math.random()*20,
    fecha:date
  };

console.log(datos);
    var options = {
  uri: 'http://localhost:7777/api/sensor',
  method: 'POST',
   headers: {
        "content-type": "application/json",
        },
  json: datos
};

  request(options,function (error, response, body) {
  if (!error && response.statusCode == 200) {
    console.log(body) // Show the HTML for the Google homepage. 
  }
});
  sleep(1000);


};

Los datos llegan al enpoint con normalidad pero, si le pongo un for a la parte anterior para que quede así

for(i=0;i<100;i++){
  for (sensor in sensors){
  var date = new Date().toJSON();

  var datos={
    name:sensors[sensor],
    valor:Math.random()*20,
    fecha:date
  };

console.log(datos);
    var options = {
  uri: 'http://localhost:7777/api/sensor',
  method: 'POST',
   headers: {
        "content-type": "application/json",
        },
  json: datos
};

  request(options,function (error, response, body) {
  if (!error && response.statusCode == 200) {
    console.log(body) // Show the HTML for the Google homepage. 
  }
});
  sleep(10000);


};
}

Los datos no llegan al endpoint, a que se debe?, me parece que es por un tema de asincronia.

Edito1

Buenas les agrego el cod que controla el tema del post en el servidor

module.exports=function(app,Sensor,io){
var express=require("express");
var router=require("express").Router(); 

  router.route("/sensor").get(function (req, res){
  Sensor.find(
    function(err, Sensor) {
      if (err)
        res.send(err)
      else{
        console.log("Exito al retornar todo");
        res.json(Sensor);

      }
      // devuelve todas las Sensors en JSON
        }
      );
}).post(function(req,res){
  console.log("BODY=");
  console.log(req.body)
    Sensor.create(
    {
    name:req.body.name,
     Valor:req.body.valor,
     Fecha:req.body.fecha
   } , function(err) {
        if (err){
          console.log("HUBO UN ERROR",err);
          res.send(err);
        }
        else{

        var temp = parseFloat(req.body.valor);
        var date = new Date(req.body.fecha); 
        console.log(date);
        console.log(temp);
        //Se pasan los datos a el cliente web ahi se manejara para mostrar la grafica en tiempo real mediante higcharts
        io.sockets.emit('post', date.getTime() - ( date.getTimezoneOffset() * 60000) , temp ,req.body.name);    
        console.log("Dato creado exitosamente");
}

});
});

  return router;
}

Imagen del cliente cuando envia los datos ,SIN USAR EL FOR HASTA 100, es decir solo se envia una instancia

http://www.subirimagenes.com/imagen-screenshotfrom2016-9618315.html

Imagen del servidor al recibir esta instancia, hasta aqui todo bien sale lo que quiero, el problema es cuando quiero emular 100 200 o n peticiones.

http://www.subirimagenes.com/imagen-screenshotfrom2016-9618316.html

AQui cuando agrego el for hasta 100 , para tener 100 peticiones tanto de Rimac como Cercado.

Enviando datos http://www.subirimagenes.com/imagen-screenshotfrom2016-9618325.html

Servidor NO recibe datos

http://www.subirimagenes.com/imagen-screenshotfrom2016-9618331.html

Tambien esta el tema de por ejemplo como es un for todo se envia de manera lineal , como añadiria sincronia a las peticiones? , pense en hilos , vengo de java ,si tienen ejemplos compartalo por favor.

Edito3

Como hice para 100 peticiones en 100 segundos no alcanzaba a llegar al final reduci a 10 y veo que las peticiones si se envian , pero se envian en bloque a que me refiero, a que tiene que terminar el for del client y recien ahi salen el servidor ,lo que quiero es que se envien constantemente no en bloque.

Además el callback del request en el client no se ejecuta, sino cuando cierro el servidor.

5
  • ¿estás usando request así: var request = require('request');? el 6 jul. 2016 a las 18:51
  • si,asi lo estoy usando,por eso solo puse la parte del cod en la que esta el problema y como dije , cuando no pongo el bucle los datos si se envian,solo 2 , pero si pongo por ejem un bucle para100 peticiones , en el servidor sale que llegan , pero es como si la coneccion aun permaneciera , y no sale el resultado de sucess final,por consecuente el socket no se envia.
    – Kevin AB
    el 6 jul. 2016 a las 18:57
  • ¿y también var sleep = require('sleep').sleep ? el 6 jul. 2016 a las 19:01
  • no , el sleep es una funcion que encontre , pues el sleep de npm creo que hace uso de python , y quiero la mas independencia posible,pero igual funciona.
    – Kevin AB
    el 6 jul. 2016 a las 20:16
  • 1
    Ese sleep( ) tiene muy mala pinta. Hay un módulo sleep en npm que bloquea todo el bucle de eventos de node. Si eso es lo que estás usando, ese es tu problema. Si bloqueas el bucle de eventos, ni se envian ni se reciben datos. Investiga sobre setTimeout( ) o setInterval( ), y quita ese sleep( ).
    – Trauma
    el 8 ene. 2017 a las 12:47

1 respuesta 1

1

La segunda función a mí me anda. Solo le falta definir sensors

for(i=0;i<100;i++){
  var sensors=["Rimac","Cercado"];
  for (var sensor in sensors){

Subí lo que probé a github

(para mis pruebas supongo que están corriendo en procesos separados el frontend y el backend, si no fuera así el problema puede estar en el sleep que es sincrónico)

2
  • Editare el post poniendo mas información con imagenes , ya revise tu código , pero no me funciona.
    – Kevin AB
    el 6 jul. 2016 a las 20:45
  • 1
    Consejo: Poner como primer renglón "use strict"; mejora el control (que estén todas las variables declaradas, lo cual ayuda a no cometer errores de tipeo y otros similares) el 6 jul. 2016 a las 20:53

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.