บทที่ 5

ลีสซิ่งและรีโมตอีเวนต์ำ

5.1 ลีสซิ่ง

5.1.1 การใช้ ลีสระหว่าง Lookup Service และ Service ของ Jini

1. มีชนิดเป็น long ซึ่งหมายถึงหน่วยเป็นมิลลิวินาที เช่น 1000 หมายถึง 1 วินาที
2. Lease.ANY หมายถึง ให้ Lookup Service เป็นผู้ตัดสินใจเองว่าจะให้เวลาเท่าใด
3.   Lease.FOREVER หมายถึง ขอลีสที่ไม่มีเวลาหมดอายุ

รูปที่ 5-1 Service ไดัรับลีสจาก Lookup Service

package net.jini.core;

public interface Lease {

    void cancel();

    long getExpiration();

    void renew(long duration);

}

long duration = lease.getExpiration() - System.currentTimeMillis();

LeaseRenewalManager

package net.jini.lease;

public Class LeaseRenewalManager {

    public LeaseRenewalManager();

    public LeaseRenewalManager(Lease lease, long expiration,

 LeaseListener listener);

    public void renewFor(Lease lease, long duration,

                         LeaseListener listener);

    public void renewUntil(Lease lease, long expiration,

   LeaseListener listener);

    // etc

}

LeaseRenewalManager สามารถดูแลลีสได้ทีละหลาย ๆ ตัวโดยที่การส่งลีสให้ LeaseRenewalManager ดูแลนั้นสามารถส่งไปทาง คอนสตรัคเตอร์หรือส่งโดยเรียกใช้เมธอด  renewFor() และ renewUntil() เวลาที่ร้องขอไปจะเป็นหน่วยมิลลิวินาทีเหมือนกันในทุก Method   โดย expiration หมายความว่าคือเวลาที่ลีสจะหมดอายุ ส่วน duration หมายความว่า เวลานับจากนี้ไปเท่าใด

แต่อย่างไรก็ตามหาก LeaseRenewalManager ไม่สามารถ รีนิวลีสได้ด้วยสาเหตุต่าง ๆ เช่นลีสหมดอายุไปแล้วหรือเครือข่ายขัดข้อง ก็จะมี Exception ส่งออกมาซึ่งจะถูกจับไว้ด้วย LeaseRenewalManager แล้วทำการเรียกใช้เมธอด notify() ของ LeaseListener ที่ลงทะเบียนไว้เมื่อตอนสร้าง LeaseRenewalManager

5.1.2 การใช้ลีสระหว่าง Service ของ Jini และ Client

            กระบวนการการใช้ลีสในการดูแล Client ว่ายังคงเชื่อมต่อ อยู่หรือไม่นั้นสามารถนำมาใช้กับ Service ใด ๆ ก็ได้ ซึ่งการที่ Service จะใช้กระบวนการ ลีสซิ่ง สำหรับ ดูแล Client ของตนนั้น Service จะต้องสร้างกระบวนการ ลีสซิ่ง ขึ้นมาเอง เนื่องจากว่าตัวกระบวนการนั้นไม่ได้เป็นส่วนหนึ่งของ Jini API ตัว ชุดพัฒนา Jini นั้นมีเพียง Interface ของคลาส ต่าง ๆ ที่จำเป็นต้องใช้มาให้เท่านั้น ส่วนลีสและผู้ดูแลลีสนั้นจึงต้องสร้างขึ้นมาเองโดย สร้างตาม Interface ที่มีมาให้ คือ AbstractLease  และ LandLord package

5.1.2.1 AbstractLease

package com.sun.jini.lease;

public abstract class AbstractLease implements Lease,java.io.Serializable {

    protected AbstractLease(long expiration);

    public long getExpiration();

    public int getSerialFormat();

    public void setSerialFormat(int format);

    public void renew(long duration);

    protected abstract long doRenew(long duration);

}

คลาสนี้ทำการสร้างตาม Lease โดยตรงโดยวิธีการนำไปใช้มีเงื่อนไข 3 อย่างคือ

