我有这个基本的 News界面

interface News {
    String getHeader();
    String getText();
}

和像SportsNews这样的具体类和 FinancialNews提供特定方法，如 getStockPrice() , getSport()等等。新闻旨在发送给

interface Subscriber<N extends News> {
    void onNews(N news);
}

问题是如何注册和维护订阅。我尝试的第一种方法是使用中央 Aggregator , 在 Class<T> 之间保留 map 对象和 Set<Subscriber<T>> ，但很快这种方法就显露出行不通了。这是所需的 API

public class Aggregator {

    public <N extends News> void subscribe(Subscriber<N> subscriber) {
        // TODO somehow (super type token) extract N and 
        // add the item to the set retrieved by getSubscribersFor()
    }

    public <N extends News> void dispatch(N news) {
        for (Subscriber<N> subscriber: getSubscribersFor(news.getClass())) {
            subscriber.onNews(news);
        }
    }

    private <N extends News> Set<Subscriber<N>> getSubscribersFor(Class<N> k) {
        // TODO retrieve the Set for the specified key from the Map
    }
}

是否有任何类型安全的替代方案？ Java 完全可以解决这个问题吗？我把this little demo online帮助您更好地了解问题的真正所在。

更新

另一种方法是制作 Aggregator本身用实际的新闻类型参数化。这没问题，只是这是先有鸡还是先有蛋的问题:现在需要找到一种方法来检索聚合器。在 Java 中无法表达以下内容

interface News {
    static Aggregator<CurrentClass> getAggregator();
}

• static方法不能是 abstract
• 无法在类型参数中引用当前类型

最佳答案

这是我会做的。如果您可以使用 Guava(由 Google 编写和使用的 Google 库)，我建议您先向下滚动并查看其他解决方案。

普通 Java

首先，首先添加一个方法来从您的订阅者那里获取类:

public interface Subscriber<N extends News> {
    void onNews(N news);
    Class<N> getSupportedNewsType();
}

然后在实现的时候:

public class MySubscriber implements Subscriber<MyNews> {

    // ...

    public Class<MyNews> getSupportedNewsType() {
        return MyNews.class;
    }
}

在您的聚合器中，包含一个未键入键和值的映射:

private Map<Class<?>, Set<Subscriber<?>> subscribersByClass = ... ;

另请注意，Guava 有一个多图实现，可以为您完成多个值的键。只需谷歌“Guava Multimap”，您就会找到它。

注册订阅者:

public <N extends News> void register(Subscriber<N> subscriber) {
    // The method used here creates a new set and puts it if one doesn't already exist
    Set<Subscriber<?>> subscribers = getSubscriberSet(subscriber.getSupportedNewsType());
    subscribers.add(subscriber);
}

并发送:

@SuppressWarnings("unchecked");
public <N extends News> void dispatch(N news) {
    Set<Subscriber<?>> subs = subscribersByClass.get(news.getClass());
    if (subs == null)
        return;

    for (Subscriber<?> sub : subs) {
        ((Subscriber<N>) sub).onNews(news);
    }
}

注意这里的 Actor 阵容。由于 register 之间泛型的性质，这将是安全的方法和 Subscriber接口(interface)，前提是没有人做一些可笑的错误，比如原始输入，如 implements Subscriber (没有通用参数)。 SuppressWarnings注释禁止编译器发出有关此转换的警告。

以及您检索订阅者的私有(private)方法:

private Set<Subscriber<?>> getSubscriberSet(Class<?> clazz) {
    Set<Subscriber<?>> subs = subscribersByClass.get(news.getClass());
    if (subs == null) {
        subs = new HashSet<Subscriber<?>>();
        subscribersByClass.put(subs);
    }
    return subs;
}

你的 private方法和字段不需要类型安全。它不会引起任何问题，因为 Java 的泛型是通过删除实现的，所以这里的所有集合无论如何都只是一组对象。试图使它们类型安全只会导致讨厌的、不必要的强制转换，这与其正确性无关。

重要的是你的 public方法是类型安全的。 Subscriber 中声明泛型的方式和 Aggregator 上的公共(public)方法，打破它的唯一方法是通过原始类型，就像我上面说的那样。简而言之，每个 Subscriber只要没有不安全的强制转换或原始输入，传递给寄存器的保证接受您注册的类型。

使用 Guava

或者，您可以查看 Guava 的 EventBus .这会更容易，IMO，对于你正在尝试做的事情。

Guava 的 EventBus类使用注释驱动的事件调度而不是接口(interface)驱动。这真的很简单。你不会有 Subscriber界面了相反，您的实现将如下所示:

public class MySubscriber {
    // ...

    @Subscribe
    public void anyMethodNameYouWant(MyNews news) {
        // Handle news
    }
}

@Subscribe Guava 的注释信号 EventBus它应该在以后记住该方法进行调度。然后注册它并派发事件，使用 EventBus实例:

public class Aggregator {
    private EventBus eventBus = new EventBus();

    public void register(Object obj) {
        eventBus.register(obj);
    }

    public void dispatch(News news) {
        eventBus.dispatch(news);
    }
}

这将自动找到接受 news 的方法反对并为您 dispatch 。您甚至可以在同一类(class)中多次订阅:

public class MySubscriber {
    // ...

    @Subscribe
    public void anyMethodNameYouWant(MyNews news) {
        // Handle news
    }

    @Subscribe
    public void anEntirelyDifferentMethod(MyNews news) {
        // Handle news
    }
}

或者对于同一订阅者中的多个类型:

public class MySubscriber {
    // ...

    @Subscribe
    public void handleNews(MyNews news) {
        // Handle news
    }

    @Subscribe
    public void handleNews(YourNews news) {
        // Handle news
    }
}

最后，EventBus尊重层次结构，所以如果你有一个扩展 MyNews 的类，例如 MyExtendedNews , 然后调度 MyExtendedNews事件也会传递给那些关心MyNews的人事件。接口(interface)也是如此。通过这种方式，您甚至可以创建一个全局订阅者:

public class GlobalSubscriber {
    // ...

    @Subscribe
    public void handleAllTheThings(News news) {
        // Handle news
    }
}

关于java - 泛型和( super ？)类型标记可以帮助构建类型安全的新闻聚合器吗？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/13038298/