EJB Message Driven Bean

Message Driven Bean, kurumsal uygulamalarda asenkron mesajları ele alan java bean’dir. MDB, EJB konteynır tarafından tetiklenir. Session veya Entity bean’lerden farklı olarak direk istemci tarafından tetiklenmez. MDB tarafında alınan ileti JMS tarafından yollanır yani ileti JMS kuyruk ya da başlık yapısına gelince, MDB sınıfı EJB konteynır tarafından tetiklenir.

MDB iki tane arayüz (interface) implement etmelidir.

· javax.jms.MessageListener

Bu interface’te onMessage() metodunu tanımlanmaktadır. İleti kuyruk/başlık (queue/topic) yapısına set edilmişse, EJB konteynır MDB’nin onMessage() metodunu tetikler ve iletiyi yollar.

· javax.ejb.MessageDrivenBean

EJB yaşam döngüsünü içeren bir arayüz tanımıdır.

ejbCreate(), EJB konteynır MDB’yi yaratmak istediginde çağırır.

ejbRemove(), EJB konteynır MDB’yi silmek istediginde çağırır. EJB havuzundan siler.

setMessageDrivenContext(), EJB konteynırı tarafından gerekli verilerin yollamasını sağlar.

MDB sınıfı;

· Home ya da Remote arayüzlere sahip değil,

· Yaşam döngüsü kısadır, Stateless Session Bean’lere benzemektedir.

· EJB 2.0’da asenkron mesajlaşma için tasarlanmıştır.

MDB konfigürasyonu ejb-jar.xml de yapılır. Konfigürasyon aşağıdaki gibidir.

MDB sınıfının adı, dizin bilgisi, transaction tipi, ....

MDB nesnesi istemci tarafından doğrudan çağrılmaz. EJB konteynır JMS kuyruk/başlık (queue/topic) yapısına set edilen iletiyi MDB’nin onMessage() metodunu çağırarak iletiyi parametre geçer. Yukarıda değinildiği gibi MDB iki tane arayüzü implement etmek zorundadır. MDB sınıfının iskelet yapısı aşağıdaki gibidir.

public class MyMDB implements MessageDrivenBean, MessageListener{

    private transient MessageDrivenContext ctx = null;

    public MyMDB(){}

    public void setMessageDrivenContext(MessageDrivenContext ctx){

        this.ctx = ctx;

    }

    public void ejbCreate(){}

    public void ejbRemove(){}

    public void onMessage(Message message){

       System.out.println("MDB Message received: "+ message.toString());

    }

 }

JMS Point to Point Messaging

Uygulamalar arası mesajlaşma nasıl yapılmaktadır? Uygulamalardan biri Gönderen Uygulama, diğeri ise Alan Uygulamadır. Gönderen uygulama mesajı kuyruğa yollar, alan uygulama ya kuyruğu dinler ya da direk kuyruktan alır. Bir gönderen, iki alan uygulama örnegini aşağıda inceleyeceğiz.

• Queue Sender
• Synchronous Queue Receiver
• Asynchronous Queue Receiver

Gönderen Uygulama
1. InitialContext nesnesi tanımlanır.
2. Tanımlanan Context nesnesi JMS Server’da tanımlanmış olan kuyruk(queue) yapısını arar.
3. Tanımlanan kuyruk yapısı için QueueConnectionFactory nesnesi tanımlanır.
4. QueueConnectionFactory nesnesini kullanarak QueueConnection nesnesini yaratırız.
5. Yaratılan Connection uzerinden QueueSession nesnesini yaratırız. Bu session’ın transacted olup olmamasına burda karar veririz.
6. QueueSession nesnesini kullanarak QueueSender nesnesini yaratırız ve ilgili mesajımızı tanımlarız.
7. Tanımladığımız mesajı gönderici kuyruk yapısı ile göndeririz.
Yukarıda yapılan anlatımları kodlamak istersek :

QueueConnection queueConn = null;
try {
InitialContext ctx = new InitialContext();
Queue queue = (Queue) ctx.lookup("queue/queue0");
QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.lookup("queue/connectionFactory");
queueConn = connFactory.createQueueConnection();
QueueSession queueSession = queueConn.createQueueSession(false, Session.DUPS_OK_ACKNOWLEDGE);
QueueSender queueSender = queueSession.createSender(queue);
queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
TextMessage message = queueSession.createTextMessage("Asin Akdeniz");
queueSender.send(message);
} catch (Exception ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}finally{
if(queueConn != null){
try {
queueConn.close();
} catch (JMSException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
}
}
}//end of finally

Alıcı Uygulama

Alıcı uygulamalar senkron ve asenkron alıcılar olabilmektedir. Senkron Alıcı, gönderici gibi ilk tanımlamaları yapar bir kaç detay dışında. Initial Context i kullanarak kuyruk yapısı tanımlanır, connection kurulur, session yaratılır. Farklılık bundan sonra başlıyor, QueueSender yerine mesajların alımının sağlayacak QueueReceiver nesnesi tanımlanır. QueueSender’den sonra yazılacak kod parçası aşağıdaki gibidir.