1. คอนสตรัคเตอร์ของคลาส นี้ประกาศว่าเป็นแบบ protected เพราะฉะนั้นการตั้งอายุของลีสนั้นสามารถตั้งได้โดย คลาส ที่เป็น ซับคลาสของคลาสนี้เท่านั้น
2. เนื่องจากเมธอด  renew() จะทำการเรียกต่อไปยังเมธอด  doRenew() เพื่อทำการ รีนิว ซึ่ง doRenew()เป็น แอ็บสแทรกต์ Method   ดังนั้นจึงเป็นการบังคับให้ซับคลาสจะต้องสร้างวิธีการในการ รีนิว ด้วยการโอเวอร์ไรด์ Method นี้
3. AbstractLease ไม่ได้ ไม่ได้มีการสร้างเมธอด  cancel() ของ Lease เหลือไว้ให้ ซับคลาสเป็นผู้ สร้าง

5.1.2.2 แพคเกจ LandLord

            เมื่อมีการร้องขอลีสตัวใหม่ Landlord จะใช้ landlord lease factory เป็นตัวสร้างลีส (LandLord สามารถสร้างเองก็ได้ แล้วแต่วิธีการสร้าง LandLord ว่าจะให้ทำอย่างไร) เมื่อลีสต้องการจะ แคนเซิล หรือ รีนิว ก็จะให้ Landlord เป็นผู้จัดการให้ โดยที่ Client ไม่จำเป็นต้องคุยกับ LandLord โดยตรง แต่กระทำผ่านลีสออบเจ็กต์

รูปที่ 5-2 คลาสและ Interface บางส่วนในแพคเกจ Landlord

com.sun.jini.lease.landlord.LeaseResource ( Interface )

com.sun.jini.lease.landlord.LeasePolicy ( Interface )

com.sun.jini.lease.landlord.LeaseManager( Interface )

            Interface นี้จะถูกนำไปสร้าง สำหรับคลาสที่ทำการจัดการกระบวนการหลังจากที่ระบบลีสซิ่ง ได้มีการทำงานต่าง ๆ เช่น มีการสร้างลีสใหม่ หรือลีสที่มีอยู่แล้วถูก รีนิว ซึ่ง LeaseManager นี้จะใช้จัดกระกระบวนการเช่น เก็บรักษา LeaseResource ที่เกิดใหม่ทั้งหมด ทำการทำลาย LeaseResource ที่หมดอายุแล้ว และกระบวนการต่าง ๆ อีกมากมาย แล้วแต่จะสร้างขึ้นอย่างไรก็ได้ โดยจะมีเมธอด  register() และ renew() สำหรับรับการแจ้งเตือนว่ามีลีสที่เกิดใหม่หรือมีลีสที่ถูกรีนิว ซึ่ง LeaseManager นี้อาจจะถูกแจ้งเตือนโดย Landlord ก็ได้

com.sun.jini.lease.landlord.LeaseDurationPolicy (คลาส)

คลาส นี้สร้างขึ้นโดยสร้างมาจาก Interface ของ LeasePolicy ซึ่งออบเจ็กต์นี้จะถูกใช้โดย Landlord ในการสร้างลีสใหม่ หรือทำการ รีนิวลีสโดยที่สามารถส่ง LandlordLeaseFactory และ LeaseManager ให้เป็นพารามิเตอร์สำหรับคอนสตรัคเตอร์ได้เพื่อให้ไว้ใช้สำหรับการสร้างลีสใหม่ และจัดการลีสที่เกิดขึ้น จากแผนภาพ UML ด้านล่างนี้ แสดงตัวอย่างการสร้างระบบลีสซิ่งด้วย แพคเกจ Landlord

รูปที่ 5-3 ตัวอย่างการออกแบบกระบวนการลิสซิ่ง

• Landlord (FooLandlord) สามารถจัดการกับลีสหลาย ๆ ตัว แต่ว่าสามารถอ้างอิงถึงลีส(LandlordLease) แต่ละตัวได้จาก คุกกี้ (Cookie) ซึ่งลีสแต่ละตัวนั้นจะมีตัวอ้างอิงไปยัง Landlord ของตัวเอง และเรียกใช้ Method ของ Landlord โดยใช้คุ๊กกี้ของตัวเอง
• การที่ Client จะกระทำใด ๆ กับลีส (เช่น รีนิวหรือแคนเซิล) การร้องขอนั้นจะถูกส่งต่อไปยัง Landlord (FooLandlord) เนื่องมาจากการจะจัดการกับลีสอย่างไรนั้นจะต้องขึ้นอยู่กับ วิธีการและการตัดสินใจของ Landlord โดยที่ Landlord จะส่งไปให้กับ LeaseDurationPolicy เป็นตัวจัดการ
• LeaseFactory สามารถถูกใช้ได้จากหลาย ๆ LeasePolicy
• Landlord หนึ่งสามารถมีได้หลาย LeasePolicy และสามารถเลือกได้ว่าจะใช้ Policy ไหน
• LeaseManager หนึ่งสามารถถูกใช้ได้จาก หลาย ๆ LeasePolicy โดยส่งผ่านเป็นคอนสตรัคเตอร์ให้กับ LeaseDurationPolicy

