Tutoriales

Escritura log con Fichero UDP y JMS

Por

23 agosto, 2003

40886

Coste de Envio de mensajes de Log

Cuando desarrollamos una aplicación, muchas veces nos planteamos donde
debemos escribir la información de log.

Si mostramos mensajes por la consola estandar (por pantalla)…… es cómodo pero es muy
lento (aunque siempre podemos redirigir la salida a un fichero)

Podemos tomar la decisión de escribirlos en un fichero local.…. el
problema puede ser, ¿quien limpia luego esos ficheros?. Si trabajamos en
entornos serios, las herramientas de monitorización y backup pueden hacer este
trabajo por nosotros … pero no nos podemos despistar.

Podemos decidir enviar los mensajes a otra máquina y que esta sea quien los
guarde. Si decidimos hacelo via TCP, debemos tener cuidado con controlar bien
esta comunicación porque sería una pena que, porque fallase el sistema de Log,
se parase nuestra aplicación.

Si usamos UDP (comunicaciones ni orientadas a conexion), tenemos que tener en
cuenta que que los paquetes no estan garantizados que lleguen.

Otra posibilidad, es utilizar JMS, es decir, mensajería …. y
luego procesar esos mensajes cuando deseemos.

Pero ¿alguna vez os habeis parado a pensar los que cuesta escribir cada uno
de los mensajes por distintos medios?

Os vamos a mostrar distintos ejemplos para que tengais una referencia.

Mensajes por pantalla y en fichero

import java.util.Date;
import java.io.*;

/**
 *
 * @author  Roberto Canales
 */
public class velocidadLog {

    /** Creates a new instance of velocidadLog */
    public static void main(String [] cadenas)
    {
        long inicio = System.currentTimeMillis();

        <font color="#008000">for(int i=0; i<1000;i++)
        {
 <b>           System.out.println(i + " La hora es " + new Date().toString());
 </b>       }</font>

          long fin = System.currentTimeMillis() - inicio;
          System.out.println("El tiempo transcurrido es " + fin + " milisegundos");

          try
          {
              FileWriter escritor = new FileWriter("logrob.txt",true);

              inicio = System.currentTimeMillis();
           <font color="#0000FF">   for(int i=0; i<1000;i++)
             {
<b>                   escritor.write(i + " La hora es " + new Date().toString());
                   escritor.flush();</b>
              }
              escritor.close();</font>
          }
          catch(Exception e)
          {
            System.out.println("Error a escribir en fichero" + e.getMessage());
          }

          fin = System.currentTimeMillis() - inicio;
          System.out.println("El tiempo transcurrido es " + fin + " milisegundos");
    }
}

import java.util.Date;

import java.io.*;

/**

* @author Roberto Canales

public class velocidadLog {

/** Creates a new instance of velocidadLog */

public static void main(String [] cadenas)

{

long inicio = System.currentTimeMillis();

for(int i=0; i<1000;i++)

{

System.out.println(i + " La hora es " + new Date().toString());

}

long fin = System.currentTimeMillis() - inicio;

System.out.println("El tiempo transcurrido es " + fin + " milisegundos");

try

{

FileWriter escritor = new FileWriter("logrob.txt",true);

inicio = System.currentTimeMillis();

for(int i=0; i<1000;i++)

{

escritor.write(i + " La hora es " + new Date().toString());

escritor.flush();

}

escritor.close();

}

catch(Exception e)

{

System.out.println("Error a escribir en fichero" + e.getMessage());

}

fin = System.currentTimeMillis() - inicio;

System.out.println("El tiempo transcurrido es " + fin + " milisegundos");

}

Si ejecutamos este código … la respuesta que optenemos es

.....
995 La hora es Fri Aug 22 20:35:44 CEST 2003
996 La hora es Fri Aug 22 20:35:44 CEST 2003
997 La hora es Fri Aug 22 20:35:44 CEST 2003
998 La hora es Fri Aug 22 20:35:44 CEST 2003
999 La hora es Fri Aug 22 20:35:44 CEST 2003
El tiempo transcurrido es <font color="#008000"><b>2994</b></font> milisegundos
El tiempo transcurrido es <font color="#0000FF"><b>111</b></font> milisegundos

.....

995 La hora es Fri Aug 22 20:35:44 CEST 2003

