¿Qué está pasando el mensaje?

Question

¿Qué es el mensaje que pasa en Java? Si pudiera, por favor proporcione un ejemplo.

Answer 1

Paso de Mensajes En Java

• Cuando un hilo envía un mensaje (un objeto) a otro hilo.

• Se utiliza para la comunicación y sincronización de subprocesos en entornos donde los subprocesos no tienen memoria compartida. Por lo tanto, los subprocesos no pueden compartir semáforos o monitores y no pueden usar variables compartidas para comunicarse. El envío de mensajes aún se puede usar, por supuesto, en una plataforma de memoria compartida.

• Los mensajes se envían a través de un canal con una operación como enviar (canal, mensaje) y se reciben de un canal con una operación como recibir (canal, mensaje). Los mensajes se pueden pasar de forma síncrona, es decir, el emisor bloquea hasta que el recibido recibe una recepción y el receptor bloquea hasta que el emisor envía un mensaje. Dado que el emisor y el receptor se encuentran en puntos conocidos específicos en su código en un instante de tiempo específico conocido, el paso de mensaje síncrono también se denomina encuentro simple con un flujo de información unidireccional desde el emisor hasta el receptor. Un ejemplo es un agente de juego de ajedrez. Los agentes pueden procesar mensajes de forma síncrona, ya que serán un apretón de manos durante todo el juego.

• En la transmisión de mensajes asíncrona, el emisor no bloquea. Si no hay un receptor esperando recibir el mensaje, el mensaje está en cola o almacenado. El receptor todavía bloquea si no hay un mensaje en cola o almacenado en el búfer cuando se ejecuta una recepción.

Answer 2

Su pregunta es un poco vaga, pero supongo que podría estar refiriéndose a la API de Java Message Service? Si es así, Wikipedia puede informarle al respecto: http://en.wikipedia.org/wiki/Java_Message_Service

Pero si está hablando de mensajes más "genéricos", entonces le sugiero que eche un vistazo al enlace ewernli publicado.

Answer 3

Interacción clásica entre dos hilos: un Productor y un Consumidor.

import java.util.Vector; 

class Producer extends Thread { 
    static final int MAXQUEUE = 5; 
    private Vector messages = new Vector(); 

    public void run() { 
     try { 
      while (true) { 
       putMessage(); 
       sleep(1000); 
      } 
     } 
     catch(InterruptedException e) { } 
    } 

    private synchronized void putMessage() 
     throws InterruptedException { 

     while (messages.size() == MAXQUEUE) 
      wait(); 
     messages.addElement(new java.util.Date().toString()); 
     notify(); 
    } 

    // Called by Consumer 
    public synchronized String getMessage() 
     throws InterruptedException { 
     notify(); 
     while (messages.size() == 0) 
      wait(); 
     String message = (String)messages.firstElement(); 
     messages.removeElement(message); 
     return message; 
    } 
} 

class Consumer extends Thread { 
    Producer producer; 

    Consumer(Producer p) { 
     producer = p; 
    } 

    public void run() { 
     try { 
      while (true) { 
       String message = producer.getMessage(); 
       System.out.println("Got message: " + message); 
       sleep(2000); 
      } 
     } 
     catch(InterruptedException e) { } 
    } 

    public static void main(String args[]) { 
     Producer producer = new Producer(); 
     producer.start(); 
     new Consumer(producer).start(); 
    } 
}