5.2 ระบบรีโมตอีเวนต์

5.2.1 RemoteEvent

package net.jini.core.event;

public class RemoteEvent {

    public long getID();

    public long getSequenceNumber();

    public java.rmi.MarshalledObject getRegistrationObject();

}

5.2.2 การลงทะเบียน Event

public void addActionListener(ActionListener listener);

public RventRegistration registerForEvent(RemoteEventListener listener);

ซึ่งพารามิเตอร์สำหรับ Method นี้ก็คือ RemoteEventListener ซึ่งทำหน้าที่เป็นตัวดักจับอีเวนต์นั่นเองสำหรับโครงสร้างของ EventRegistration คือ

package net.jini.core.event;

import net.jini.core.lease.Lease;

public class EventRegistration implements java.io.Serializable {

    public EventRegistration(long eventID, Object source, Lease lease

                             ,long seqNum);

    public long getID();

    public Object getSource();

    public Lease getLease();

    public long getSequenceNumber();

}

5.2.3 RemoteEventListener

public interface RemoteEventListener

                 extends java.rmi.Remote, java.util.EventListener {

    public void notify(RemoteEvent theEvent) throws UnknownEventException,java.rmi.RemoteException;

}

5.2.4 Single Listener

            หากมีออบเจ็กต์ผู้ดักฟังเพียงตัวเดียวเราสามารถใช้ตัวแปรที่มีค่าเดียว (Single-valued variable) มารองรับออบเจ็กต์ผู้ดักฟังอีเวนต์ได้

รูปที่ 5-4 คลาสไดอะแกรมของระบบ Single Listener

โดยตัวอย่าง Method ที่ใช้ทำการลงทะเบียนดักฟังอีเวนต์คือ

//Use landlord for create new lease

protected ServerLandlord landlord = new ServerLandlord()

protected final long defaultDuration = 10*1000  //10 Seconds

protected RemoteEventListener listener = null;

public EventRegistration addRemoteListener(RemoteEventListener listener)

                           throws java.util.TooManyListenersException {

    if (this.listener == null){

this.listener = listener;

    } else { throw new java.util.TooManyListenersException(); }

    //Create new Lease for EventRefgsitration

    Lease l = landlord.newLease(defaultDuration);

    return new EventRegistration(0L, this, l, 0L);

}

public void eventNotify(long eventID, long seqNum){

    if(listener == null){

       return;

    }

    //Create Remote event and send event to listener object

    RemoteEvent remoteEvent = new RemoteEvent(this, eventID, seqNum, null);

    Listener.notify(remoteEvent);

}

5.2.5 Multiple Listener

            ในกรณีที่จะต้องรองรับออบเจ็กต์ที่ทำการดักฟังอีเวนต์หลายตัวนั้น ในการออกแบบอาจจะใช้ออบเจ็กต์ประเภท คอนเทนเนอร์มาช่วยในการเก็บรักษาออบเจ็กต์ตัวดักฟังอีเวนต์เช่น Vector, Hashtable หรืออาจจะใช้ javax.swing.event.EventListenerList มาช่วยก็สามารถทำได้

รูปที่ 5-5 คลาสไดอะแกรมของระบบ Multiple Listener

โดยตัวอย่าง Method ที่ใช้ทำการลงทะเบียนดักฟังอีเวนต์ซึ่งยังไม่ได้จัดการกับลีสที่หมดอายุแล้วคือ

//Use landlord for create new lease

protected ServerLandlord landlord = new ServerLandlord()

protected final long defaultDuration = 10*1000  //10 Seconds

protected Vector listeners = new Vector();

