java EE 8 中的依赖注入 (CDI)

Question

我一直在研究 CDI 以简化代码，并且我一直在尝试将它与 Java EE 8 一起使用。我试图复制现有示例但没有成功。我想知道是否有人可能遇到过同样的问题：

PoolManager 类：

import javax.ejb.Startup;
import javax.ejb.Singleton;
import javax.annotation.PostConstruct;

@Singleton
@Startup
public class PoolManager {

    private Queue<Object> pooledObjects;

    @PostConstruct
    private void init() {
        System.out.println("Hi");
        pooledObjects = new LinkedBlockingQueue<Object>(1_000);
        for (int i = 0; i <= 1000; i++) {
            pooledObjects.offer(i);
        }   
    }


    public void returnObject(Object o) {
        pooledObjects.offer(o);
    }

    public Object borrowObject() {
        return pooledObjects.poll();
    }
}

UsePoolManager 类：

public class UsePoolManager {

    @Inject 
    private PoolManager poolManager;

    public void usePooledObject() {
        Object object = this.poolManager.borrowObject();
        System.out.println(object);
    }

}

和主要的：

public static void main(String[] args) {

        UsePoolManager user = new UsePoolManager();
        user.usePooledObject();
    }
}

注入似乎在运行时根本不起作用。我没有bean xml（我知道这没有必要，添加它并没有改变任何东西。）。

任何帮助将不胜感激。

谢谢！

---

检查我是使用 SE 还是 EE 进行澄清...

Answer 1

您需要在 JBoss 或 Tomcat 等 JavaEE 容器中运行它，而不是像独立的 JavaSE 应用程序（使用 publis static void main）

Answer 2

为了论证，使用 Java SE 的 CDI 2 容器：

在 Gradle 中：

// https://mvnrepository.com/artifact/org.jboss.weld.se/weld-se-core
compile group: 'org.jboss.weld.se', name: 'weld-se-core', version: '3.0.4.Final'

public class CDI2Fire {

    public static void main(String[] args)  {

        SeContainerInitializer initializer = 
                    SeContainerInitializer.newInstance();

            try (SeContainer container = initializer.disableDiscovery().addPackages(CDI2Fire.class).initialize()) {
                container.select(UsePoolManager.class);
            }
        }
    }

@ApplicationScoped
public class UsePoolManager {

    @Inject 
    private PoolManager poolManager;

    public void init(@Observes @Priority(Interceptor.Priority.APPLICATION - 100)
        @Initialized(ApplicationScoped.class) Object init) throws Exception{
        usePooledObject();
    }

    public void usePooledObject() {
        Object object = this.poolManager.borrowObject();
        System.out.println(object);
    }

}

@Singleton
@Startup
public class PoolManager {

    private Queue<Object> pooledObjects;

    @PostConstruct
    private void init() {
        System.out.println("Hi");
        pooledObjects = new LinkedBlockingQueue<Object>(1_000);
        for (int i = 0; i <= 1000; i++) {
            pooledObjects.offer(i);
        }   
    }


    public void returnObject(Object o) {
        pooledObjects.offer(o);
    }

    public Object borrowObject() {
        return pooledObjects.poll();
    }
}

Answer 3

关于您自己的答案：您通过将业务方法调用 usePooledObject() 移动到初始化侦听器中来更改完整的应用程序逻辑，而不是像原始示例中那样手动调用它。

这可能不是最好的主意，因为在任意初始化事件上疯狂运行的对象很难控制。

因此：您可能错过的一点是，在select() 之后使用get()：

try (SeContainer ...) {
    // replaces the original "new":
    UsePoolManager user = CDI.current().select(UsePoolManager.class).get();
    user.usePooledObject();
}

进一步注意，CDI.current() 的使用消除了在范围内具有具体容器引用的必要性。因此，只要容器处于活动状态，您就可以在应用程序的任何地方使用它。