将一般事件传递给番石榴事件总线？

Question

我变得非常喜欢Google Gauva的EventBus，以至于我想把它包含在我的Swing GridBagBuilder API中。我们的目标是获取一个Swing组件，在任意事件中用它做一些事情，并将其订阅到EventBus。问题是我认为EventBus完成的反射操作不喜欢我的任意事件类型的泛型。

本质上，该方法接受双消费者，其中C是Swing组件，E是订阅EventBus的任意事件类型。

public <E> void subscribe(EventBus eventBus, BiConsumer<C,E> consumer) { 
    eventBus.register(new Object() { 
        @Subscribe
        public void processEvent(E event) { 
            try { 
            consumer.accept(comp, event);
            } catch (Exception e) { 
                e.printStackTrace();
            }
        }
   });
}

事件总线似乎在工作，但我一直收到奇怪的< code>ClassCastException错误。有什么办法能让我成功吗？还是我想要实现的目标注定要失败？

更新:这里有一个SSCCE。当有多种事件类型时，它就崩溃了，在某个地方泛型和内部反射机制被搞乱了，它不能区分一种事件类型和另一种事件类型。

import java.awt.Component;
import java.util.function.BiConsumer;

import javax.swing.JButton;

import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;

public class EventBusTest<C extends Component> {
    private final C comp;

    public static void main(String[] args) {
        final EventBus eventBus = new EventBus();

        EventBusTest<JButton> test = new EventBusTest<>(new JButton("Hello"));
        test.subscribe(eventBus, (JButton c, SomeEvent e) -> System.out.println("Hello"));
        test.subscribe(eventBus, (JButton c, SomeOtherEvent e) -> System.out.println("World"));

        eventBus.post(new SomeEvent());
    }

    private EventBusTest(C comp) { 
        this.comp = comp;
    }
    public<E> void subscribe(EventBus eventBus, BiConsumer<C,E> consumer) { 
        eventBus.register(new Object() { 
            @Subscribe
            public void processEvent(E event) { 
                try { 
                consumer.accept(comp, event);
                } catch (Exception e) { 
                    e.printStackTrace();
                }
            }
       });
    }

    private static final class SomeEvent {}
    private static final class SomeOtherEvent {}
}

这是控制台打印...

java.lang.ClassCastException: com.swa.rm.pricing.EventBusTest$SomeEvent cannot be cast to com.swa.rm.pricing.EventBusTest$SomeOtherEvent
    at com.swa.rm.pricing.EventBusTest$$Lambda$14/28594521.accept(Unknown Source)
    at com.swa.rm.pricing.EventBusTest$1.processEvent(EventBusTest.java:32)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
    at java.lang.reflect.Method.invoke(Unknown Source)
    at com.google.common.eventbus.EventSubscriber.handleEvent(EventSubscriber.java:74)
    at com.google.common.eventbus.SynchronizedEventSubscriber.handleEvent(SynchronizedEventSubscriber.java:47)
    at com.google.common.eventbus.EventBus.dispatch(EventBus.java:322)
    at com.google.common.eventbus.EventBus.dispatchQueuedEvents(EventBus.java:304)
    at com.google.common.eventbus.EventBus.post(EventBus.java:275)
    at com.swa.rm.pricing.EventBusTest.main(EventBusTest.java:21)
Hello

Answer 1

在 subscribe（） 中的匿名 Object 子类中的类型参数 E 将始终被删除，因为没有具体的类型来重新定义它。E 的擦除只是 Object，因此没有什么可以阻止使用任何类型调用 processEvent（） 方法。

要解决此问题，您需要传递类型令牌（Class