03.f Implementación del buffer tipo FIFO (Cola de espera, el primero es primero en salir) 2da parte (320) Continuación del programa que se conecta por la red para procesar información, ya vimos la parte de la Telefonista, ahora veremos la secretaria. contact Created,Modified 2009-04-02 11:52:25, 2009-05-07 19:09:04 Author,Nick Gustavo Guillermo Perez, (madgus) [myblog]

Secretaria:

1. package com.compunauta.aprendiendojava;

2. import java.io.*;

3. import java.net.*;

4. /**

5. * <p>Título: Aprendiendo Java</p>

6. * <p>Descripción: Ejemplos del Libro Aprendiendo Java de Compunauta</p>

7. * <p>Copyright: Copyright (c) 2006 www.compunauta.com</p>

8. * <p>Empresa: COMPUNAUTA</p>

9. * @author Gustavo Guillermo Pérez

10. * @version 2006.01.01

11. */

13. public class Cap3_sock_sec {

14. //Declaramos unas variables globales a este tipo de datos

15. public static int PORT=4567;

16. public static String HOST="127.0.0.1";

17.  

18. public static void main(String[] args) {

19. System.err.println("Intentando conectar con la telefonista");

20. Socket skt=(Socket)null;

21. try {skt = new Socket(HOST, PORT);}

22. catch (Exception ex) {

23. System.err.println("La telefonista no está en línea");

24. System.exit(-1);

25. }

26.  

27. int tel;

28. BufferedReader teclado=new BufferedReader(new InputStreamReader(System.in));

29. try {

30. ObjectOutputStream datos = new ObjectOutputStream(skt.getOutputStream());

31. System.err.println("Nos conectamos con la telefonista:"+HOST+":"+PORT);

32. System.err.println("Ingrese números -1 termina");

33. while (true){

34. if((tel=leerInt(teclado))==-1){

35. System.err.println("Programa terminado");

36. datos.writeInt(-1);

37. datos.flush();

38. datos.close();

39. skt.close();

40. System.exit(0);

41. }else{

42. datos.writeInt(tel);

43. datos.flush();

44. }

45. }//fin de la lectura eterna

46. }catch (IOException ex1) {ex1.printStackTrace(System.err);}

47.  

48. }//fin del método principal

50. //Funciones o métodos auxiliares

51. public static int leerInt(BufferedReader buff){

52. int lee=0;

53. boolean error;

54. do {

55. error=false;

56. try {lee = Integer.parseInt(buff.readLine());}

57. catch (NumberFormatException ex) {

58. System.err.println("Entrada erronea, repetir:?");

59. error=true;}

60. catch (Exception ex){ex.printStackTrace(System.err);}

61. } while (error);

62. return lee;

63. }//final de la funcion leer

65. }//final de la clase

Descripción del funcionamiento:

En las líneas 15 y 16 declaramos las variables globales que almacenarán el puerto y la dirección de red donde nos conectaremos, en este caso la dirección 127.0.0.1 es universal y permite conectarse a la misma máquina así que podremos ejecutar el programa de la secretaria y la telefonista en la misma PC en consolas de comandos diferentes, si estamos en el laboratorio con más de 1 PC en RED, entonces en ese número pondremos el que nos comente el administrador del sistema para conectarnos a la PC que correrá la telefonista.

En la línea 18 comienza nuestro método principal y de la misma manera que en el programa anterior definimos el Socket (skt) como un elemento vacío sin inicializar, ya que estamos obligados a revisar errores.

Entre las líneas 21 a 25 comprobamos que se pueda hacer una conexión al puerto y dirección de red indicados, puede suceder que el error no sea exactamente que la telefonista no está en línea y que el sistema operativo esté denegando el acceso a conectarse al exterior, por ello revisar el firewall del sistema o los permisos necesarios.

Si nos pudimos conectar el programa siguió adelante y procedemos a crear un objeto BufferedReader para manipular la entrada por teclado y declaramos una variable tel que almacenará un teléfono para enviar.

En la línea 29 comienza el bloque donde abriremos la conexión de datos remota por medio de un flujo de datos del tipo ObjetOutputStream.

Como en el componente anterior utilizamos un bucle eterno para la ejecución del programa que saldrá por otros mecanismos. (línea 33).

En la línea 34, asignamos el valor que se lee por teclado a la variable tel, ese segmento está entre paréntesis porque porque ese mismo valor asignado lo compararemos antes de proseguir, podríamos haber hecho primero la asignación y después la comparación.

Si la secretaria escribió -1 enviamos el -1 a la telefonista para avisarle que terminamos, (línea 36), la orden datos.fluxh(); vacía los datos de memoria RAM al flujo de datos inmediatamente y en las líneas 38 y 39 cerramos debidamente el flujo de datos y la conexión de red antes de salir sin producir error, salir con el código 0 es no producir error.

En la línea 41 comienza el bloque de datos que se ejecutará caso contrario a que la secretaria ingrese un -1. Donde podemos ver que escribimos en el flujo de datos el número entero correspondiente al teléfono y obligamos la escritura inmediata con la orden flush();.

Termina el bucle etenro while(true){} termina el bloque de control de errores y el método principal, a continuación están la función auxiliar leerInt que no explicaremos porque es la misma que vimos en el capítulo anterior.

Nota: Veremos con más detalles el uso de sockets durante el transcurso del libro, no ahondaremos en ello ahora. Queda como ejercicio para el lector producir el error de Buffer Overrun y revisar en la documentación electrónica los métodos y objetos utilizados de la biblioteca de Java.

leavecomment

---