Crear proxy web. Fallo reenviar información.

[beker]

Buenas

En un proyecto que tengo entre manos estoy preparando un servidor proxy en java, donde evidentemente tendré datos de entrada por un puerto, y que posteriormente reenviaré tal como llegaron a otra dirección y puerto en concreto.

Actualmente me encuentro un poco atascado porque originalmente para capturar los
datos que se recivian por el socket lo hacía con un algoritmo complicado
con un in.read() pero por defecto read se queda unos segundos esperando
mientras no recibe TODOS los datos del socket antes de cerrarlo y eso me
esta dando algunos problemas y para más adelante sería más engorroso de
manejar(os pongo parte del codigo):

Código (java) [Seleccionar] Expandir

byte[] buffer = new byte[4096];
int saved = 0;
int len;

              for (;;) {

               if (done) {
                   break;
               }

               len = buffer.length;

               // Used to be 1, but if we block it doesn't matter
               // however 1 will break with some servers, including apache
               if (len == 0) {
                   len = buffer.length;
               }
               if (saved + len > buffer.length) {
                   len = buffer.length - saved;
               }
               int len1 = 0;
               while (len1 == 0) {
                   try {
                       len1 = in.read(buffer, saved, len);
                   } catch (Exception ex) {
                       if (done && (saved == 0))
{System.out.println("INICIO5555:");
                           break a;
                       }
                       len1 = -1;
                       break;
                   }
               }
               len = len1;
               if ((len == -1) && (saved == 0)) {
                   break;
               }
               if (len == -1) {
                   done = true;
               }

               // No matter how we may (or may not) format it, send it
               // on unformatted - we don't want to mess with how its
               // sent to the other side, just how its displayed
               if ((out != null) && (len > 0)) {
                   //slowLink.pump(len);
                   out.write(buffer, saved, len);
               }


               xmltextAUX = xmltextAUX + new String(buffer, 0, len);

           }


En xmltextAux se almacena en forma de cadena todos los bytes recividos
gracias al byte[] buffer = new byte[4096];...

Ahora estoy intentando pasar éste codigo a otro que utiliza funciones más
avanzadas(y sin espera) asi que todo lo anterior se resumiria en algo
similar a ésto:

Código [Seleccionar] Expandir

   InputStreamReader ir = new InputStreamReader(in);
           BufferedReader r = new BufferedReader(ir);
           while ((xmltextAUX = r.readLine()).trim().length() > 0) {
               xmltext = xmltext + xmltextAUX;
           }
           System.out.println("MENSAJE:" + xmltext);

           if ((out != null) && (xmltext.length() > 0)) {
               System.out.println("INICIO8:");
               //slowLink.pump(len);
               //DataOutputStream dout = new DataOutputStream(out);
               //dout.writeBytes(xmltext);
               //Charset charset = Charset.forName("ISO-8859-1");
               PrintWriter p = new PrintWriter(out, true);
               p.write(xmltext);
               //out.write(xmltext.getBytes(charset));
           }


La parte de recibir por el socket de entrada el mensaje lo lee exactamente
igual que la otra funcion, pero a la hora de escribir lo que se ha
recibido por él para enviarlo por el socket "out" de salida algo falla
porque es como si no se enviara nada.

La mayor diferencia y donde creo que reside el problema es que en el
codigo antiguo el mensaje se recibia como una serie de bytes[] y se
enviaba directamente como los bytes[] que eran; y en la nueva version
vamos leyendo línea a línea como un string y luego lo mandamos como un
string y puede que haya algún problema de conversión, o de formato o algo
así que no se interpreta correctamente por el servidor.

Un saludo chicos y muchas gracias de antemano por leer tanta parrafada

[Aeros]

inserta codigo en java

[beker]

inserta codigo en java

¿? El código que he puesto en el post es java, podría poner el código de toda la clase, pero vamos, de la versión que funciona, a la que no, sólo cambian las partes que están citadas.

Un saludo!

[Debci]

inserta codigo en java

Al parece con un solo bucle no captas toda la info, o el contenedor es demasiado pequeño, te recomiendo cojer la salida de todo lo que entra y analizar (debuggearlo vamos )

Es lo que me parece ver, pero es primera hora de la mañana y no estoy muy fino, luego te lo pruebo y demas.

Saludos

[beker]

inserta codigo en java

Al parece con un solo bucle no captas toda la info, o el contenedor es demasiado pequeño, te recomiendo cojer la salida de todo lo que entra y analizar (debuggearlo vamos )

Es lo que me parece ver, pero es primera hora de la mañana y no estoy muy fino, luego te lo pruebo y demas.

Saludos

En el codigo inicial tiene un bucle infinito con for(; y en el inferior también tiene un bucle con while ((xmltextAUX = r.readLine()).trim().length() > 0) donde se queda leyendo hasta que no hay más información en el socket...