996 La hora es Fri Aug 22 20:35:44 CEST 2003

997 La hora es Fri Aug 22 20:35:44 CEST 2003

998 La hora es Fri Aug 22 20:35:44 CEST 2003

999 La hora es Fri Aug 22 20:35:44 CEST 2003

El tiempo transcurrido es 2994 milisegundos

El tiempo transcurrido es 111 milisegundos

Es decir, ha costado 25 veces más escribir en pantalla que en disco.

Escritura UDP

Si creamos un pequeño programa cliente UDP (que envia los mensajes de Log)
.. y un servidor …… tenemos que estar seguros de los que estamos haciendo
…

Programa cliente

import java.net.* ;
import java.io.* ;
import java.util.*;

class clienteUPD
{
        public static void main(String[] args)
        {
            try
            {
                    String cadena = null;
                    byte[] paqueteBytes = null;
                    DatagramPacket paqueteUDP = null;

                    InetAddress direccion = InetAddress.getByName("localhost") ;

                    long inicio = System.currentTimeMillis();

                    for(int i=0;i<1000;i++)
                    {
                        DatagramSocket socketUDP = new DatagramSocket() ;
                       <b><font color="#008000"> cadena = i + " La hora es " + new Date().toString();</font></b>
                        paqueteBytes = cadena.getBytes() ;
                        paqueteUDP = new DatagramPacket(paqueteBytes, paqueteBytes.length,direccion,<font color="#FF0000">8031</font>);
                        <font color="#008000"><b>socketUDP.send(paqueteUDP) ;</b></font>
                        socketUDP.close() ;

                    }

                    long fin = System.currentTimeMillis() - inicio;
                    System.out.println("El tiempo transcurrido es " + fin + " milisegundos");
                }
            catch (IOException e)
            {
                        System.out.println(e) ;
            }

        }
}

import java.net.* ;

import java.io.* ;

import java.util.*;

class clienteUPD

