是否可以在Java中編寫通用多路複用器？

Question

我有很多使用setListener方法註冊的監聽器，而不是addListener。所以爲了允許多個監聽器註冊一個對象，我必須使用多路複用器。這很好，但現在我必須爲每個偵聽器接口創建一個多路複用器。所以我的問題是：是否可以按照以下代碼的要求實現Mux.create（）？

AppleListener appleListener1 = new AppleProcessorA(); 
AppleListener appleListener2 = new AppleProcessorB(); 
AppleListener appleListenerMux = Mux.create(appleListener1, appleListener2); 
Apple apple = new Apple(); 
apple.setListener(appleListenerMux); 

OrangeListener orangeListener1 = new OrangeProcessorA(); 
OrangeListener orangeListener2 = new OrangeProcessorB(); 
OrangeListener orangeListenerMux = Mux.create(orangeListener1, orangeListener2); 
Orange apple = new Orange(); 
orange.setListener(orangeListenerMux); 

class Mux { 
    public static <T> T create(T... outputs) { } 
} 

我想這可能是使用反射。有沒有什麼理由使用反射會是一個壞主意？ （性能出現在腦海裏）

Answer 1

這是可能的使用動態Proxy。

最簡單的方法是將所需的界面作爲第一個參數傳遞給您的Mux.create()調用。否則，您將不得不使用反射來從所提供的所有具體偵聽器實例中猜測所需的接口（難以確定所有偵聽器對象是否實現了幾個共同的接口）。

下面是它的短：

public class Mux { 

    /** 
    * @param targetInterface 
    *   the interface to create a proxy for 
    * @param instances 
    *   the concrete instances to delegate to 
    * @return a proxy that'll delegate to all the arguments 
    */ 
    @SuppressWarnings("unchecked") 
    public static <T> T create(Class<T> targetInterface, final T... instances) { 
     ClassLoader classLoader = targetInterface.getClassLoader(); 
     InvocationHandler handler = new InvocationHandler() { 
      @Override 
      public Object invoke(Object proxy, Method m, Object[] args) 
        throws Throwable { 
       for (T instance : instances) { 
        m.invoke(instance, args); 
       } 
       return null; 
      } 
     }; 
     return (T) Proxy.newProxyInstance(classLoader, 
       new Class<?>[] { targetInterface }, handler); 
    } 
} 

，你會使用，例如，如下：

Apple apple = new Apple(); 
AppleListener l1 = new AppleListenerA(); 
AppleListener l2 = new AppleListenerB(); 
apple.setListener(Mux.create(AppleListener.class, l1, l2)); 
apple.doSomething(); // will notify all listeners 

這是通過簡單地創建一個動態Proxy被強制轉換爲目標類型T。該代理使用InvocationHandler，該代理只將代理的所有方法調用委託給給定的具體實例。

注意，儘管在一般我完成所有的參數和局部變量只要有可能，我只有在這種情況下完成T... instances強調這一事實，如果instances是不決賽，然後引用它的匿名內部類中不會被允許（你會得到一個「不能引用在不同方法中定義的內部類中的非最終變量參數」）。

還要注意的是，上述假設的實際方法調用不返回任何有意義的（或有用的）值，因此handler也返回null所有方法調用。如果您想收集返回值並以有意義的方式返回這些值，則需要添加更多代碼。

---

另外，可以檢查所有給instances以確定它們都實現了常用接口，並通過所有那些newProxyInstance()。這使得Mux.create()使用起來更加方便，並且失去了對其行爲的一些控制。

/** 
* @param instances 
*   the arguments 
* @return a proxy that'll delegate to all the arguments 
*/ 
@SuppressWarnings("unchecked") 
public static <T> T create(final T... instances) { 

    // Inspect common interfaces 
    final Set<Class<?>> commonInterfaces = new HashSet<Class<?>>(); 
    commonInterfaces.addAll(Arrays.asList(instances[0].getClass() 
      .getInterfaces())); 

    // Or skip instances[0] 
    for (final T instance : instances) { 
     commonInterfaces.retainAll(Arrays.asList(instance.getClass() 
       .getInterfaces())); 
    } 

    // Or use ClassLoader.getSystemClassLoader(); 
    final ClassLoader classLoader = instances[0].getClass().getClassLoader(); 

    // magic 
    final InvocationHandler handler = new InvocationHandler() { 
     @Override 
     public Object invoke(final Object proxy, final Method m, final Object[] args) 
       throws Throwable { 
      for (final T instance : instances) { 
       m.invoke(instance, args); 
      } 
      return null; 
     } 
    }; 

    final Class<?>[] targetInterfaces = commonInterfaces 
      .toArray(new Class<?>[commonInterfaces.size()]); 
    return (T) Proxy.newProxyInstance(classLoader, targetInterfaces, 
      handler); 
} 

Answer 2

我認爲您的解決方案是「適配器」和「工廠方法」設計模式的混合。關於如何在Java中實現這些模式，我已經提供了以下兩個有用的鏈接：

• Adapter design pattern in Java
• Factory method design pattern in Java

Answer 3

Composite模式很適合你的情況。

AppleListener appleListener1 = new AppleProcessorA(); 
AppleListener appleListener2 = new AppleProcessorB(); 
CompositeListener composite = CompositeListener.for(appleListener1, appleListener2); 
Apple apple = new Apple(); 
apple.setListener(composite); 

您可能需要重構AppleListener和OrangeListener實現一個包含了受通知監聽器的方法的Listener接口。 CompositeListener還必須擴展此偵聽器以實現組合模式。