EJB 3.0规范提供了注释，可以应用于字段或setter方法以注入依赖项. EJB容器使用全局JNDI注册表来定位依赖项.以下注释在EJB 3.0中用于依赖注入.
@EJB : 用于注入其他EJB引用.
@Resource : 用于注入数据源或单例服务，如sessionContext，timerService等.
使用步骤@EJB
@EJB可以按以下方式在字段或方法上使用 :
public class LibraryMessageBean implements MessageListener { //dependency injection on field. @EJB LibraryPersistentBeanRemote libraryBean; ...}public class LibraryMessageBean implements MessageListener { LibraryPersistentBeanRemote libraryBean; //dependency injection on method. @EJB(beanName="com.IT屋.stateless.LibraryPersistentBean") public void setLibraryPersistentBean( LibraryPersistentBeanRemote libraryBean) { this.libraryBean = libraryBean; } ...}使用@Resource的步骤
@Resource通常用于注入EJB容器提供的单例.
public class LibraryMessageBean implements MessageListener { @Resource private MessageDrivenContext mdctx; ...}示例应用程序
让我们创建一个测试EJB应用程序在EJB中测试依赖注入服务.
| Step | 描述 |
|---|---|
| 1 | 在包 com.it1352.timer 下创建一个名为 EjbComponent 的项目，如 EJB中所述 - 创建申请章. |
| 2 | 使用在 EJB - 消息驱动Bean 章节中创建的Bean.保持其余文件不变. |
| 3 | 清理并构建应用程序以确保业务逻辑按照要求运行. |
| 4 | 最后，在JBoss Application Server上以jar文件的形式部署应用程序.如果JBoss应用服务器尚未启动，它将自动启动. |
| 5 | 现在创建EJB客户端，一个基于控制台的应用程序，其方式与主题创建 EJB - 创建应用程序章节中所述的相同客户端访问EJB . |
EJBComponent(EJB模块)
LibraryMessageBean.java
package com.tuturialspoint.messagebean; import com.it1352.entity.Book; import com.it1352.stateless.LibraryPersistentBeanRemote; import javax.annotation.Resource;import javax.ejb.ActivationConfigProperty;import javax.ejb.EJB;import javax.ejb.MessageDriven;import javax.ejb.MessageDrivenContext;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageListener;import javax.jms.ObjectMessage; @MessageDriven( name = "BookMessageHandler", activationConfig = { @ActivationConfigProperty( propertyName = "destinationType", propertyValue = "javax.jms.Queue"), @ActivationConfigProperty( propertyName = "destination", propertyValue ="/queue/BookQueue") })public class LibraryMessageBean implements MessageListener { @Resource private MessageDrivenContext mdctx; @EJB LibraryPersistentBeanRemote libraryBean; public LibraryMessageBean() { } public void onMessage(Message message) { ObjectMessage objectMessage = null; try { objectMessage = (ObjectMessage) message; Book book = (Book) objectMessage.getObject(); libraryBean.addBook(book); }catch (JMSException ex) { mdctx.setRollbackOnly(); } } }EJBTester(EJB客户端)
EJBTester .java
package com.it1352.test; import com.it1352.entity.Book; import com.it1352.stateless.LibraryPersistentBeanRemote; import java.io.BufferedReader;import java.io.FileInputStream;import java.io.IOException;import java.io.InputStreamReader;import java.util.List;import java.util.Properties;import javax.jms.ObjectMessage;import javax.jms.Queue;import javax.jms.QueueConnection;import javax.jms.QueueConnectionFactory;import javax.jms.QueueSender;import javax.jms.QueueSession;import javax.naming.InitialContext;import javax.naming.NamingException; public class EJBTester { BufferedReader brConsoleReader = null; Properties props; InitialContext ctx; { props = new Properties(); try { props.load(new FileInputStream("jndi.properties")); } catch (IOException ex) { ex.printStackTrace(); } try { ctx = new InitialContext(props); } catch (NamingException ex) { ex.printStackTrace(); } brConsoleReader = new BufferedReader(new InputStreamReader(System.in)); } public static void main(String[] args) { EJBTester ejbTester = new EJBTester(); ejbTester.testMessageBeanEjb(); } private void showGUI() { System.out.println("**********************"); System.out.println("Welcome to Book Store"); System.out.println("**********************"); System.out.print("Options \n1. Add Book\n2. Exit \nEnter Choice: "); } private void testMessageBeanEjb() { try { int choice = 1; Queue queue = (Queue) ctx.lookup("/queue/BookQueue"); QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("ConnectionFactory"); QueueConnection connection = factory.createQueueConnection(); QueueSession session = connection.createQueueSession( false, QueueSession.AUTO_ACKNOWLEDGE); QueueSender sender = session.createSender(queue); while (choice != 2) { String bookName; showGUI(); String strChoice = brConsoleReader.readLine(); choice = Integer.parseInt(strChoice); if (choice == 1) { System.out.print("Enter book name: "); bookName = brConsoleReader.readLine(); Book book = new Book(); book.setName(bookName); ObjectMessage objectMessage = session.createObjectMessage(book); sender.send(objectMessage); } else if (choice == 2) { break; } } LibraryPersistentBeanRemote libraryBean = (LibraryPersistentBeanRemote) ctx.lookup("LibraryPersistentBean/remote"); List booksList = libraryBean.getBooks(); System.out.println("Book(s) entered so far: " + booksList.size()); int i = 0; for (Book book:booksList) { System.out.println((i+1)+". " + book.getName()); i++; } } catch (Exception e) { System.out.println(e.getMessage()); e.printStackTrace(); }finally { try { if(brConsoleReader !=null) { brConsoleReader.close(); } } catch (IOException ex) { System.out.println(ex.getMessage()); } } } } EJBTester执行以下任务 :
从jndi.properties加载属性并初始化InitialContext对象.
在testStatefulEjb()方法中，使用名称"/queue/BookQueue"完成jndi查找，以获取Jboss中可用队列的引用.然后使用队列会话创建发件人.
然后向用户显示库存储用户界面，并要求他/她输入选项.
如果用户输入1，系统会要求输入书名，发件人会将书名发送到队列.当JBoss容器在队列中收到此消息时，它会调用消息驱动bean的onMessage方法.我们的消息驱动bean然后使用有状态会话bean addBook()方法保存书.会话Bean通过EntityManager调用将数据库保存在数据库中.
如果用户输入2，则使用名称 - "LibraryStatefulSessionBean/remote"完成另一个jndi查找"再次获取远程业务对象(有状态EJB)并完成书籍列表.
运行客户端以访问EJB
在项目资源管理器中找到EJBTester.java.右键单击EJBTester类并选择运行文件.
在Netbeans控制台中验证以下输出.
run:**********************Welcome to Book Store**********************Options 1. Add Book2. Exit Enter Choice: 1Enter book name: Learn EJB**********************Welcome to Book Store**********************Options 1. Add Book2. Exit Enter Choice: 2Book(s) entered so far: 21. learn java1. learn EJBBUILD SUCCESSFUL (total time: 15 seconds)
上面显示的输出表明我们的消息驱动bean正在接收消息并将书存储在持久存储中，并且从数据库中检索书籍.
我们的消息驱动bean正在使用LibraryPersistentBean使用@EJB注释注入它，如果是异常，MessageDrivenContext，object用于回滚事务.