public EventRegistration addRemoteListener(RemoteEventListener listener)

                           throws java.util.TooManyListenersException {

    //Add listener to Vector

    listeners.addElement(listener);

    //Create new Lease for EventRefgsitration

    Lease l = landlord.newLease(defaultDuration);

    return new EventRegistration(0L, this, l, 0L);

}

และตัวอย่าง Method ที่ทำการส่งอีเวนต์ให้กับตัวดักฟังคือ

public void eventNotify(long eventID, long seqNum){

    if(listeners.isEmpty()){

       return;

    }

    //Create Remote event object

    RemoteEvent remoteEvent = new RemoteEvent(this, eventID, seqNum, null);

    //Send RemoteEvent to all listeners

    RemoteEventListener listener = null;

    For(Enumeration e = listeners.elements();e.hasMoreElements();){

listener = (RemoteEventListener)e.nextElement();

Listener.notify(remoteEvent);

    }

}

5.3 รีโมตอีเวนต์สำหรับ Lookup Service

            ในกรณีที่ Client กำลังทำงานอยู่ Client สามารถได้รับข้อมูลต่าง ๆ จาก Lookup Service ได้เช่น มี Service ที่ต้องการมาลงทะเบียนใหม่ Service ที่กำลังใช้อยู่ได้ออกจากระบบจินีไปแล้ว หรือ Service ที่มีอยู่มีการเปลี่ยนแปลง Attribute

            ซึ่งกระบวนการที่กล่าวมานี้นั้น Lookup Service จะใช้หลักการของ รีโมตอีเวนต์ เพื่อส่งอีเวนต์ไปบอกยัง Client ของ Lookup Service กระบวนการที่จะทำให้ Client สามารถรับอีเวนต์จาก Lookup Service ได้ก็เหมือนกับกระบวนการของ รีโมตอีเวนต์ดังที่กล่าวมาแล้วข้างต้น ก็คือ

• สร้างออบเจ็กต์สำหรับดักฟังอีเวนต์
• ลงทะเบียนออบเจ็กต์นั้นกับ ต้นกำเนิดของอีเวนต์ซึ่งกรณีนี้ก็คือ Lookup Service นั่นเอง

ตัวอย่างของคลาสสำหรับออบเจ็กต์ตัวดักฟังคือ

import java.rmi.*;

import java.rmi.server.*;

import net.jini.core.lookup.*;

import net.jini.core.event.*;

public class LookupServiceListener extends UnicastRemoteObject

                                     implements RemoteEventListener {

    public void notify(RemoteEvent event) throws UnknownEventException

                                                   RemoteException{

       if(!(event instanceof ServiceEvent)){

           Throw new UnknownEventException(“LookupServiceListener”);

}

ServiceEvent sevent = (ServiceEvent)event;

ServiceItem item = sevent.getServiceItem();

if(sevent.getTransition()==ServiceRegistrar.TRANSITION_NOMATH_MATCH){

    System.out.println(“Found new Service”);

}

    }

}

TRANSITION_NOMATH_MATH

TRANSITION_MATH_NOMATH

TRANSITION_MATH_MATH

• Template Object สำหรับ Service ที่ต้องการค้นหา
• ลักษณะการเปลี่ยนแปลงที่ต้องการจะรู้
• RemoteEventListener
• มาแชลด์ออบเจ็กต์ (Marshaled Object)
• ระยะเวลาที่ต้องการจะรับอีเวนต์

ซึ่งหลังจากเรียกใช้ Method นี้แล้ว ก็จะคืนค่าออกมาเป็นออบเจ็กต์ของคลาส EventRegistration ซึ่งจะนำมาใช้เช่นเดียวกับกระบวนการของ RemoteEvent ทั่วไปคือนำลีสที่ได้จาก EventRegistration ออบเจ็กต์ ไปส่งให้กับ LeaseRenewalManager เพื่อดูแลต่อไป

Last update : June 17, 2009 17:00 ( Thailand )

Apple, Mac, iMac, iPhone and iPod are trademarks of Apple, Inc.

Jini, Java and all Java-based are trademarks of Sun Microsystems, Inc.

JiniSoft Corporation

Copyright @ 1990 - 2009   Mr. Roongroj Rojanapo ( )

99/2 Soi Ramindra 14, Ramindra Road, Bangkane, Bangkok 10230, Thailand

	E-mail	:	roongroj @ mac.com
	SMS	:	081 615-5135  ( iPhone )
	FAX	:	02   943-6433