Vérifier le statut d'un courtier ActiveMQ

Je veux créer une classe java , qui a pour seul but de vérifier le statut d'un courtier ActiveMQ (ou la connectivité à un courtier ActiveMQ comme une interruption de service peut être définie comme le client de perte de la connexion réseau).

donc, fondamentalement, il y aurait un thread en cours d'exécution après toutes les quelques secondes pour vérifier le statut du courtier et si le courtier est en panne, je veux faire un tâche spécifique de l'envoi du groupe de soutien et des trucs comme ça.

Les exemples en ligne ne sont pas suffisamment détaillées pour expliquer comment le ci-dessus peut être réalisé.

Quelqu'un a déjà fait cela, ou peut suggérer une belle façon de rendre cela possible??

Grâce,
Neeraj

OriginalL'auteur Neeraj | 2011-10-18

  1. 7

    Envoyer un Testmessage au courtier:

    try {
    ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
    Connection conn = factory.createConnection(user, password);
    Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
    MessageProducer producer = session.createProducer("test");
    MessageConsumer consumer = session.createConsumer("test");
    consumer.setMessageListener(this); //class that implements MessageListener
    conn.start();
    TextMessage message = new ActiveMQTextMessage();
    message.setText("TestMessage");
    producer.send(message);
} catch (JMSException e) {
    //somethings very wrong
}

    connecter, envoyer un message, si vous recevez le message: tout est très bien. si non....

    c'est ce que je fais. En plus je fais d'autres trucs:

    • écouter plusieurs Consultatif des Sujets de recevoir des événements importants (comme le comité Consultatif.PLEIN) qui sont des indicateurs importants que somethings mal.
    • régulièrement le courtier statistiques de la statistique, le plugin pour surveiller le message de la taille de la mémoire de stockage des messages.
    • configurer une file d'attente de lettres mortes si je sais que quand un message a été rejeté par le consommateur.
    Serait le bloc catch être exécutée même si le courtier est en panne et ne pas répondre?ou si il y a un énorme réseau de retard?
    lorsque le courtier est en bas de la createConnection d'échec de l'appel et de l'exception sera pris. si vous voulez juste pour vérifier le réseau de retard, vous devrez manuellement la commande ping sur le serveur à partir d'une distance de destination. le bouclage du périphérique n'est jamais ralentir.

    OriginalL'auteur Laures

  2. 8

    La suite sera aussi pour vérifier si ActiveMQ est en place et en cours d'exécution:

    try {
   ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(url);
   //set transport listener so that active MQ start is notified.
   factory.setTransportListener(transportListenerObject); 
   Connection connection = factory.createConnection();
   //This will throw error if activeMQ is not running.
   connection.setClientID("my_client_id"); 
} catch (JMSException ex) {
    if (ex.getLinkedException() instanceof IOException) {
        //ActiveMQ is not running. Do some logic here.
        //use the TransportListener to restart the activeMQ connection
        //when activeMQ comes back up.
    } else {
        //Something seriously went wrong with the factory or connection
        //creation. Abort the process here, as nothing can be done.
        //Log the error and troubleshoot.
    }
}
    Pourquoi était-ce downvoted?
    Comment u peut utiliser le TransportListener, pour redémarrer quand courtier activeMQ revient?
    Cela va déclencher la transportResumed() la méthode

    OriginalL'auteur Anand

  3. 7

    J'ai besoin d'une solution pour la même question, c'est pourquoi j'ai lire plus sur le sujet et fait plusieurs tests.

    L'envoi d'un message de test (comme Laures suggéré) peut être un problème dans certains environnements.

    La façon "normale" serait de définir un TransportListener (comme Anand proposé), mais vraiment de mettre en œuvre la condition de l'interface et de réagir sur les événements signalés.

    Pour d'autres ActiveMQ, des débutants (comme je l'ai été jusqu'au mois dernier), je poste un échantillon de démarrage de la mise en œuvre. Il a juste écrit la journalisation pour chaque événement. Dans un environnement réel, on peut penser à une reconnexion procès en transportInterupted() jusqu'à transportResumed() ou similaire et beaucoup de choses plus ...

    import java.io.IOException;

import org.apache.activemq.transport.TransportListener;
import org.apache.log4j.Logger;

class ConnectionStateMonitor
  implements TransportListener
{
  private static final Logger log = Logger.getLogger(ConnectionStateMonitor.class);

  @Override
  public void onCommand(Object command)
  {
    log.debug("Command detected: '" + command + "'");
  }

  @Override
  public void onException(IOException exception)
  {
    log.error("Exception detected: '" + exception + "'");
  }

  @Override
  public void transportInterupted()
  {
    log.error("Transport interuption detected.");
  }

  @Override
  public void transportResumed()
  {
    log.info("Transport resumption detected.");
  }
}

    La TransportListener peut être défini par exemple:

    ActiveMQConnection connection = (ActiveMQConnection) _factory.createConnection();
...
connection.addTransportListener(new ConnectionStateMonitor());

    Amusez-vous!

    En outre, vous pouvez également utiliser le basculement dans l'URI de connexion, "le basculement:tcp://host:port ". Cela indiquera au client de se reconnecter automatiquement si il y a une exception socket: activemq.apache.org/how-can-i-support-auto-reconnection.html

    OriginalL'auteur Mayoares