{

public static void main(String[] args)

{

try

{

String cadena = null;

byte[] paqueteBytes = null;

DatagramPacket paqueteUDP = null;

InetAddress direccion = InetAddress.getByName("localhost") ;

long inicio = System.currentTimeMillis();

for(int i=0;i<1000;i++)

{

DatagramSocket socketUDP = new DatagramSocket() ;

cadena = i + " La hora es " + new Date().toString();

paqueteBytes = cadena.getBytes() ;

paqueteUDP = new DatagramPacket(paqueteBytes, paqueteBytes.length,direccion,8031);

socketUDP.send(paqueteUDP) ;

socketUDP.close() ;

}

long fin = System.currentTimeMillis() - inicio;

System.out.println("El tiempo transcurrido es " + fin + " milisegundos");

}

catch (IOException e)

{

System.out.println(e) ;

}

Si lo ejecutamos nos dice

El tiempo transcurrido es 1232 milisegundos

Y ahora el servidor

import java.net.* ;
import java.io.* ;

public class servidorUDP
{
    public static void main(String[] args)
    {
        try
        {
            int tamaPaquete = 1024;
            DatagramSocket s = new DatagramSocket(<font color="#FF0000">8031</font>) ;

            while (true)
            {
                    DatagramPacket datagramaUDP =  new DatagramPacket( new byte [tamaPaquete], tamaPaquete) ;
<b><font color="#0000FF">                    s.receive(datagramaUDP) ;
</font></b>
 <font color="#0000FF"><b>                   String msg = new String(datagramaUDP.getData()).trim() ;
                    System.out.println("Recibido mensaje " + datagramaUDP.getAddress().getHostName() + " - " + msg) ;
 </b></font>           }
        }
        catch (Exception e)
        {
            System.out.println("Error en proceso");
        }
    }
}

import java.net.* ;

import java.io.* ;

public class servidorUDP

{

public static void main(String[] args)

{

try

{

int tamaPaquete = 1024;

DatagramSocket s = new DatagramSocket(8031) ;

while (true)

{

DatagramPacket datagramaUDP = new DatagramPacket( new byte [tamaPaquete], tamaPaquete) ;

s.receive(datagramaUDP) ;

String msg = new String(datagramaUDP.getData()).trim() ;

System.out.println("Recibido mensaje " + datagramaUDP.getAddress().getHostName() + " - " + msg) ;

}

}

catch (Exception e)

{

System.out.println("Error en proceso");

}

Pero si vemos la consola del servidor … se nos estan perdiendo datos

Posiblemente … estemos mandandolos muy rápido

Si ahora modificamos un poco nuestro código y ponemos un retardo … podemos
ver que no se pierden datos

import java.net.* ;
import java.io.* ;
import java.util.*;

class <b>clienteUPD</b>
{
      <font color="#FF0000"> static void retardo(int iMilisegundos)
       {
            try
            {
                Thread.currentThread().sleep(iMilisegundos);
            }
            catch(Exception e)
            {}
       }
       </font>

        public static void <b>main</b>(String[] args)
        {
            try
            {
                    String cadena = null;
                    byte[] paqueteBytes = null;
                    DatagramPacket paqueteUDP = null;

                    InetAddress direccion = InetAddress.getByName("localhost") ;

                    long inicio = System.currentTimeMillis();

                    for(int i=0;i<1000;i++)
                    {
                        DatagramSocket socketUDP = new DatagramSocket() ;
                        cadena = i + " La hora es " + new Date().toString();
                        paqueteBytes = cadena.getBytes() ;
                        paqueteUDP = new DatagramPacket(paqueteBytes, paqueteBytes.length,direccion,8031);
                        socketUDP.send(paqueteUDP) ;
  <font color="#FF0000">                      retardo(100);
  </font>                      socketUDP.close() ;

                    }

                    long fin = System.currentTimeMillis() - inicio;
                    System.out.println("El tiempo transcurrido es " + fin + " milisegundos");
                }
            catch (IOException e)
            {
                        System.out.println(e) ;
            }
        }
}

import java.net.* ;

import java.io.* ;

import java.util.*;

class clienteUPD

{

static void retardo(int iMilisegundos)

{

try

{

Thread.currentThread().sleep(iMilisegundos);

}

catch(Exception e)

{}

}

public static void main(String[] args)

{

try

{

String cadena = null;

byte[] paqueteBytes = null;

DatagramPacket paqueteUDP = null;

InetAddress direccion = InetAddress.getByName("localhost") ;

long inicio = System.currentTimeMillis();

for(int i=0;i<1000;i++)

{

DatagramSocket socketUDP = new DatagramSocket() ;

cadena = i + " La hora es " + new Date().toString();

paqueteBytes = cadena.getBytes() ;

paqueteUDP = new DatagramPacket(paqueteBytes, paqueteBytes.length,direccion,8031);

socketUDP.send(paqueteUDP) ;

retardo(100);

socketUDP.close() ;

}

long fin = System.currentTimeMillis() - inicio;

System.out.println("El tiempo transcurrido es " + fin + " milisegundos");

}

catch (IOException e)

{

System.out.println(e) ;

}

Como conclusión, podemos decir que …. si se generan
demasiados mensajes …. y los mandamos todos seguidos ….. se perderán
paquetes … así que tenemos que ser habiles y utilizar mecanismos un poco más
elaborados para asegurarnos de no perder datos.

Envio de mensajes a través de JMS

JMS es un interfaz para interactuar con proveedores de servicio
de mensajería (bueno… más o menos)

Nosotros podemos crear un programa cliente que se conecte a una
cola de mensajes y enviar nuestra información.

Una de las ventajas que puede presentarnos este sistema es que
el gestor de colas podría ser cualquier cosa …… de tan modo que se nos
puede proporcionar de un modo transparente capacidad de persistencia,
transaccionalidad, backup, politicas de enrutamiento …etc.

Nosotros vamos ha hacer un pequeño programa que se conecte a
una cola que hemos creado en el servidor de aplicaciones J2EE de Sun (versión
1.3.1). Tengo que decir que me he vuelto loco intentando hacer funcionar este
ejemplo en la versión 1.4 (con pequeños cambios siguiendo de tutorial de Sun) ….. por lo que al final he desistido y seguido las
recomendaciones de muchos foros de (obviamente esto no es un proyecto vital) usando la 1.3.

Os vamos a mostrar todos los pasos (que son muy sencillos)

Nos descargamos el software J2EE de sun (y lo
instalamos)

Ponemos las variables de entorno

Arrancamos el servidor escribiendo

j2ee -verbose

Creamos la cola escribiendo

j2eeadmin -addJmsFactory ColaRoberto queue

Escribimos el código que manda los mensajes

/*
 * envioMensajeSimple.java
 *
 * Created on 12 de agosto de 2003, 22:33

 * @author  Roberto Canales
 */

import javax.naming.*;
import javax.jms.*;
import java.util.*;


public class <b>envioMensajeSimple</b> {
    /** Punto de entrada a la aplicacion*/
    public static void main(String[] args) {
        envioMensajeSimple programa = new envioMensajeSimple();
        programa.arranca();
    }

    /** Funcion para centralizar mensajes*/
    void depura(String cadena) {
        System.out.println("Mensaje: " + cadena);
    }

    private static InitialContext <b>getInitialContext</b>() throws NamingException
    {
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");
        env.put("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");
        env.put(Context.PROVIDER_URL, "iiop://127.0.0.1:1050");

        return new InitialContext(env);
    }

    /** Metodo encargado de ejecutar la tarea*/
    void <b>arranca</b>() {
        // inicializamos las variables
        Context jndiContext = null;
        Queue destino = null;
        QueueConnection  conexion = null;
        QueueSession  sesionActual = null;
        QueueSender  enviadorMensajes = null;
        TextMessage mensaje = null;


        // identificamos en nombre de la cola
        String colaDestino = "<font color="#FF0000">ColaRoberto</font>";

        try {
            depura("Creamos un contexto");
             //jndiContext = new InitialContext();
            jndiContext = getInitialContext();
        }
        catch (NamingException e) {
            System.out.println("Imposible crear el contexto  " + "contexto: " + e.toString());
            System.exit(1);
        }

        try {
            // creamos el objeto para construir la conexion
            depura("Buscamos la factoria");
            QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup("<font color="#FF0000">QueueConnectionFactory</font>");

            // localizamos la cola destino
            depura("Buscamos la cola");
            destino = (Queue) jndiContext.lookup(<font color="#FF0000">colaDestino</font>);

            // creamos una conexión
            depura("Creamos la conexion");
            conexion = queueConnectionFactory.createQueueConnection();

            depura("Creamos la sesion");
            sesionActual = conexion.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

            // Creamos una factoria de mensaje y un mensaje
            depura("Creamos el productor de mensajes");

          <font color="#0000FF">  enviadorMensajes = sesionActual.createSender(destino);

            mensaje = sesionActual.createTextMessage();
<font size="3">           <i> </i></font></font>

* envioMensajeSimple.java

* Created on 12 de agosto de 2003, 22:33

* @author Roberto Canales

import javax.naming.*;

import javax.jms.*;

import java.util.*;

public class envioMensajeSimple {

/** Punto de entrada a la aplicacion*/

public static void main(String[] args) {

envioMensajeSimple programa = new envioMensajeSimple();

programa.arranca();

}

/** Funcion para centralizar mensajes*/

void depura(String cadena) {

System.out.println("Mensaje: " + cadena);

}

private static InitialContext getInitialContext() throws NamingException

{

Hashtable env = new Hashtable();

env.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");

env.put("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");

env.put(Context.PROVIDER_URL, "iiop://127.0.0.1:1050");

return new InitialContext(env);

}

/** Metodo encargado de ejecutar la tarea*/

void arranca() {

// inicializamos las variables

Context jndiContext = null;

Queue destino = null;

QueueConnection conexion = null;

QueueSession sesionActual = null;

QueueSender enviadorMensajes = null;

TextMessage mensaje = null;

// identificamos en nombre de la cola

String colaDestino = "ColaRoberto";

try {

depura("Creamos un contexto");

//jndiContext = new InitialContext();

jndiContext = getInitialContext();

}

catch (NamingException e) {

System.out.println("Imposible crear el contexto " + "contexto: " + e.toString());

System.exit(1);

}

try {

// creamos el objeto para construir la conexion

depura("Buscamos la factoria");

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup("QueueConnectionFactory");

// localizamos la cola destino

depura("Buscamos la cola");

destino = (Queue) jndiContext.lookup(colaDestino);

// creamos una conexión

depura("Creamos la conexion");

conexion = queueConnectionFactory.createQueueConnection();

depura("Creamos la sesion");

sesionActual = conexion.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

// Creamos una factoria de mensaje y un mensaje

depura("Creamos el productor de mensajes");

enviadorMensajes = sesionActual.createSender(destino);

mensaje = sesionActual.createTextMessage();

<i><font size="3" color="#0000FF">		</font><b><font size="3" color="#FF00FF">mensaje.setStringProperty("TipoMensaje", "1");</font></b></i><font size="3">
</font>

           long inicio = System.currentTimeMillis();

           for(int i=0;i<1000;i++)
           {
               // Asociamos texto al mensaje
 <b>               mensaje.setText("Nuevo mensaje " + new Date() );
</b><font color="#0000FF">
                //depura("Enviamos el mensaje");
                enviadorMensajes.send(mensaje);</font>
           }
            enviadorMensajes.close();

            long fin = System.currentTimeMillis() - inicio;
            System.out.println("El tiempo transcurrido es " + fin + " milisegundos");


        }
        catch (Exception e) {
            depura("Error en la aplicación " + e.toString());
            e.printStackTrace();
        }
        finally {
            if (conexion != null) {
                try {
                    conexion.close();
                }
                catch (JMSException e)
                {}
            }
        }

        depura("Salimos del programa");
    }
}

mensaje.setStringProperty("TipoMensaje", "1");

long inicio = System.currentTimeMillis();

for(int i=0;i<1000;i++)

{

// Asociamos texto al mensaje

mensaje.setText("Nuevo mensaje " + new Date() );

//depura("Enviamos el mensaje");

enviadorMensajes.send(mensaje);

}

enviadorMensajes.close();

long fin = System.currentTimeMillis() - inicio;

System.out.println("El tiempo transcurrido es " + fin + " milisegundos");

}

catch (Exception e) {

depura("Error en la aplicación " + e.toString());

e.printStackTrace();

}

finally {

if (conexion != null) {

try {

conexion.close();

}

catch (JMSException e)

{}

}

depura("Salimos del programa");

}

Ahora el código del cliente (que se diferencia muy poquito del anterior)

/*
 * recuperacionPrecio.java
 *
 * Created on 20 de agosto de 2003, 20:22
 */
import javax.naming.*;
import javax.jms.*;
import java.util.*;

/**
 *
 * @author  Roberto Canales
 */
public class <b>recepcionMensajeSimple</b> {

    /** Creates a new instance of recuperacionPrecio */
    public recepcionMensajeSimple() {
    }

    /**
     * @param args the command line arguments
     */
    /** Punto de entrada a la aplicacion*/
    public static void <b>main</b>(String[] args) {
        recepcionMensajeSimple programa = new recepcionMensajeSimple();
        programa.arranca();
    }

    /** Funcion para centralizar mensajes*/
    void <b>depura</b>(String cadena) {
        System.out.println("Mensaje: " + cadena);
    }

    private static InitialContext <b>getInitialContext</b>() throws NamingException
    {
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");
        env.put("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");
        env.put(Context.PROVIDER_URL, "iiop://127.0.0.1:1050");

        return new InitialContext(env);
    }

    /** Metodo encargado de ejecutar la tarea*/
    void <b>arranca</b>() {
        // inicializamos las variables
        Context jndiContext = null;
        Queue origen = null;
        QueueConnection  conexion = null;
        QueueSession  sesionActual = null;
        QueueReceiver  receptorMensajes = null;
        TextMessage mensaje = null;


        // identificamos en nombre de la cola
        String colaorigen = "ColaRoberto";

        try {
            depura("Creamos un contexto");
             //jndiContext = new InitialContext();
            jndiContext = getInitialContext();
        }
        catch (NamingException e) {
            System.out.println("Imposible crear el contexto  " + "contexto: " + e.toString());
            System.exit(1);
        }

        try {
            // creamos el objeto para construir la conexion
            depura("Buscamos la factoria");
            QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup("QueueConnectionFactory");

            // localizamos la cola origen
            depura("Buscamos la cola");
            origen = (Queue) jndiContext.lookup(colaorigen);

            // creamos una conexión
            depura("Creamos la conexion");
            conexion = queueConnectionFactory.createQueueConnection();

            depura("Creamos la sesion");
            sesionActual = conexion.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

            // Creamos una factoria de mensaje y un mensaje
            depura("Creamos el Receptor de Mensajes");
         <font color="#0000FF">
            receptorMensajes = sesionActual.createReceiver(origen);

            depura("Arrancamos la conexion");
            conexion.start();

            depura("Leemos el mensajes");
            mensaje = (TextMessage)receptorMensajes.receive();

            depura("El mensaje recibido es " + mensaje.getText());

            receptorMensajes.close();
</font>       }
        catch (Exception e) {
            depura("Error en la aplicación " + e.toString());
            e.printStackTrace();
        }
        finally {
            if (conexion != null) {
                try {
                    conexion.close();
                }
                catch (JMSException e)
                {}
            }
        }

        depura("Cerramos el lector");
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

* recuperacionPrecio.java

* Created on 20 de agosto de 2003, 20:22

import javax.naming.*;

import javax.jms.*;

import java.util.*;

/**

* @author Roberto Canales

public class recepcionMensajeSimple {

/** Creates a new instance of recuperacionPrecio */

public recepcionMensajeSimple() {

}

/**

* @param args the command line arguments

/** Punto de entrada a la aplicacion*/

public static void main(String[] args) {

recepcionMensajeSimple programa = new recepcionMensajeSimple();

programa.arranca();

}

/** Funcion para centralizar mensajes*/

void depura(String cadena) {

System.out.println("Mensaje: " + cadena);

}

private static InitialContext getInitialContext() throws NamingException

{

Hashtable env = new Hashtable();

env.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");

env.put("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");

env.put(Context.PROVIDER_URL, "iiop://127.0.0.1:1050");

return new InitialContext(env);

}

/** Metodo encargado de ejecutar la tarea*/

void arranca() {

// inicializamos las variables

Context jndiContext = null;

Queue origen = null;

QueueConnection conexion = null;

QueueSession sesionActual = null;

QueueReceiver receptorMensajes = null;

TextMessage mensaje = null;

// identificamos en nombre de la cola

String colaorigen = "ColaRoberto";

try {

depura("Creamos un contexto");

//jndiContext = new InitialContext();

jndiContext = getInitialContext();

}

catch (NamingException e) {

System.out.println("Imposible crear el contexto " + "contexto: " + e.toString());

System.exit(1);

}

try {

// creamos el objeto para construir la conexion

depura("Buscamos la factoria");

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup("QueueConnectionFactory");

// localizamos la cola origen

depura("Buscamos la cola");

origen = (Queue) jndiContext.lookup(colaorigen);

// creamos una conexión

depura("Creamos la conexion");

conexion = queueConnectionFactory.createQueueConnection();

depura("Creamos la sesion");

sesionActual = conexion.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

// Creamos una factoria de mensaje y un mensaje

depura("Creamos el Receptor de Mensajes");

receptorMensajes = sesionActual.createReceiver(origen);

depura("Arrancamos la conexion");

conexion.start();

depura("Leemos el mensajes");

mensaje = (TextMessage)receptorMensajes.receive();

depura("El mensaje recibido es " + mensaje.getText());

receptorMensajes.close();

}

catch (Exception e) {

depura("Error en la aplicación " + e.toString());

e.printStackTrace();

}

finally {

if (conexion != null) {

try {

conexion.close();

}

catch (JMSException e)

{}

}

depura("Cerramos el lector");

}

Si usais NetBeans (o cualquier otro entorno gráfico) aseguraos que
encuentra el fichero j2ee.jar

Si arrancamos ahora nuestro programa para enviar mensajes a la cola

Mensaje: Creamos un contexto
Mensaje: Buscamos la factoria
Mensaje: Buscamos la cola
Mensaje: Creamos la conexion
Java(TM) Message Service 1.0.2 Reference Implementation (build b14)
Mensaje: Creamos la sesion
Mensaje: Creamos el productor de mensajes
El tiempo transcurrido es <font color="#FF0000"><b>43142</b></font> milisegundos
Mensaje: Salimos del programa

Mensaje: Creamos un contexto

Mensaje: Buscamos la factoria

Mensaje: Buscamos la cola

Mensaje: Creamos la conexion

Java(TM) Message Service 1.0.2 Reference Implementation (build b14)

Mensaje: Creamos la sesion

Mensaje: Creamos el productor de mensajes

El tiempo transcurrido es 43142 milisegundos

Mensaje: Salimos del programa

El tiempo es un pelín alto.. aunque puede deberse a distintas cosas (como el
lookup de nombre de máquina)

Si paramos el servidor de aplicaciones

Y lo volvemos a arrancar ….. y lanzamos el programa que lee mensajes de la
cola … los mensajes siguen

Mensaje: Creamos un contexto
Mensaje: Buscamos la factoria
Mensaje: Buscamos la cola
Mensaje: Creamos la conexion
Java(TM) Message Service 1.0.2 Reference Implementation (build b14)
Mensaje: Creamos la sesion
Mensaje: Creamos el Receptor de Mensajes
Mensaje: Arrancamos la conexion
Mensaje: Leemos el mensajes
Mensaje: El mensaje recibido es Nuevo mensaje Sat Aug 23 10:38:54 CEST 2003
Mensaje: Cerramos el lector

Hay un linea que marcamos en el programa enviador de mensajes

mensaje.setStringProperty(«TipoMensaje»,
«1»);

Una de las gracias que tiene el uso de JMS, es que te permite
conectar un programa cliente y filtrar solo los mensajes que deseas …..

Si modificamos un poquito el programa receptor (ojo que ahora
leemos 1000 mensajes) .. podemos establecer el filtro a través de propiedades,
con una sintaxis parecida a la de SQL

/*
 * recepcionSimpleConFiltro .java
 *
 * Created on 20 de agosto de 2003, 20:22
 */
import javax.naming.*;
import javax.jms.*;
import java.util.*;

/**
 *
 * @author  Roberto Canales
 */
public class <b>recepcionSimpleConFiltro</b> {

    /** Creates a new instance of recuperacionPrecio */
    public recepcionSimpleConFiltro() {
    }

    /** Punto de entrada a la aplicacion*/
    public static void <b>main</b>(String[] args) {
        recepcionSimpleConFiltro programa = new recepcionSimpleConFiltro();
        programa.arranca();
    }

    /** Funcion para centralizar mensajes*/
    void <b>depura</b>(String cadena) {
        System.out.println("Mensaje: " + cadena);
    }

    private static InitialContext <b>getInitialContext</b>() throws NamingException
    {
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");
        env.put("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");
        env.put(Context.PROVIDER_URL, "iiop://127.0.0.1:1050");
        //env.put("org.omg.CORBA.ORBInitialHost","127.0.0.1");

        return new InitialContext(env);
    }

    /** Metodo encargado de ejecutar la tarea*/
    void <b>arranca</b>() {
        // inicializamos las variables
        Context jndiContext = null;
        Queue origen = null;
        QueueConnection  conexion = null;
        QueueSession  sesionActual = null;
        QueueReceiver  receptorMensajes = null;
        TextMessage mensaje = null;


        // identificamos en nombre de la cola
        String colaorigen = "ColaRoberto";

        try {
            depura("Creamos un contexto");
             //jndiContext = new InitialContext();
            jndiContext = getInitialContext();
        }
        catch (NamingException e) {
            System.out.println("Imposible crear el contexto  " + "contexto: " + e.toString());
            System.exit(1);
        }

        try {
            // creamos el objeto para construir la conexion
            depura("Buscamos la factoria");
            QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup("QueueConnectionFactory");

            // localizamos la cola origen
            depura("Buscamos la cola");
            origen = (Queue) jndiContext.lookup(colaorigen);

            // creamos una conexión
            depura("Creamos la conexion");
            conexion = queueConnectionFactory.createQueueConnection();

            depura("Creamos la sesion");
            sesionActual = conexion.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

            // Creamos una factoria de mensaje y un mensaje
            depura("Creamos el Receptor de Mensajes");

 <b><font size="3">        receptorMensajes = sesionActual.createReceiver(origen,"TipoMensaje = 1");
</font><font size="4"> </font></b>
            depura("Arrancamos la conexion");
            conexion.start();

            depura("Leemos el mensajes");
            <font color="#0000FF">for(int i=0;i<1000;i++)</font>
            mensaje = (TextMessage)receptorMensajes.receive();

            depura("El mensaje recibido es " + mensaje.getText());

            receptorMensajes.close();
        }
        catch (Exception e) {
            depura("Error en la aplicación " + e.toString());
            e.printStackTrace();
        }
        finally {
            if (conexion != null) {
                try {
                    conexion.close();
                }
                catch (JMSException e)
                {}
            }
        }

        depura("Cerramos el lector");
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

* recepcionSimpleConFiltro .java

* Created on 20 de agosto de 2003, 20:22

import javax.naming.*;

import javax.jms.*;

import java.util.*;

/**

* @author Roberto Canales

public class recepcionSimpleConFiltro {

/** Creates a new instance of recuperacionPrecio */

public recepcionSimpleConFiltro() {

}

/** Punto de entrada a la aplicacion*/

public static void main(String[] args) {

recepcionSimpleConFiltro programa = new recepcionSimpleConFiltro();

programa.arranca();

}

/** Funcion para centralizar mensajes*/

void depura(String cadena) {

System.out.println("Mensaje: " + cadena);

}

private static InitialContext getInitialContext() throws NamingException

{

Hashtable env = new Hashtable();

env.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");

env.put("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");

env.put(Context.PROVIDER_URL, "iiop://127.0.0.1:1050");

//env.put("org.omg.CORBA.ORBInitialHost","127.0.0.1");

return new InitialContext(env);

}

/** Metodo encargado de ejecutar la tarea*/

void arranca() {

// inicializamos las variables

Context jndiContext = null;

Queue origen = null;

QueueConnection conexion = null;

QueueSession sesionActual = null;

QueueReceiver receptorMensajes = null;

TextMessage mensaje = null;

// identificamos en nombre de la cola

String colaorigen = "ColaRoberto";

try {

depura("Creamos un contexto");

//jndiContext = new InitialContext();

jndiContext = getInitialContext();

}

catch (NamingException e) {

System.out.println("Imposible crear el contexto " + "contexto: " + e.toString());

System.exit(1);

}

try {

// creamos el objeto para construir la conexion

depura("Buscamos la factoria");

QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup("QueueConnectionFactory");

// localizamos la cola origen

depura("Buscamos la cola");

origen = (Queue) jndiContext.lookup(colaorigen);

// creamos una conexión

depura("Creamos la conexion");

conexion = queueConnectionFactory.createQueueConnection();

depura("Creamos la sesion");

sesionActual = conexion.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

// Creamos una factoria de mensaje y un mensaje

depura("Creamos el Receptor de Mensajes");

receptorMensajes = sesionActual.createReceiver(origen,"TipoMensaje = 1");

depura("Arrancamos la conexion");

conexion.start();

depura("Leemos el mensajes");

for(int i=0;i<1000;i++)

mensaje = (TextMessage)receptorMensajes.receive();

depura("El mensaje recibido es " + mensaje.getText());

receptorMensajes.close();

}

catch (Exception e) {

depura("Error en la aplicación " + e.toString());

e.printStackTrace();

}

finally {

if (conexion != null) {

try {

conexion.close();

}

catch (JMSException e)

{}

}

depura("Cerramos el lector");

}

Como conclusión …. la utilización de colas de mensajes….. penalizando
en tiempo … nos proporciona mayores garantias de entrga y mejores capacidades
de gestión, desacomplando la generación y la captura..

Conclusión General

En función del tipo de aplicación …. debemos decidir cual es el sistema
que más nos interesa

… aunque con este ejemplo si hemos ganado algo claro …. la posibilidad de
tener ejemplos a mano, para hacer nuestras propias pruebas.

Sobre el
Autor ..

2 Comentarios

ale_T_L lopez 31 octubre, 2014 at 3:53 am

Siguiendo el tutorial, en la parte que ejecuto la linea de comandos \\\»j2ee -verbose\\\» me da el siguiente fallo:

ERROR: Set JAVA_HOME to the path of a valid jdk.

Donde tendria que tener instalada la jdk??

Algo me puede ayudar, Gracias

Responder
alejandro morales 31 octubre, 2014 at 3:54 am

amigo esa aplicacion puede enviar vensajes masivos cargados de na base de datos o de excel

Responder

Escritura log con Fichero UDP y JMS

Coste de Envio de mensajes de Log

Mensajes por pantalla y en fichero

Escritura UDP

Envio de mensajes a través de JMS

Conclusión General

2 Comentarios

Dejar respuesta Cancelar respuesta

Envíanos tu tutorial