MQSeries en utilisant Java

Ce n'est pas un cours d'instruction sur MQSeries pour Java. Au lieu de cela, vous êtes portés par les étapes à la façon installer et configurer MQSeries pour Java de sorte que vous puissiez développer et examiner des programmes de JMS. Si vous n'avez pas ces produits satisfont les téléchargent des sites Web appropriés. En outre, ce n'est pas un cours d'instruction détaillé sur JMS, bien que le code d'échantillon de JMS soit à condition que vous puissiez télécharger pour examiner votre configuration. Nous marcherons par le code d'échantillon pour expliquer ce qu'il fait, et pour te montrer comment les programmes de construction et de essai de JMS avec les outils d'IBM te permettent d'écrire le code portatif de JMS.

Conditions de matériel et de logiciel

Nous emploierons les versions de logiciel d'exploitation de Windows de MQSeries pour Java, ainsi vous devrez avoir un ordinateur avec le logiciel d'exploitation de Windows NT et avec le logiciel d'exploitation du paquet 6a ou du Windows 2000 de service avec le paquet 1 de service. Si vous employez Windows NT, vous assurez vous avoir la dernière version de Microsoft scripting l'appui installé sur votre ordinateur. La manière la plus facile d'assurer ceci est d'installer l'Internet Explorer 5.5 avec le plus défunt paquet de service. Vous aurez besoin au moins du mb 256 de RAM et environ 1.2 gigaoctet d'espace disque libre pour le téléchargement, installe, et des dossiers d'application.

Procédé d'installation et de configuration du MQSeries

Pour l'installation et la configuration du MQSeries, visiter svp l'aide d'installation

Classe de QSender

Il y a deux classes dans le code d'échantillon qui contiennent le code de JMS. Elles sont QSender et le QReceiver. Laisser passer par les méthodes importantes dans chacune de ces classes et regarder comment chacun emploie JMS pour envoyer et recevoir des messages.

Quand vous regardez ceci classe dans le nouveau dossier de code d'échantillon fourni ici, vous verra qu'ils diffèrent légèrement des classes dans l'article précédent. Puisque l'aucun-arg constructeur pour javax.naming.InitialContext se relie maintenant automatiquement pour transférer le serveur nommé, j'ai remplacé les appels au constructeur qui exigent java.util. Argument de propriétés avec des appels au l'aucun-arg constructeur. Ceci a également éliminé la nécessité de fournir des propriétés de système pour l'adresse d'usine de contexte de JNDI et de fournisseur de JNDI. Puisque ces propriétés de système n'ont été plus exigées, j'ai également enlevé la propriété de système pour le nom de contexte de JNDI, qui est pourquoi vous devez dactylographier jms/avant les noms de JNDI des objets administrés.

La fonctionnalité de transmission de messages de ces classes demeure la même que les versions plus tôt. La classe de QSender est employée par QSenderUI pour envoyer des messages à une file d'attente. Les méthodes importantes dans QSender sont setConnection (), setQueue (), et sendMessage (). Voici la méthode de setConnection ().

La prochaine méthode à regarder est setQueue (). Cette méthode s'appelle par le QSenderUI quand un nom de file d'attente est écrit dans le GUI. Voici le code pour le setQueue () :

public void setConnection(String connectionName)

							    throws JMSException, NamingException, Throwable {

							    try {

							        close();

							        QueueConnectionFactory factory =

							            
							(QueueConnectionFactory) getInitContext().lookup(

							              
							  getJmsContext() + connectionName);

							        connection = 
							factory.createQueueConnection();

							        session = 
							connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

							    } catch (Throwable e) {

							        setExceptionMessage(e);

							        throw e;

							    }

							}

La prochaine méthode à regarder est setQueue (). Cette méthode s'appelle par QSenderUI quand un nom de file d'attente est écrit dans le GUI. Voici le code pour le setQueue () :

public void setQueue(String queueName)

						    throws JMSException, NamingException, Throwable {

						    try {

						        if (connection != null)

						            
						connection.stop();

						        if (sender != null)

						            sender.close();

						        Queue queue = (Queue) 
						getInitContext().lookup(getJmsContext() + queueName);

						        sender = session.createSender(queue);

						        
						sender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

						        sender.setPriority(4);

						        sender.setTimeToLive(0);

						        connection.start();

						    } catch (Throwable e) {

						        setExceptionMessage(e);

						        throw e;

						    }

						}

Dans le setQueue (), la première chose à se produire est le QueueConnection est arrêtée et le QueueSender est fermé, si nécessaire. Puis, l'objet de file d'attente est recherché de JNDI basé sur le paramètre de queueName. Après, un QueueSender est créé pour envoyer des messages à la file d'attente, et des attributs sur le QueueSender sont placés. En conclusion, le QueueConnection est commencé, accès laissant au système de transmission de messages. De nouveau, il n'y a aucun code spécifique de MQSeries dans cette méthode.

Keywords: MQSeries Using Java,websphere mq using java,mqseries queue manager,java sample code,mqseries reason code,web services using java,java open source,java source code,using web services,using source code,mq using java,using open source.

HTML Quizes

XML Quizes