在ejb环境中实现“观察者”模式.htm

写给JSP初级程序员的书

int count = 0;&nbsp;<br>
while (i.hasNext()){&nbsp;<br>
ListenerSupplier listenerSupplier = (ListenerSupplier)i.next();&nbsp;<br>
array[count] = listenerSupplier.getListener(publisherClass);&nbsp;<br>
count++;&nbsp;<br>
}&nbsp;<br>
return array;&nbsp;<br>
}&nbsp;<br>
<br>
/**&nbsp;<br>
* 返回当前已经为指定发布者类注册的监听器提供者副本。&nbsp;<br>
* 这是一个同步方法，从而允许getListeners方法保持非同&nbsp;<br>
* 步。&nbsp;<br>
* @param publisherClass&nbsp;<br>
* @param checkInheritance 如为true，则返回为指定发布者类和它的所有父类&nbsp;<br>
* 注册的监听器提供者；如为flase，则只返回为指定发布者类注册的监听&nbsp;<br>
* 器提供者&nbsp;<br>
* @return 相应的监听器提供者的集合（永不为null）&nbsp;<br>
*/&nbsp;<br>
private synchronized Collection getListenerSuppliersCopy(Class&nbsp;<br>
publisherClass, boolean checkInheritance){&nbsp;<br>
if ( checkInheritance ) {&nbsp;<br>
Collection publishers = myListenerSuppliersMap.keySet();&nbsp;<br>
Iterator i = publishers.iterator();&nbsp;<br>
Collection listenerSuppliers = new ArrayList();&nbsp;<br>
while (i.hasNext()) {&nbsp;<br>
Class nextPublisherClass = (Class)i.next();&nbsp;<br>
if ( nextPublisherClass.isAssignableFrom(publisherClass) ) {&nbsp;<br>
if ( myListenerSuppliersMap.get(nextPublisherClass) != null ) {&nbsp;<br>
listenerSuppliers.addAll((Collection)&nbsp;<br>
myListenerSuppliersMap.get(nextPublisherClass));&nbsp;<br>
}&nbsp;<br>
}&nbsp;<br>
}&nbsp;<br>
return listenerSuppliers;&nbsp;<br>
} else {&nbsp;<br>
Collection listenerSuppliers = (Collection)&nbsp;<br>
myListenerSuppliersMap.get(publisherClass);&nbsp;<br>
if ( listenerSuppliers == null ) {&nbsp;<br>
return Collections.EMPTY_LIST;&nbsp;<br>
} else {&nbsp;<br>
//如果你决定不使用ArrayList，请改用clone支持的其他cast方式&nbsp;<br>
return (ArrayList)((ArrayList)listenerSuppliers).clone();&nbsp;<br>
}&nbsp;<br>
}&nbsp;<br>
}&nbsp;<br>
<br>
/**&nbsp;<br>
* 一个确保值非null的简单方法&nbsp;<br>
*/&nbsp;<br>
protected void assertNotNull(String message, Object object){&nbsp;<br>
if ( object == null ) {&nbsp;<br>
throw new IllegalArgumentException(message);&nbsp;<br>
}&nbsp;<br>
}&nbsp;<br>
//保存“发布者类 -> 监听器提供者的集合”对&nbsp;<br>
protected HashMap myListenerSuppliersMap = new HashMap();&nbsp;<br>
private static DefaultListenerRegistry instance = new DefaultListenerRegistry();&nbsp;<br>
}&nbsp;<br>
<br>
<br>
第二个提供者示例允许使用无状态会话Bean作为监听器。它用会话Bean的一个EJBHome构造，利用create()方法返回一个可用的无状态会话Bean。请注意这个提供者在WebLogic 5.1下运行，这是因为，该服务器串行化对无状态Bean的调用，不会因为同时使用同一无状态Bean而抛出RemoteException异常。&nbsp;<br>
<br>
//StatelessSupplier.javapackage com.jwasp.listener;&nbsp;<br>
import java.util.EventListener;&nbsp;<br>
import javax.ejb.CreateException;&nbsp;<br>
import javax.ejb.EJBHome;&nbsp;<br>
import java.rmi.RemoteException;&nbsp;<br>
import java.lang.reflect.Method;&nbsp;<br>
import java.lang.reflect.InvocationTargetException;&nbsp;<br>
/**&nbsp;<br>
* 在getListener方法中，利用指定的监听器（无状态会话Bean）&nbsp;<br>
* 的EJBHome调用create()方法返回一个监听器。请确保EJB容&nbsp;<br>
* 器串行化了对监听器的调用（或者在fireXXX方法中提供对监&nbsp;<br>
* 听器的同步）。&nbsp;<br>
*/&nbsp;<br>
public class StatelessSupplier implements ListenerSupplier {&nbsp;<br>
public StatelessSupplier(EJBHome ejbHome) throws RemoteException{&nbsp;<br>
if ( ejbHome == null ) {&nbsp;<br>
throw new IllegalArgumentException("EJBHome is null");&nbsp;<br>
} else if ( !ejbHome.getEJBMetaData().isStatelessSession() ) {&nbsp;<br>
throw new IllegalArgumentException&nbsp;<br>
("EJBHome should belong to stateless session bean");&nbsp;<br>
}&nbsp;<br>
myEjbHome = ejbHome;&nbsp;<br>
}&nbsp;<br>
public EventListener getListener(Class publisherClass)&nbsp;<br>
throws RemoteException, ListenerActivationException {&nbsp;<br>
try {&nbsp;<br>
Method createMethod = myEjbHome.getClass().getMethod("create", new Class[0]);&nbsp;<br>
Object object = createMethod.invoke(myEjbHome, new Object[0]);&nbsp;<br>
if ( object instanceof EventListener ) {&nbsp;<br>
return (EventListener)object;&nbsp;<br>
} else {&nbsp;<br>
throw new ListenerActivationException("Remote interface doesn't extend EventListener");&nbsp;<br>
}&nbsp;<br>
} catch(NoSuchMethodException nsme) {&nbsp;<br>
throw new ListenerActivationException("Home interface doesn't define create() method");&nbsp;<br>
} catch(SecurityException se) {&nbsp;<br>
throw new ListenerActivationException(se.getMessage());&nbsp;<br>
} catch(IllegalAccessException iae) {&nbsp;<br>
throw new ListenerActivationException(iae.getMessage());&nbsp;<br>
} catch(IllegalArgumentException iare) {&nbsp;<br>
throw new ListenerActivationException(iare.getMessage());&nbsp;<br>
} catch(InvocationTargetException ite) {&nbsp;<br>
throw new ListenerActivationException(ite.getTargetException().getMessage());&nbsp;<br>
}&nbsp;<br>
}&nbsp;<br>
private EJBHome myEjbHome;&nbsp;<br>
}&nbsp;<br>
<br>
<br>
■ 结束语&nbsp;<br>
本文描述的框架允许你使用分布式的观察者/监听器（不错，监听器也可以是EJB；提供者将负责创建/定位EJB）。但是，它的目标不是替代JMS或消息驱动的Bean，该框架的目标是补充那两种强大的通知机制。结合JMS、消息驱动的Bean，本文描述的框架允许你在面对分布式事件发布者和监听器时，正确地实现Observer模式。&nbsp;<br>
<br>
注意发布者不必一定是EJB。当发布者是普通的类时，你同样可以方便地应用本文所描述的框架。&nbsp;<br>
<br>
最后，我想要指出，该框架的本质是：在发布者和观察者当时不存在的情况下，建立两者之间的关系。因此，任何想要发布者在创建时配置自己的地方，都可以使用本文所介绍的框架（如果发布者是一个EJB，则配置应该在ejbCreate()/ejbActivate()方法里进行；如果发布者是一个普通的类，则应该在构造函数里进行）。按照这种方法，如果发布者不是一个singleton，你不必担心所有的实例都有一组同样的监听器（或一组同样的实现业务逻辑的功能）。&nbsp;<br>
<br>
下载本文的源代码：&nbsp;<br>
<br>
http://www.ccidnet.com/tech/focus/java_little_t/ImplementObserverPattern.zip<br>
<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
</p>

</body>

</html>