Qu'est-ce que le passage de message?

Question

Quel est le message passant en Java? Si vous le pouvez, donnez un exemple.

Answer 1

Message Passing En Java

• Lorsqu'un thread envoie un message (un objet) à un autre thread.

• Utilisé pour la communication de thread et la synchronisation dans des environnements où les threads n'ont pas de mémoire partagée Les threads ne peuvent donc pas partager des sémaphores ou des moniteurs et ne peuvent pas utiliser de variables partagées pour communiquer. Le passage de message peut toujours être utilisé, bien sûr, dans une plate-forme de mémoire partagée.

• Les messages sont envoyés via un canal avec une opération comme envoi (canal, message) et reçus d'un canal avec une opération comme réception (canal, message). Les messages peuvent être transmis de manière synchrone, ce qui signifie que l'expéditeur se bloque jusqu'à ce que le destinataire reçoive une réception et que le destinataire se bloque jusqu'à ce que l'expéditeur effectue un envoi. Puisque l'expéditeur et le destinataire sont à des points connus spécifiques dans leur code à un instant spécifique connu, le passage de message synchrone est également appelé un simple rendez-vous avec un flux d'informations unidirectionnel de l'expéditeur vers le destinataire. Un exemple est un agent de jeu d'échecs. Les agents peuvent traiter les messages de manière synchrone, puisqu'ils seront en train de se passer une poignée de main tout au long de la partie.

• Lors du passage de message asynchrone, l'expéditeur ne bloque pas. S'il n'y a pas de récepteur en attente de réception du message, le message est mis en file d'attente ou tamponné. Le récepteur bloque toujours s'il n'y a pas de message mis en file d'attente ou tamponné lorsqu'une réception est exécutée.

Answer 2

Votre question est un peu vague, mais je suppose que vous faites peut-être référence à l'API Java Message Service? Si oui, Wikipedia peut tout vous dire à ce sujet: http://en.wikipedia.org/wiki/Java_Message_Service

Mais si vous parlez de plus de "générique" de passage de messages, alors je vous suggère de jeter un oeil sur le lien ewernli posté!

Answer 3

Interaction classique entre deux threads: un producteur et un consommateur.

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(); 
    } 
}