将几个相同的CDI bean注入一个类？

Question

目前，我的 CDI bean 注入一次就能完成所有工作，但我需要大约 6 到 10 个单独的实例（？），具体取决于我的输入。 （理想情况下，我希望能够根据需要注入动态数量的相同 CDI bean。）

不幸的是，我需要注入 bean，因为该类依赖于另一个 CDI bean。 （见下文2.CDI bean类）

1. 客户端类

@ApplicationScoped
public class Clients {
   Publisher pub;
   Subscriber sub;
   @Inject
   ListenerBean listener;

   public void init(){
      pub = new Publisher();
      sub = new Subscriber(listener);
   }
}

1. CDI bean 类

@Dependent
public class ListenerBean{
   @Inject
   private eventHandler h;

   public void onMessage(Msg msg){
      h.doesSomething();
   }
}

我正在寻找的功能，但不确定那里有什么可用的。我还没有找到任何人想要完成同样的事情。

for(Subscriber s: listOfSubscribers){
   @Inject
   ListenerBean l;
   s = new Subscriber(l);
}

// The only thing I can do right now is
@Inject
ListenerBean listener1;
@Inject
ListenerBean listener2;
@Inject
ListenerBean listener3;
@Inject
ListenerBean listener4;

---

编辑：听众确实需要是可识别的。 （在注入后调用 setter。）可能不是最佳实践，但不确定如何实现这一点-

• 监听器将监听不同的主题（由各自的消费者声明）
• 每个听众都必须根据主题处理他们的消息

@Inject
ListenerBean listener1;
listener1.setTopic("TopicA");

Answer 1

如果您需要注入 @Dependent 范围 bean 的多个 不同 实例，您可以通过 programmatic lookup 来实现 - 换句话说，通过 Instance<T>。

通过Instance 对@Dependent bean 的每个bean 解析都将导致创建一个新的bean 实例。以下代码说明了这一点：

@Inject Instance<ListenerBean> instance;

public void createMultipleBeanInstances() {
  // bean1 and bean2 are two different instances because the bean is @Dependent
  // you can OFC do this in a cycle and generate as many as you like
  ListenerBean bean1 = instance.get(); 
  ListenerBean bean2 = instance.get();
}

请注意，您通过编程查找创建的依赖 bean 的生命周期绑定到 Instance 对象，这意味着只要 Instance 存在，它们就会存在。假设您将@Inject Instance 注入到 bean 中，它将与注入它的 bean 一起被销毁。

Answer 2

我的评论后的解释。不过我可能误解了你的问题。

首先，您的代码看起来基本上类似于多播器的实现：您注入了几个对象，这些对象都实现了一个通用接口来调用相同的方法。

我认为，在尝试注入各种接收器对象时，您基本上遇到了一个 XY 问题：发射器是否真的需要知道接收器，或者事件到达就足够了目标？

如果我的假设是正确的，即您的发射器并不真正需要知道订阅者，您可以简单地使用Event 标准机制：

首先，定义一个消息（可以携带附加信息，但这不是特别需要，只需要一个类）：

public class MyMessage {
     // if needed, add some fields
}

然后，在您的发射器中，注入相应的事件类型，并使用它来触发消息：

@Inject
private Event<MyMessage> myEvent;  // note: type is message, not the bean

...

myEvent.fire(new MyMessage()); // to broadcast the message to everyone who is interested

在您的订阅者中，只需@Observe 消息：

public void theMethodWeWantCalled(@Observes MyMessage messageObject) {
    // do things here
}

就是这样：无需耦合发射器和订阅器。