QueueReceiver queueReceiver = queueSession.createReceiver(queue);
queueConn.start();
TextMessage message = (TextMessage) queueReceiver.receive();
queueConn.close();

Asenkron alıcı uygulaması biraz daha farklılaşmaktadır. Burada alıcı sınıfın mesaj dinleyicileri tanımlanır. Tanımlayacağımız alıcı sınıfın MessageListener Java arayüzünü implement etmesi gerekmektedir. Bu arayüz sadece onMessage metodunu içermektedir. Tanımladığımız istemci nesnesini QueueReceiver’ın setMessageListener metoduna register ederiz.

InitialContext ctx = new InitialContext();
Queue queue = (Queue) ctx.lookup("queue/queue0");
QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.lookup("queue/connectionFactory");
QueueConnection queueConn = connFactory.createQueueConnection();
QueueSession queueSession = queueConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
QueueReceiver queueReceiver = queueSession.createReceiver(queue);
Main asyncReceiver = new Main();
queueReceiver.setMessageListener(asyncReceiver);
queueConn.setExceptionListener(asyncReceiver);
queueConn.start();
System.out.print("waiting for messages");
for (int i = 0; i < 10; i++) {
Thread.sleep(1000);
System.out.print(".");
}
System.out.println();
queueConn.close();
}
public void onMessage(Message message){
TextMessage msg = (TextMessage) message;
try {
System.out.println("received: " + msg.getText());
} catch (JMSException ex) {
ex.printStackTrace();
}
}
public void onException(JMSException exception){
System.err.println("an error occurred: " + exception);
}

Java Message Service (JMS) Giriş

Mesajlaşma Nedir?

Yazılım bileşenleri ya da uygulamaları arasında iletişimi sağlayan metodtur. Istemci (Client) mesajı başka bir istemciye gönderir ya da alır. Gönderenin (Sender), alıcı (receiver) hakkında herhangi birşey bilmesine gerek yok tersi içinde aynısı geçerli. Gönderenin ve alanın sadece mesaj formatı konusunda bilgi sahibi olması gerekmektedir. Bu bağlamda mesajlaşmanın RMI gibi teknolojilerden (uzaktaki uygulamanın metod bilgisinin gerektirtiği) farklı olduğu anlaşılmaktadır.

JMS API?

Java Message Service, okuma/gonderme/alma/yaratma gibi mesajlaşma özelliklerine sahip olan Java API’sidir. JMS uygulama bileşenleri arasında doğrudan iletişim kurmak yerine bir mesaj sunucusu (Message Server) aracılığıyla iletişim kurmasını sağlar. JMS iletişimi Asenkron ve güvenli sağlanır. Istemci mesajı diğer istemciye gonderir ve istemci bu mesajı gerektiği zaman alır. Bu mesajlaşma güvenilir bir şekilde yapılır yani mesajlar kaybolmaz ya da birden fazla kez yollanmaz.

JMS Mimarisi?

Kısaca JMS elemanları hakkında bilgi vermek gerekirse:

· JMS Provider (JMS interfacelerinin implementasyonudur.)

· JMS Client (Mesajı gönderen ya da alan uygulamadır.)

· JMS Producer/Publisher (JMS istemcisinin mesajı yaratması ve göndermesidir.)

· JMS Consumer/Subscriber (JMS istemcisinin mesajı almasıdır.)

· JMS Message (JMS istemcileri arasında transfer edilen veridir.)

· JMS Queue (Yollanan mesajların okunmaya hazır halde beklediği kuyruk veri yapısıdır.)

· JMS Topic (Dağıtıcı istemci tarafından dağıtılan mesajların birden fazla alıcı istemci tarafından alınmasını sağlayan mekanizmadır.)

JMS Model

JMS API si 2 modeli desteklemektedir.

· Point to point or Queuing Model

· Publish and Subscribe Model

Point to point : Gönderici istemci mesajı kuyruk (queue) yapısına yollar, alıcı istemci ise bu kuyruk yapısından mesajı olur. Sadece bir alıcı mesajı okuyabilir ve her okunan mesaj için alındığına dair bilgilendirme yapılır.

Publish/Subscribe Model: belirlenen mesaj başlığına (message topic) mesajları yollar. Birden fazla istemci bu mesaj başlığına register olup gelen mesajları alır. Bu istemcilerin birbirlerinden ya da gondericiden haberi olmaz. İstemciler listener olgusuna kaydolur ve yollanan mesajları alır. Mesaj bütün kayıtlı istemciler tarafından alındıktan sonra silinir.

JMS i kullanmak için öncelikle session ve kuyrukları (queue) yönetecek JMS provider’a ihtiyaç vardır.

· OpenJMS, from The OpenJMS Group

· Open Message Queue, from Sun Microsystems

· JBoss Messaging from JBoss

· Apache ActiveMQ

bunlardan bazıları..

JMS 2 bölümünde kavramlar daha da detaylandırılacak.