Java. Java Message Service. ANTAL Margit. JMS API technológia. ANTAL Margit. Sapientia - EMTE

Java ´ ak ´ technologi ˝ as ´ 14. eload Java Message Service ANTAL Margit

´ ak ´ - 14. eload ˝ as ´ Java technologi Java Message Service

¨ Uzenet´ ıtasi ´ tovabb´ ´ mintak JMS API ´ technologia ´ ak ´ peld

ANTAL Margit Sapientia - EMTE

2008

˝ as ´ celja ´ Az eload


◮ ◮ ◮

¨ ´ os ´ architektur ´ Uzenetkommunik aci ´ ak ´ JMS technologia ´ ak ´ Peld ◮ ◮ ◮ ◮

¨ ´ o´ Uzenet gyart Szinkron uzenetfogyaszt o´ ¨ Aszinkron uzenetfogyaszt o´ ¨ ¨ Uzenetbab (message-driven bean)


¨ ´ ıtasi ´ mintak ´ Uzenettov abb´


◮

point-to-point modell: az uzenetet egyetlen ¨ ´ ´ calalkalmazashoz kell eljuttatni ¨ ´ asa: ´ Uzenetek tarol ◮ ◮

◮

´ memoria ´ o´ perzisztens tarol

¨ publish-subscribe modell: az uzenetet tobb ¨ ¨ alkalmazasnak ´ komponensnek, illetve tobb kell ´ ıtani tovabb´ ´ as) ´ jellegu˝ kozz ¨ et ´ etel ´ broadcast (uzenetsz or ¨ ◮ ◮ ◮

´ ıtoje ˝ publisher: az uzenet kesz´ ¨ ´ ¨ topic: tema kor ˝ ˝ subscriber: elofizet ok


Point-point architektura ´

Java ´ ak ´ technologi ˝ as ´ 14. eload Java Message Service ANTAL Margit ¨ Uzenet´ ıtasi ´ tovabb´ ´ mintak JMS API ´ technologia ´ ak ´ peld

Publish-subscribe architektura ´


¨ ´ ˝ Uzenetrendszer resztvev ok


¨ Uzenetrendszer ◮

◮

◮

◮

´ ´ osztalyok ´ JMS API: olyan Java interfeszek es ´ asok ´ halmaza, mely az uzenetkezel o˝ szolgaltat ¨ ´ of ´ uggetlen ´ es ´ et ´ lehetov ˝ e´ teszik - (javax.jms gyart eler ¨ csomag) ´ o: ´ konkret ´ uzenetkezel JMS API implementaci o˝ ¨ ´ rendszer. Nem szuks u, ¨ egszer ˝ hogy Javaban legyen ´ implementalva. ´ ´ ´ Alkalmazasszerver JMS tamogat assal: ´ ´ ast ´ biztos´ıt. Regisztralni ´ kell a nevszolg altat ´ okat, ´ ´ ´ kapcsolat gyart uzenetk uld asi ¨ ¨ esi/-fogad ´ vegpontokat (queue, topic) ¨ ´ ´ as ´ seg´ıtseg ´ evel ´ ´ amely a nevszolg altat Ugyfel: ´ ´ ast ´ igenybe veszi a szolgaltat


´ objektumok Adminisztralt


´ ´ Ezeket alkalmazasszerverben kell letrehozni (pl. GlassFish): ◮ Connection Factories szerepe kodb ´ ol ´ kapcsolatot ´ ıthetunk letes´ o˝ rendszerrel. ¨ uzenetkezel ¨ ◮ Destination Resources t´ıpusok: ◮ ◮

´ Topic Destination: publish-subscribe architektur ´ ahoz ´ Queue Destination: point-to-point architektur ´ ahoz


¨ Uzenetrendszer ugyfelek ¨


´ asa ´ vagy fogyasztasa ´ Feladatuk: uzenet gyart ¨ ◮ gyart ´ o´ ◮ fogyaszto ´ ◮ ◮

´ ´ szinkron : varakozik am´ıg uzenet erkezik ¨ ´ regisztral ´ az uzenetsorn ´ amely aszinkron: azugyf al, ¨ el ¨ ´ ´ ´ ¨ ´ uzenet erkez esekor ertes´ ıti az osszes regisztralt ¨ ugyfelet ¨


¨ Uzenetek


◮

´ Reszei: ◮

◮ ◮

◮

´ az uzenet ´ ıtas ´ ara ´ vonatkozo´ fejlec: tovabb´ ¨ ´ ok ´ informaci ´ ´ ert ´ ek) ´ parok ´ tulajdonsagok: (nev¨ torzs: az uzenet tartalma ¨

JMS API uzenet t´ıpusok: ¨ ◮ ◮ ◮ ◮

◮

´ TextMessage : karakterlanc ¨ MapMessage : asszociat´ıv tomb ´ BytesMessage : bajtsorozat StreamMessage: Java primit´ıv t´ıpusu´ adatokat tartalmazo´ adatfolyam ´ ObjectMessage: szerializalhat o´ Java objektum


´ ´ esei ´ JMS hasznalat tipikus lep


´ evel ´ ´ uk lekerj 1. JNDI seg´ıtseg ¨ a ConnectionFactory-t. ´ ashoz ´ ´ Ez tartalmazza a kapcsolod szuks ¨ eges ´ ´ evel ´ parametereket. Ennek seg´ıtseg kapcsplatot nyitunk az uzenetrendszerrel (Connection). ¨ ´ evel ´ ´ 2. A Connection seg´ıtseg letrehozunk egy Session ´ es ´ objektumot. Ez testes´ıti meg az uzenetk uld ¨ ¨ es ´ munkamenetet. ´ fogadas ´ ´ es ´ architektur ´ ol ´ fugg ˝ ´ 3. Vegpontt ol letrehozzuk az ´ at ¨ oen ˝ illetve fogado´ objektumokat. uzenetk uld ¨ ¨ o, ◮ ◮

˝ QueueSender, TopicPublisher kuld ¨ o: ´ QueueReceiver, TopicSubscriber fogado:


´ ak ´ Peld


´ ´ ult, Mindharom projekt Netbeansben kesz ¨ t´ıpusa: Enterprise Application Client ◮

QSender

◮

SyncQReceiver

◮

AsyncQReceiver


http://www.ms.sapientia.ro/˜manyi/QSender.txt http://www.ms.sapientia.ro/˜manyi/SyncQReceiver.txt http://www.ms.sapientia.ro/˜manyi/AsyncQReceiver.txt

¨ ´ ıtese ´ Uzenetbabok kesz´


◮ ◮

aszinkron uzenetfogyaszt o´ ugyfelek ¨ ¨ ´ ak ´ a MessageListener interfeszt ´ implementalj

◮

¨ ´ uk, ´ nincs kozvetlen interfesz sem pedig ¨ sem lokalis, ´ ´ eshez ´ tavoli eler

◮

´ ezzel a komponenssel indirekt modon, az ´ uzenetsoron keresztul, ¨ ¨ lehet kommunikalni ˝ od ¨ o˝ komponensek rejtozk

◮


´ MessageListener interfesz

Java ´ ak ´ technologi ˝ as ´ 14. eload Java Message Service ANTAL Margit ¨ Uzenet´ ıtasi ´ tovabb´ ´ mintak

import javax.jms.*;

JMS API ´ technologia ´ ak ´ peld

public interface MessageListener{ public void onMessage( Message message); }

¨ Uzenetbab I package jms; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.jms.*;


@MessageDriven( mappedName = "jms/myQueue", activationConfig = { @ActivationConfigProperty (propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"), @ActivationConfigProperty (propertyName = "destinationType", propertyValue = "javax.jms.Queue") }

¨ Uzenetbab II )


public class MessageListenerBeanBean implements MessageListener { public void onMessage( Message message ){ TextMessage msg = null; try{ if( message instanceof TextMessage){ msg = (TextMessage) message; System.out.println( "Received message: "+msg.getText()); } else{ System.out.println( "Message of wrong type "); }


¨ Uzenetbab III


} catch( Exception e ){ System.out.println( "Exception: "+ e.getMessage()); } } }


Java. Java Message Service. ANTAL Margit. JMS API technológia. ANTAL Margit. Sapientia - EMTE

Recommend Documents